1. 使用Messenger的原理
Messenger 可以译为信使，通过他可以在不同进程中换地Message对象，在Message中放入我们需要传递的数据，就可以轻松的实现数据的进程间传递了，Messenger是一种轻量级的IPC方案，它的底层实现是AIDL，为什么这么说呢，我们来看下Messenger这个类就知道了，从Messenger的构造方法中，我们可以看出，不管是IMessenger还是Stub.asInterface，这种使用方法都表明它的底层是AIDL，如果不明白为什么，可以看我的上一篇文章。
/**
* Create a new Messenger pointing to the given Handler. Any Message
* objects sent through this Messenger will appear in the Handler as if
* {@link Handler#sendMessage(Message) Handler.sendMessage(Message)} had
* been called directly.
*
* @param target The Handler that will receive sent messages.
*/
public Messenger(Handler target) {
mTarget = target.getIMessenger();
}
/**
* Create a Messenger from a raw IBinder, which had previously been
* retrieved with {@link #getBinder}.
*
* @param target The IBinder this Messenger should communicate with.
*/
public Messenger(IBinder target) {
mTarget = IMessenger.Stub.asInterface(target);
}
Messenger 的使用方法很简单，它对AIDL进行了封装，使我们可以更简单的进行进程间通信。同时，由于它一次发送一个请求，因此在服务端我们不用考虑线程同步的问题，这是因为服务端中不存在兵法执行的情形。实现一个Messenger 有如下几个步骤，分为服务端和客户端。
2. Messenger 的实现
(1) 服务端进程
首先，我们需要在服务端创建一个Service来处理客户端的连接请求，同时创建一个Handler并通过它来一个Messenger 对象，然后在Service 的onBind 中返回这个Messenger 对象底层的Binder 即可。
(2) 客户端进程
客户端进程中，首先要绑定服务端的Service，绑定成功之后用服务端返回的IBinder 对象创建一个Messenger ，通过这个Messenger 就可以向服务端发送请求了，发送消息类型为Message 对象，如果需要服务端能够回应客户端，就和服务端一样，我们还需要创建一个新的Messenger ，并吧Messenger 对象通过Message的replyTo参数传递给服务端，服务端通过这个replyTo参数就可以回应客户端。下边来看两个例子，帮助我们理解这些话
(1) 服务端代码
首先来看服务端代码，可以看到 MessengerHandler 用来处理客户端发送的消息，并从消息中取出客户端发来的文本信息。而messenger 是一个 Messenger 对象，他和 MessengerHandler 相关联，并在 onBind方法中返回它里边的 Binder 对象，可以看出，这里的 Messenger 的作用就是将客户端的消息传递给 MessengerHandler 处理。
public class MessengerService extends Service {
private static class MessengerHandler extends Handler {
@Override
public void handleMessage(Message msg) {
switch (msg.what) {
case 1:
Log.e("messages", "ServiceMessages ======== " + msg.getData().getString("msg"));
break;
default:
super.handleMessage(msg);
break;
}
}
}
private final Messenger messenger = new Messenger(new MessengerHandler());
@Nullable
@Override
public IBinder onBind(Intent intent) {
return messenger.getBinder();
}
}
当然，别忘了注册 Service，让它在单独的进程中运行。
<service android:name=".service.MessengerService"
android:process=":remote"></service>
(2) 客户端代码
客户端代码也比较简单，首先我们需要绑定服务端的 MessengerService ，根据服务端返回的 binder 对象来创建 Message 对象并使用此对象向服务端发送消息，下面的代码在 Bundle 中向服务端发送了一句话，上边的服务端会打印这句话。
public class MainActivity extends AppCompatActivity {
/**
* 创建Messenger 通过Messenger可以向服务端发送消息 发送的类型为Message
*/
private Messenger mService;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
//绑定服务
Intent intent = new Intent(this, MessengerService.class);
bindService(intent, connection, Context.BIND_AUTO_CREATE);
}
private ServiceConnection connection = new ServiceConnection() {
/**、
* 链接一个服务成功的时候调用
* @param name
* @param service
*/
@Override
public void onServiceConnected(ComponentName name, IBinder service) {
//创建Messenger
mService = new Messenger(service);
//向服务端发送消息
Message msg = Message.obtain(null, 1);
Bundle bundle = new Bundle();
bundle.putString("msg", "接受信息");
msg.setData(bundle);
try {
mService.send(msg);
} catch (RemoteException e) {
e.printStackTrace();
}
}
/**
* 服务呗杀死或者中断的时候呗调用 如果我们自己接触绑定不会调用
* @param name
*/
@Override
public void onServiceDisconnected(ComponentName name) {
}
};
@Override
protected void onDestroy() {
super.onDestroy();
unbindService(connection);
}
}
来看下打印结果
12-18 02:38:25.591 2200-2200/com.demo.text.demotext E/messages: ActivityMessages ======== 收到消息了
通过上边的例子可以看出，在 Messenger 中进行数据传递必须将数据放入 Message 中，而 Messenger 和 Message 都实现了 Parcelable 接口，因此可以跨进程传输。简单来说，Message 中支持的类型就是 Messenger 所支持的传输类型。实际上，通过 Messenger 来传输的 Message，Message 中能使用的载体只有 what、arg1、arg2、Bundle 以及 replyTp。Message 中的另外一个字段 object 在同一个进程中很实用，但是在进程间通信的时候，在 Android 2.2 以前 object 字段不支持跨进程传输，即便在 2.2 以后，也仅仅是系统提供的实现了 Parcelable 接口的对象才能通过它来传输。这就意味着我们自定义的 Parcelable 对象是无法通过 object 字段来传输的。非系统的 Parcelable 对象无法通过 object 来传输，这也导致了 object 字段的实用性大大降低，索性我们还有 Bundle。
3. 服务端如何回应客户端
(1) 服务端代码
我们这里需要修改一下MessengerHandler，当收到消息后，会立即回复一条消息给客户端。
public class MessengerService extends Service {
private static class MessengerHandler extends Handler {
@Override
public void handleMessage(Message msg) {
switch (msg.what) {
case 1:
Log.e("messages", "ServiceMessages ======== " + msg.getData().getString("msg"));
Messenger client = msg.replyTo;
Message messageReply = Message.obtain(null, 1);
Bundle bundle = new Bundle();
bundle.putString("reply", "收到消息了");
messageReply.setData(bundle);
try {
client.send(messageReply);
} catch (RemoteException e) {
e.printStackTrace();
}
break;
default:
super.handleMessage(msg);
break;
}
}
}
private final Messenger messenger = new Messenger(new MessengerHandler());
@Nullable
@Override
public IBinder onBind(Intent intent) {
return messenger.getBinder();
}
}
(2) 客户端代码
为了接收服务端的回复，客户端也需要准备一个接收消息的 Messenger 和 Handler， 如下所示。
private static class MessengerHandler extends Handler {
@Override
public void handleMessage(Message msg) {
switch (msg.what) {
case 1:
Log.e("messages", "ActivityMessages ======== " + msg.getData().getString("reply"));
break;
default:
super.handleMessage(msg);
break;
}
}
}
private final Messenger mGetReplyMessage = new Messenger(new MessengerHandler());
除了上述修改，我们还需要注意一点，当客户端发送消息的时候，需要把接收服务端回复的 Messenger 通过 Message 的 replyTo 参数传递给服务端，如下所示
/**、
* 链接一个服务成功的时候调用
* @param name
* @param service
*/
@Override
public void onServiceConnected(ComponentName name, IBinder service) {
//创建Messenger
mService = new Messenger(service);
//向服务端发送消息
Message msg = Message.obtain(null, 1);
Bundle bundle = new Bundle();
bundle.putString("msg", "接受信息");
msg.setData(bundle);
msg.replyTo = mGetReplyMessage;
try {
mService.send(msg);
} catch (RemoteException e) {
e.printStackTrace();
}
}
/**
* 服务呗杀死或者中断的时候呗调用 如果我们自己接触绑定不会调用
* @param name
*/
@Override
public void onServiceDisconnected(ComponentName name) {
}
};
根据上述修改，我们在运行一下程序，看下log日志，没毛病，老铁，功能已经实现了。
12-18 02:38:25.591 2200-2200/com.demo.text.demotext E/messages: ActivityMessages ======== 收到消息了
12-18 02:38:25.167 2216-2216/? E/messages: ServiceMessages ======== 接受信息
下边给出一张工作原理图，方便读者更好的理解 Messenger 。
、
