Android 利用Messenger进行跨进程通信

Messenger通信原理

Messenger其实是谷歌对aidl进行的封装，用来处理简单的跨进程通信。那么如何用Messenger传递信息呢？

单向通信

现在假设我们有服务端和客户端，并且服务端与客户端不在同一进程中。

     首先服务端需要创建一个Handler用来接收客户端发送来的消息，然后利用这个handler，来构造一个Messenger，并且在onBind方法中将messenger的IBinder返回给客户端。那么当客户端通过bindService方法绑定这个服务之后，就可以通过这个IBinder对象来构造一个Messenger对象，然后就可以发送Message类型的消息，从而实现一个单向跨进程通信。

这么说可能有些抽象，下面我贴上实现代码，看完就应该很容易理解了。

//服务端代码

RemoteService.class

public class RemoteService extends Service {
private static final String TAG = "RemoteService";
private Handler receiveHandler = new Handler(){
@Override
public void handleMessage(Message msg) {
switch (msg.what){
case 0:
Log.d(TAG,"收到了客户端发来的消息：" + msg.getData().getString("client_message"));
break;
default:
super.handleMessage(msg);
}
}
};
//这里利用一个Handler对象构造一个Messenger对象
private Messenger messenger = new Messenger(receiveHandler);
public RemoteService() {
}

@Override
public IBinder onBind(Intent intent) {
return messenger.getBinder();
}
}

这里要注意，由于演示的是跨进程通信，但是为了方便我并没有写两个应用，而是在service的配置中开了一个进程

AndroidManifest.xml

<service
android:process=":remote"
android:name=".service.RemoteService"
android:enabled="true"
android:exported="true"></service>

//客户端代码

MainActivity.class

public class MainActivity extends AppCompatActivity {

private Messenger messenger;
private ServiceConnection mConnection = new ServiceConnection(){
@Override
public void onServiceConnected(ComponentName name, IBinder service) {
//这里利用一个IBinder对象构造一个Messenger对象
messenger = new Messenger(service);
Message msg = Message.obtain(null, 0);
Bundle bundle = new Bundle();
bundle.putString("client_message","I'm from 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_main);

final Intent intent = new Intent(this, RemoteService.class);

//绑定服务按钮
Button btnBind = (Button) findViewById(R.id.btn_bind);
btnBind.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
bindService(intent, mConnection, BIND_AUTO_CREATE);
}
});
}
}

当我们点击绑定服务按钮时，控制台就会输出一条信息：

D/RemoteService: 收到了客户端发来的消息：I'm from Client!。

下面说一下双向通信：

    要实现双向通信，那么客户端也需要创建一个Handler对象来接收服务端发来的消息。

        然后同样，利用这个Handler对象来构造一个Messenger对象，并且在给服务端发消息时，

给Message对象的replyTo属性赋值，也就是msg.replyTo = clientMessenger;

那么服务端如何给客户端发消息呢？

其实很容易，就是利用刚才的msg.replyTo来获取客户端Messenger，然后发送消息。

    双向通信代码（跨进程）

//服务端代码

RemoteService.class

public class RemoteService extends Service {
private static final String TAG = "RemoteService";
private Handler receiveHandler = new Handler(){
@Override
public void handleMessage(Message msg) {
switch (msg.what){
case 0:
Log.d(TAG,"收到了客户端发来的消息：" + msg.getData().getString("client_message"));
//在这里得到客户端的Messenger
Messenger clientMessenger = msg.replyTo;
Message msg1 = Message.obtain(null, 0);
Bundle bundle = new Bundle();
bundle.putString("server_message","I'm from Server!");
msg1.setData(bundle);
try {
clientMessenger.send(msg1);
} catch (RemoteException e) {
e.printStackTrace();
}
break;
default:
super.handleMessage(msg);
}
}
};

private Messenger messenger = new Messenger(receiveHandler);
public RemoteService() {
}

@Override
public IBinder onBind(Intent intent) {
return messenger.getBinder();
}
}

//客户端代码

MainActivity.class

public class MainActivity extends AppCompatActivity {

private Messenger messenger;
private ServiceConnection mConnection = new ServiceConnection(){
@Override
public void onServiceConnected(ComponentName name, IBinder service) {
//这里利用一个IBinder对象构造一个Messenger对象
messenger = new Messenger(service);
Message msg = Message.obtain(null, 0);
Bundle bundle = new Bundle();
bundle.putString("client_message","I'm from Client!");
msg.setData(bundle);
//这里就是把客户端的Messenger传递过去
msg.replyTo = clientMessenger;
try {
messenger.send(msg);
} catch (RemoteException e) {
e.printStackTrace();
}
}

@Override
public void onServiceDisconnected(ComponentName name) {

}
};

private Handler clientHandler = new Handler(){
@Override
public void handleMessage(Message msg) {
switch (msg.what){
case 0:
Log.d("MainActivity","收到了服务端传回的消息:"+msg.getData().getString("server_message"));
break;
default:
super.handleMessage(msg);
}
}
};

private Messenger clientMessenger = new Messenger(clientHandler);

@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);

final Intent intent = new Intent(this, RemoteService.class);

//绑定服务按钮
Button btnBind = (Button) findViewById(R.id.btn_bind);
btnBind.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
bindService(intent, mConnection, BIND_AUTO_CREATE);
}
});
}
}

当我们点击绑定服务按钮时，控制台就会输出这两条信息：

D/RemoteService: 收到了客户端发来的消息：I'm from Client!。

D/MainActivity: 收到了服务端传回的消息:I'm from Server!