哈喽，大家好，接触Android的同学们对AIDL这个概念肯定不会陌生，就算没用过，那肯定也是听过。很多刚开始接触Android的朋友可能会感觉AIDL很难。今天，就用Messenger来教大家如何简单的实现跨进程通信。
Messenger
Messenger翻译为信使，通过它可以在不同的进程中传递Message对象。Messenger就一种轻量级的IPC方案，它的底层实现还是AIDL，只是Android帮我们把大部分方法都封装在了里面，这样使用起来会更加方便。
下面用一个简单的例子来看看Messenger是如何实现跨进程通信的。
在写代码之前，先理一理Messenger跨进程通信的步骤：
服务端
- 首先我们要在服务端创建一个Service来处理客户的连接请求。
- 在Service中创建一个Handler并通过它创建一个Messenger。
- 通过Service的onBind方法将Messenger对象底层的Binder返回。
客户端
- 首先需要绑定服务端Service。
- 用服务端返回的Binder对象创建一个Messenger。
- 然后就可以用Messenger给服务的发送消息。
服务端：
public class OtherService extends Service {
public static final int SERVICE_GET_MESSAGE = 0;
@Override
public IBinder onBind(Intent intent) {
//将messenger底层的Binder对象返回给客户端。
return messenger.getBinder();
}
private static class MessageHandler extends Handler {
@Override
public void handleMessage(Message msg) {
switch (msg.what) {
case SERVICE_GET_MESSAGE:
//接受到客户端发送的消息。
Log.d("Test", "get message = " + msg.getData().getString("msg"));
break;
default:
super.handleMessage(msg);
}
}
}
private final Messenger messenger = new Messenger(new MessageHandler());
}
客户端:
public class MainActivity extends AppCompatActivity {
private Messenger messenger;
public static final int ACTIVITY_HANDLER_MSG = 0;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
//绑定服务
Intent intent = new Intent(this, OtherService.class);
bindService(intent, connection, Context.BIND_AUTO_CREATE);
}
private ServiceConnection connection = new ServiceConnection() {
@Override
public void onServiceConnected(ComponentName name, IBinder service) {
//用服务端返回的Binder对象创建新的Messenger对象
messenger = new Messenger(service);
Message sendMsg = Message.obtain(null, OtherService.SERVICE_GET_MESSAGE);
Bundle bundle = new Bundle();
bundle.putString("msg", "this is a msg");
sendMsg.setData(bundle);
try {
//客户端给服务端发送消息
messenger.send(sendMsg);
} catch (Exception e) {
e.printStackTrace();
}
}
@Override
public void onServiceDisconnected(ComponentName name) {
}
};
}
上面是一个很简单的例子，在启动应用后，客户端绑定服务端，然后服务端接收到客户端发送的消息。一些相关注释已经标在了代码中，大家可以简单看看。
上面的例子是客户端单方面给服务端发送消息，如果服务端想要回复客户端该怎么办呢。这个时候我们可以在客户端创建一个Handler，然后用Handler生成一个Messenger对象，最后用Message的replyTo将Messenger对象传递给服务端，这时候服务端就可以用客户端传递过来的Messenger对象来给客户端发送消息了。
下面我们来看看如何修改代码
服务端：
private static class MessageHandler extends Handler {
@Override
public void handleMessage(Message msg) {
switch (msg.what) {
case SERVICE_GET_MESSAGE:
Log.d("Test", "get message = " + msg.getData().getString("msg"));
//获取客户端传递过来的Messenger对象
Messenger activityMessager = msg.replyTo;
Message message = Message.obtain(null, MainActivity.ACTIVITY_HANDLER_MSG);
Bundle bundle = new Bundle();
bundle.putString("msg", "客户端发送消息成功");
message.setData(bundle);
try {
//给客户端发送消息
activityMessager.send(message);
} catch (Exception e) {
e.printStackTrace();
}
break;
default:
super.handleMessage(msg);
}
}
}
服务端的改动很小，就是接收到客户端传递过来的Messenger后用这个Messenger来和客户端通信。
客户端：
private static class MessageHandler extends Handler {
@Override
public void handleMessage(Message msg) {
switch (msg.what) {
case ACTIVITY_HANDLER_MSG:
Log.d("Test", "服务端消息:" + msg.getData().getString("msg"));
break;
default:
super.handleMessage(msg);
}
}
}
private final Messenger serviceMessage = new Messenger(new MessageHandler());
首先我们创建客户端接收消息的Handler和发送消息的Messenger。
private ServiceConnection connection = new ServiceConnection() {
@Override
public void onServiceConnected(ComponentName name, IBinder service) {
messenger = new Messenger(service);
Message sendMsg = Message.obtain(null, OtherService.SERVICE_GET_MESSAGE);
Bundle bundle = new Bundle();
bundle.putString("msg", "this is a msg");
sendMsg.setData(bundle);
//将客户端的Messenger传递给服务端
sendMsg.replyTo = serviceMessage;
try {
messenger.send(sendMsg);
} catch (Exception e) {
e.printStackTrace();
}
}
@Override
public void onServiceDisconnected(ComponentName name) {
}
};
然后在绑定成功Service的时候将客户端的Messenger对象传递给服务端。
这样就实现了客户端与服务端的双方通信。
到这里就讲完了Messenger的简单使用，如果文中有错误的地方欢迎大家指正，如果有疑惑的地方，欢迎大家留言讨论。
