android 中进程间通信,比较常用的有以下五种方法,intent,共享文件,Messenger,AIDL,socket。其中Messenger,AIDL两种方式,都是建立在Binder机制之上。而对于通过共享文件在进程之间进行通信效果也不是那么理想,就以SharePreference为例,由于android对SharePreference采用了内存缓存策略,导致在并发读写时,常常造成数据丢失,而socket则主要用在网络方面,intent在传递数据时,携带数据量有限制。因此我们在本文中先谈一谈Messenger,其他文章将会有后续介绍。
本篇文章是在《android开发技术探索》这本书的讲解之上,改编整理而来。我们知道在一个应用中开启多个进程是很容易的,只需要在清单文件中,加上一行代码就可以
android:process=":remote"
前面的冒号标示,这个进程的名字是在包名之后再加上":remote",如若不然,也可以通过以下写法:
android:process="com.ningxia.remote"
而如果这个包名是"com.ningxia"的话,那么第一种写法的进程就会是"com.ningxia:remote",而第二种写法的名字就是我们所指定的。我们在指定进程名字的时候,是需要带上一个"."号的。
笔者在读这本书之前,曾经尝试过使用Rxbus在两个进程中发送消息,结果消息石沉大海,杳无音讯。直到读到了这本书,才恍然大悟。尽管是在同一个应用中开启的两个进程,但是效果是同两个应用区别不大的。因此要想在进程之间通信,就需要了解android IPC的通信机制。
public class MessengerActivity extends AppCompatActivity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_messenger);
Intent intent=new Intent(this,MessengerService.class);
bindService(intent,serviceConnection, Context.BIND_AUTO_CREATE);
findViewById(R.id.textView).setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
if(messenger!=null){
Message obtain = Message.obtain(null, 101);
Bundle data=new Bundle();
data.putString("yumin","hello yumin sister");
obtain.setData(data);
//在这里拿到activity专属的messenger赋值给即将发送给服务的消息。
obtain.replyTo=messenger1;
try {
//通过基于服务IBinder创建的messenger发送含有activity的messenger的消息给服务。
messenger.send(obtain);
} catch (RemoteException e) {
e.printStackTrace();
}
}
}
});
}
private Messenger messenger;
private ServiceConnection serviceConnection=new ServiceConnection() {
@Override
public void onServiceConnected(ComponentName name, IBinder service) {
//基于服务IBinder创建一个新的Messenger,activity发送消息给服务,全是依赖这个messenger
messenger=new Messenger(service);
Message obtain = Message.obtain(null, 101);
Bundle data=new Bundle();
data.putString("yumin","hello yumin");
obtain.setData(data);
//获取activity专属的messenger,将这个messenger赋值给即将发送给服务的消息。
obtain.replyTo=messenger1;
try {
//通过基于服务IBinder创建的messenger发送含有activity的messenger的消息给服务。
messenger.send(obtain);
} catch (RemoteException e) {
e.printStackTrace();
}
}
@Override
public void onServiceDisconnected(ComponentName name) {
}
};
@Override
protected void onDestroy() {
unbindService(serviceConnection);
super.onDestroy();
}
//activity专属的messenger,用来通过消息的replyto传递给service,service通过获取这个messenger,发送消息回activity
public Messenger messenger1=new Messenger(new MessengerHandler());
private class MessengerHandler extends Handler {
@Override
public void handleMessage(Message msg) {
switch (msg.what){
case 102:
Log.e("MessengerActivity",msg.getData().getString("xiaoyu"));
break;
default:
super.handleMessage(msg);
}
}
}
}
public class MessengerService extends Service {
public MessengerService() {
}
private final String TAG="MessengerService";
private class MessengerHandler extends Handler{
@Override
public void handleMessage(final Message msg) {
switch (msg.what){
case 101:
Log.e(TAG,msg.getData().getString("yumin")+"....");
//获取activity传递过来的消息,然后从消息中获得activity的messenger
Messenger messenger=msg.replyTo;
Message obtain = Message.obtain(null, 102);
Bundle bundle=new Bundle();
bundle.putString("xiaoyu","i get your idea");
obtain.setData(bundle);
try {
//通过获得的activity的messenger发送消息
messenger.send(obtain);
} catch (RemoteException e) {
e.printStackTrace();
}
break;
default:
super.handleMessage(msg);
break;
}
}
}
private final Messenger messenger=new Messenger(new MessengerHandler());
@Override
public IBinder onBind(Intent intent) {
// TODO: Return the communication channel to the service.
return messenger.getBinder();
}
}
上面的代码有以下几点需要注意
service和activity都分别有自己的Messenger。另外activity还会新建一个基于service的messenger传递过来的ibinder来新建一个用来发送activity的消息的messenger。也就是说一共有三个Messenger对象,但是实际上只有两个Messenger,因为其中acitvity的一个Messenger和service中的Messenger是基于同一个Ibinder构建的。另外一个是activity发送到service的消息的replyto方法携带的,携带的这个messenger到服务之后,被服务获取到,通过获取的这个messenger发送消息到activity。
service的Messenger通过obBinder方法,将service的messenger.getBinder(),传递到activity的onServiceConnected中,然后在acitvity中使用service的messenger的ibinder新建一个messenger用来发送activity的消息到service中。
activity中除了采用service传递过来的iBinder新建的messenger之外,还有自定义的一个messenger,这个activity中自定义的messenger是通过activity的消息中的方法replyto携带到service中。
service 通过获得的消息的replyto拿到activity的messenger,来send当前service需要返回给activity的消息。