以前讲到跨进程通信，我们总是第一时间想到AIDL(Android接口定义语言)，实际上，使用Messenger在很多情况下是比使用AIDL简单得多的。
大家看到Messenger可能会很轻易的联想到Message，然后很自然的进一步联想到Handler——没错，Messenger的核心其实就是Message以及Handler来进行线程间的通信。
以下是如何使用Messenger的步骤:
- Service需要实现一个Hanlder，用以处理从客户端收到的消息
- 用该Handler创建一个Messenger对象，Messenger对象内部会引用该Handler对象
- 用创建好的Messenger对象获得一个IBinder实例，并且将该IBinder通过Service的onBind方法返回给各个客户端
- 客户端通过收到的IBinder对象实例化一个Messenger对象，该Messenger内部指向指向Service中的Handler。客户端通过该Messenger对象就可以向Service中的Hanlder发送消息。
- Service中的Hanlder收到消息后，在Handler中的handleMessage方法中处理消息。
- 通过上面的第4步与第5步，就完成了客户端向Service发送消息并且Service接收到消息的单向通信过程，即客户端 -> Service。如果要实现Service向客户端回消息的通信过程，即Service -> 客户端，那么前提是在客户端中也需要像Service一样内部维护有一个指向Handler的Messenger。当在第四步中客户端向Service发送信息时，将Message的replyTo属性设置为客户端自己的Messenger。这样在第5步Service在Handler的handleMessage中处理收到的消息时，可以通过Message的Messenger再向客户端发送Message，这样客户端内维护的Handler对象就会收到来自于Service的Message，从而完成Service向客户端发送消息且客户端接收到消息的通信过程。
综上六步就能完成客户端与Service的跨进程双向通信过程:
客户端 -> Service -> 客户端
简单的例子（客户端向服务器端发送消息，服务器接收）：
//服务端
public class MessengerServiceDemo extends Service {
static final int MSG_SAY_HELLO = 1;
class ServiceHandler extends Handler {
@Override
public void handleMessage(Message msg) {
switch (msg.what) {
case MSG_SAY_HELLO:
//当收到客户端的message时，显示hello
Toast.makeText(getApplicationContext(), "hello!", Toast.LENGTH_SHORT).show();
break;
default:
super.handleMessage(msg);
}
}
}
final Messenger mMessenger = new Messenger(new ServiceHandler());
@Nullable
@Override
public IBinder onBind(Intent intent) {
Toast.makeText(getApplicationContext(), "binding", Toast.LENGTH_SHORT).show();
//返回给客户端一个IBinder实例
return mMessenger.getBinder();
}
}
服务端主要是返给客户端一个IBinder实例，以供服务端构造Messenger，并且处理客户端发送过来的Message。当然，不要忘了要在Manifests文件里面注册.
//客户端
public class ActivityMessenger extends Activity {
static final int MSG_SAY_HELLO = 1;
Messenger mService = null;
boolean mBound;
private ServiceConnection mConnection = new ServiceConnection() {
public void onServiceConnected(ComponentName className, IBinder service) {
//接收onBind()传回来的IBinder，并用它构造Messenger
mService = new Messenger(service);
mBound = true;
}
public void onServiceDisconnected(ComponentName className) {
mService = null;
mBound = false;
}
};
//调用此方法时会发送信息给服务端
public void sayHello(View v) {
if (!mBound) return;
//发送一条信息给服务端
Message msg = Message.obtain(null, MSG_SAY_HELLO, 0, 0);
try {
mService.send(msg);
} catch (RemoteException e) {
e.printStackTrace();
}
}
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
}
@Override
protected void onStart() {
super.onStart();
//绑定服务端的服务，此处的action是service在Manifests文件里面声明的
Intent intent = new Intent();
intent.setAction("com.lypeer.messenger");
//不要忘记了包名，不写会报错
intent.setPackage("com.lypeer.ipcserver");
bindService(intent, mConnection, Context.BIND_AUTO_CREATE);
}
@Override
protected void onStop() {
super.onStop();
// Unbind from the service
if (mBound) {
unbindService(mConnection);
mBound = false;
}
}
}
客户端就主要是发起与服务端的绑定，以及通过onServiceConnected()方法来过去服务端返回来的IBinder，借此构造Messenger，从而可以通过发送Message的方式与服务端进行交互。
服务器接收消息后回复消息给客户端
客户端修改：
客户端需要添加一个handler用于接收消息
//clientMessenger是客户端自身的Messenger，内部指向了ClientHandler的实例
//MyService可以通过Message的replyTo得到clientMessenger，从而MyService可以向客户端发送消息，
//并由ClientHandler接收并处理来自于Service的消息
private Messenger clientMessenger = new Messenger(new ClientHandler());
//客户端用ClientHandler接收并处理来自于Service的消息
private class ClientHandler extends Handler {
@Override
public void handleMessage(Message msg) {
Log.i("DemoLog", "ClientHandler -> handleMessage");
if(msg.what == RECEIVE_MESSAGE_CODE){
Bundle data = msg.getData();
if(data != null){
String str = data.getString("msg");
Log.i("DemoLog", "客户端收到Service的消息: " + str);
}
}
}
}
...
//在sayHello(View v)中发送消息之前插入
//需要将Message的replyTo设置为客户端的clientMessenger，
//以便Service可以通过它向客户端发送消息
msg.replyTo = clientMessenger;
服务端修改：
在服务端的handler获取客户端发送的msg.replyTo
//通过Message的replyTo获取到客户端自身的Messenger，
//Service可以通过它向客户端发送消息
clientMessenger = msg.replyTo;
if(clientMessenger != null){
Log.i("DemoLog", "MyService向客户端回信");
Message msgToClient = Message.obtain();
msgToClient.what = SEND_MESSAGE_CODE;
//可以通过Bundle发送跨进程的信息
Bundle bundle = new Bundle();
bundle.putString("msg", "你好，客户端，我是MyService");
msgToClient.setData(bundle);
try{
clientMessenger.send(msgToClient);
}catch (RemoteException e){
e.printStackTrace();
Log.e("DemoLog", "MyService向客户端发送信息失败: " + e.getMessage());
}
}
