最近在学习Android开发艺术探索这本书,看到Messenger的跨进程通信,觉得书上讲得不错,所以在这里做个总结。
Messenger的思路很简单,通过它可在不同进程传递Message对象,我们在Message中放入我们需要传递的数据,就可以轻松实现数据的进程间传递了。Messenger的底层是AIDL,它对AIDL做了封装,使我们可以更简单地进行进程间通信。
1.服务端进程
public class MessengerService extends Service {
private Handler handler = new Handler(){
@Override
public void handleMessage(Message msg) {
if (msg.what==MSG){
Toast.makeText(MessengerService.this, msg.getData().getString("msg"), Toast.LENGTH_SHORT).show();
}
}
};
private Messenger messenger = new Messenger(handler);
@Override
public IBinder onBind(Intent intent) {
// TODO: Return the communication channel to the service.
return messenger.getBinder();
}
}
看看这个服务端代码,我们使用了一个Handler处理客户端发送的Message,从Message取出我们所需的数据。
我们新建了一个Messenger对象,从构造参数我们可以看出它和handler相关联。我们在onBind()方法中返回了messenger中的binder对象。
由于我们处理的是跨进程通信,所以别忘了在Manifest文件中给Service加上process属性.
<service
android:name=".MessengerService"
android:process=":remote"/>
我们知道,一个应用的进程默认名称为包名,应用内的所有组件都运行在这个进程内,如果想让某个组件独立运行在另一个进程,那么则加上process属性,这里的“:remote”全程应该是包名:remote,省去了前面的包名。
2.客户端进程##
public class MainActivity extends AppCompatActivity {
private Messenger messenger;
public static final int MSG = 1;
private Button btn;
private ServiceConnection connection = new ServiceConnection(){
@Override
public void onServiceConnected(ComponentName name, IBinder service) {
messenger = new Messenger(service);
Message message = Message.obtain(null,MSG);
Bundle bundle = new Bundle();
bundle.putString("msg","helloworld");
message.setData(bundle);
try {
messenger.send(message);
} catch (RemoteException e) {
e.printStackTrace();
}
}
@Override
public void onServiceDisconnected(ComponentName name) {
}
};
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
btn = (Button) findViewById(R.id.bindService);
btn.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
Intent intent = new Intent(MainActivity.this,MessengerService.class); bindService(intent,connection,BIND_AUTO_CREATE);
}
});
}
@Override
protected void onDestroy() {
unbindService(connection);
super.onDestroy();
}
}
这个代码我们也比较熟悉了,跟平常bindService在客户端和服务端在同一进程的写法相似。区别在于使用了Messenger.
同样地我们在客户端也要新建一个Messenger对象,在构造参数里传入返回的binder对象。
我们在Message中放入我们要的数据,借助的是Bundle,最后用messenger.send(message);发送过去即可。
我们运行一下程序,可见服务端收到了Messenger发来的信息。
在Messenger传输数据需要将数据放入Message.我们都知道,跨进程运输的数据需要实现序列化,所以Messenger和Message必定实现了Parcelable接口,看下源码
public final class Message implements Parcelable
public final class Messenger implements Parcelable
Message的载体有what,arg1,arg2,Bundle,object和replyTo,在同一进程内,obj很常用,但是在跨进程中就不行了,只有系统提供的Parcelable对象才可以通过它进行传输,我们自己定义的Parcelable对象是无法通过它传输的。但是我们还有Bundle,只要对象实现了Parcelable接口,利用bundle.putExtra(key,object)就能传递数据了,这里我们只演示传递String类型数据。
接下来我们再来看看服务端如何回复客户端发送的消息。
当服务端接收到客户端的消息时,我们也新建一个Messenger对象回复客户端,代码如下
//重点在这句话
Messenger messenger = msg.replyTo;
Message replyMessage = Message.obtain(null,REPLYMESSAGE);
Bundle bundle = new Bundle();
bundle.putString("reply","好的我知道了");
replyMessage.setData(bundle);
messenger对象由replyTo赋值。而replyTo来自客户端的Messenger,这样两者就建立联系。
再看看客户端的修改,我们新建了Handler对象和Mssenger对象。
private Handler getReplyHandler = new Handler(){
@Override
public void handleMessage(Message msg) {
if(msg.what==REPLYMESSAGE){
Toast.makeText(MainActivity.this,msg.getData().getString("reply"),Toast.LENGTH_SHORT).show();
}
}
};
private Messenger getReplyMessenger = new Messenger(getReplyHandler);
然后我们需要把接收服务端回复的Messenger通过Message的replyTo参数传递给服务端,这句话有点难理解,多看几遍。
private ServiceConnection connection = new ServiceConnection(){
@Override
public void onServiceConnected(ComponentName name, IBinder service) {
messenger = new Messenger(service);
Message message = Message.obtain(null,MSG);
Bundle bundle = new Bundle();
bundle.putString("msg","成功进行跨进程通信!");
message.setData(bundle);
//这句话与服务端的Messenger messenger = msg.replyTo;相对应,缺一不可
message.replyTo = getReplyMessenger;
try {
messenger.send(message);
} catch (RemoteException e) {
e.printStackTrace();
}
}
再运行一下程序
最后再放上一张Messenger的工作原理,找不到书上的原图,只能自己画了。