美文网首页
2.4 Android中的IPC方式(一)

2.4 Android中的IPC方式(一)

作者: 武安长空 | 来源:发表于2016-06-16 13:04 被阅读84次

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一次发送一个请求,是串行,不存在并发。因此服务端不需要考虑线程同步问题。

相关文章

  • IPC 机制(下)

    2.4 Android 中的 IPC 方式 2.4.1 使用 Bundle Bundle 实现了 Parcelab...

  • Android中的IPC方式

    2.4 Android中的IPC方式 在上节中,我们介绍了IPC的几个基础知识:序列化和Binder,本节开始详细...

  • 2.4 Android中的IPC方式(一)

    1. 实现IPC(跨进程)方法一 Bundle Bundle可以通过Intent在跨进程时带过去,它支持基本数据类...

  • Android中的IPC方式——Binder(三)

    Android中的IPC方式——Binder(一) Android中的IPC方式——Binder(二) 基于A...

  • 2.4 Android中的IPC方式(二)

    1. AIDL简介 Messenger是串行处理客户端发来的消息,如果大量的消息同时发送到服务端,服务端只能一个个...

  • 2.4 Android中的IPC方式(四)

    1. Socket简介 Socket也称为套接字,是网络通信中的概念。它分为流式套接字和用户数据报套接字,分别对应...

  • 2.4 Android中的IPC方式(三)

    1. ContentProvider简介 ContentProvider是Android中专门用于不同应用间进行数...

  • Android IPC(二)

    Android IPC Android中的IPC方式 使用Bundle Android的四大组件都支持在Inten...

  • Binder

    前言 Android系统是基于Linux系统的,理论上应该使用Linux内置的IPC方式。Linux中的IPC方式...

  • Android匿名共享内存(Ashmem)

    Android匿名共享内存 在Android中我们熟知的IPC方式有Socket、文件、ContentProvid...

网友评论

      本文标题:2.4 Android中的IPC方式(一)

      本文链接:https://www.haomeiwen.com/subject/imumdttx.html