2.4 Android中的IPC方式(一)

1. 实现IPC(跨进程)方法一 Bundle

Bundle可以通过Intent在跨进程时带过去,它支持基本数据类型,实现了Parcelable接口的对象,实现了Serializable接口的对象以及其他一些Android支持的特殊对象。

2. 特殊场景

A进程进行一个计算,计算完成后启动B进程的一个组件并把计算结果传递给B进程。问题是该结果不支持放入Bundle。
思考解决方式如下:A进程启动B进程的服务完成计算,B进程的服务把计算结果给目标组件。

3. 实现IPC(跨进程)方法二 文件共享

两个进程读写同一文件可以实现跨进程通信。windows上,一个文件如果被加了排斥锁将会导致其他进程无法对其进行访问,包括读写。而Android是基于Linux的,使得其并发读写文件没有限制。所以文件共享的方式要考虑并发问题。下面的代码是MainActivity中序列化对象到文件,不同进程的SecondActivity反序列化文件到对象。

// 序列化
try {
    User user = new User(110, "allen");
    File cache = new File(getCacheDir(), "cache.txt");
    if (!cache.exists()) {
        cache.createNewFile();
    }
    
    ObjectOutputStream out = new ObjectOutputStream(new FileOutputStream(cache.getAbsoluteFile()));
    out.writeObject(user);
    out.close();
    Log.e("aaa","---------"+user.toString());
} catch (IOException e) {
    e.printStackTrace();
}
// 反序列化
try {
    File cache = new File(getCacheDir(), "cache.txt");
    if (!cache.exists()) {
        cache.createNewFile();
    }
    
    ObjectInputStream in = new ObjectInputStream(new FileInputStream(cache.getAbsoluteFile()));
    User newUser = (User) in.readObject();
    in.close();
    Log.e("aaa","---------"+newUser.toString());
} catch (IOException e) {
    e.printStackTrace();
} catch (ClassNotFoundException e) {
    e.printStackTrace();
}

文件类型没有要求,比如txt的,xml的。但SharedPreferences是个例外,SharedPrefrences是Android提供的轻量级存储方案,它以键值对的方式来存储数据,在底层实现上采用了xml文件来存储。其目录位于/data/data/packageName/shared_prefs目录下。从本质上来说,SharedPreference也属于文件的一种,但是对于系统对它的读写有一定的缓存策略,即在内存中会有一份SharedPreference文件的缓存。因此在多进程模式下,系统对它的读写就变得不可靠。因此不建议进程间通信使用SharedPreference。

3. Messenger简介

Messanger可以翻译为信使,顾名思义,通过它可以在不同的进程中传递Message对象。它是一种轻量级的IPC方案,它的底层实现了AIDL。(书中说是根据构造方法的写法和aidl相似,有些牵强)。
下面看下Messenger的代码:

public final class Messenger implements Parcelable {
    private final IMessenger mTarget;

    public Messenger(Handler target) {
        mTarget = target.getIMessenger();
    }
    
    public void send(Message message) throws RemoteException {
        mTarget.send(message);
    }
    
    public IBinder getBinder() {
        return mTarget.asBinder();
    }
    // ...
    
    public Messenger(IBinder target) {
        mTarget = IMessenger.Stub.asInterface(target);
    }
}

重点还是IMessenger是个aidl接口。用everything搜一下可以搜到以下结果:

Paste_Image.png

4. 简单Messenger跨进程实现

服务端:

public class MessengerService extends Service {
    private Handler messengerHandler = new Handler() {
        @Override
        public void handleMessage(Message msg) {
            super.handleMessage(msg);
            switch (msg.what) {
                case 0:
                    String text = msg.getData().getString("msg");
                    Log.e("aaa", text);
                    break;
            }
        }
    };
    private Messenger messenger = new Messenger(messengerHandler);

    public MessengerService() {
    }

    @Override
    public IBinder onBind(Intent intent) {
        return messenger.getBinder();
    }
}

客户端:

public class MessengerActivity extends AppCompatActivity {

    Messenger messenger;
    ServiceConnection serviceConnection = new ServiceConnection() {
        @Override
        public void onServiceConnected(ComponentName name, IBinder service) {
            messenger = new Messenger(service);
            // 发消息
            Message msg = Message.obtain();
            msg.what = 0;
            Bundle bundle = new Bundle();
            bundle.putString("msg", "hello, this is client.");
            msg.setData(bundle);
            try {
                messenger.send(msg);
            } catch (RemoteException e) {
                e.printStackTrace();
            }
        }

        @Override
        public void onServiceDisconnected(ComponentName name) {

        }
    };

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_messenger);

        Intent intent = new Intent(this, MessengerService.class);
        bindService(intent, serviceConnection, BIND_AUTO_CREATE);
    }

    @Override
    protected void onDestroy() {
        super.onDestroy();
        unbindService(serviceConnection);
    }
}

Service定义在单独的进程中

<service
    android:name="._2activity.Messenger.MessengerService"
    android:enabled="true"
    android:exported="true"
    android:process=":remote" />

Messenger支持的数据类型实际是Message支持的数据类型,Message支持Bundle,所以适用性很强。

5. 实现客户端发信息并且服务端响应

上面的例子中服务端定义了接受消息的Messenger(也就是参数是Handler的),客户端通过Binder拿到服务端的Messenger,然后用服务端的Messenger发消息给服务端。同样,服务端要回应,需要有客户端接受消息的Messenger。
Activity中如下:

// 定义客户端接受消息的Messenger
Messenger clientMessenger = new Messenger(new Handler(){
    @Override
    public void handleMessage(Message msg) {
        super.handleMessage(msg);
        Log.e("aaa",msg.getData().getString("reply"));
    }
});
// 通过Message的replyto参数给服务端
// 发消息
Message msg = Message.obtain();
msg.what = 0;
Bundle bundle = new Bundle();
bundle.putString("msg", "hello, this is client.");
msg.setData(bundle);
// 把接收消息的Messenger通过Message的replyTo给服务端
msg.replyTo = clientMessenger;
messenger.send(msg);

服务端接收消息后,拿到客户端的Messenger,再给客户端发消息。

private Handler messengerHandler = new Handler() {
    @Override
    public void handleMessage(Message msg) {
        super.handleMessage(msg);
        switch (msg.what) {
            case 0:
                String text = msg.getData().getString("msg");
                Log.e("aaa", text);
                // 服务端回应
                Messenger clientMessenger = msg.replyTo;
                Message message = Message.obtain();
                Bundle bundle = new Bundle();
                bundle.putString("reply","收到收到已收到");
                message.setData(bundle);
                try {
                    clientMessenger.send(message);
                } catch (RemoteException e) {
                    e.printStackTrace();
                }
                break;
        }
    }
};

6. 总结

Messenger很强大,它是实现轻量级IPC的方案。在普通开发中,还可以用于Service调Activity中的方法,或者Activity调Service中的方法。之前说Activity调Service中的方法通过Binder,Service调Activity中的方法通过广播,这里又加了一种方案。
另外,Messenger一次发送一个请求,是串行,不存在并发。因此服务端不需要考虑线程同步问题。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 215,133评论 6 497
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 91,682评论 3 390
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 160,784评论 0 350
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 57,508评论 1 288
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,603评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,607评论 1 293
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,604评论 3 415
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,359评论 0 270
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,805评论 1 307
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,121评论 2 330
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,280评论 1 344
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,959评论 5 339
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,588评论 3 322
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,206评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,442评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,193评论 2 367
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,144评论 2 352

推荐阅读更多精彩内容