随笔Android IPC进程通信之——Messenger

本文主要是介绍随笔Android IPC进程通信之——Messenger，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

随笔Android IPC进程通信之——Messenger

android中用于进程通信和数据共享的方式有多种，最基本的Bundle，文件共享，Messenger，AIDL，ContentProvider，Socket等，他们的区别和使用场景这里就不再说了，详情自行查看了解了解，本文直接介绍方式之一Messenger（信使）的使用方式。

代码为例，开始看看我们遇到的问题，模拟多进程数据同步问题

1.新建一个IPCDemo，创建一个自己的Applciation并声明一个公用变量value

2.新建两个Activity，在第一个MainActivity中修改Oncreate中修改 Application中value值为8

由MainActivity进入第二个页面（服务Activity）注意此activity在Manifest中配置中添加android:process=”:remote”，目的是让其单独运行在一个进程中，和MainActivity不同进程。

在ServerActivity中我们同样打印Applcation中的value；
结果如下：

3.引起的问题 我们知道一个应用中Application是一个重量级的，由系统创建的单一实例，其中的数据是共享的，那么这里我们在MainActivity中修改了value值，这个应用中的其他访问的地方应该都是修改后的值，但上面的结果却不是这样。

原因就在于，我们的ServerActivity配置了android:process=":remote"，这会导致ServerActivity运行在另一进程中，说白了就是，MainActivity是一个应用，ServerActivity是一个应用，既然是两个不同应用，那么就会有两个不同的Application实例，Application会创建多次（这里两次），这两个实例分别位于不同进程（应用中），这就是为什么修改第一个全局值，而第二个进程中的值没有任何影响的原因。

4.解决问题 我们如何让第一个进程修改变量值的时候，通知另一个进程同步修改对应的值？接下来就利用本文介绍的Messenger。

Messenger 运用

messenger 其实是基于消息的进程通信方式，最基本的理解就是有客户端，服务端如下图：

接下来代码介绍：
我们的MainActivity用来充当客户端，ServerActivity充当服务端，因为两个页面完全运行在不同的进程中。

首先，创建一个MessengerService，并在manifest中配置成和ServerActivity中相同的进程。代码如下：

/*** Created by Frosty on 2017/6/13.*//public class    MessengerService extends Service{public static String TAG = MessengerService.class.getSimpleName();public final static int FROM_CLIENT = 1;//来此客户端请求public final static int FROM_SERVICE= 2;//来此服务端请求private Messenger msngerCurrent;//当前类使用（发送消息、接收处理消息）@Overridepublic void onCreate() {super.onCreate();msngerCurrent = new Messenger(new MessengerHandler());}@Nullable@Overridepublic IBinder onBind(Intent intent) {return msngerCurrent.getBinder();}public static class MessengerHandler extends Handler{@Overridepublic void handleMessage(Message msg) {switch (msg.what){case FROM_CLIENT:///1.处理接受消息Log.e(TAG,"收到来自客户端【"+msg.getData().getString("name")+"】的消息："+msg.getData().getString("content"));MyApplication.value = msg.getData().getInt("value");//2.拿到客户端发送消息附带的Messenger，用它回传消息Messenger msngerReply = msg.replyTo;//封装回传消息Message replyMsg = Message.obtain(null,FROM_SERVICE);Bundle bundle = new Bundle();bundle.putString("name","阿里云");bundle.putString("content","你好，我这边已经同步修改，值为："+MyApplication.value);replyMsg.setData(bundle);try {msngerReply.send(replyMsg);//回传消息}catch (Exception e){}break;default:break;}}}
}

这里暂时只说明这个服务的功能，利用MessengerHandler处理发送自客户端来的数据，通过msg.what匹配。

所以我们在客户端（MainActivity中去注册绑定这个服务，并在修改appvalue时候发送一个消息给这个服务）

public class MainActivity extends AppCompatActivity {private Messenger msngerCurrent;private class MessengerHandler extends Handler{@Overridepublic void handleMessage(Message msg) {switch (msg.what){case MessengerService.FROM_SERVICE:Log.e("MessengerService","收到来自服务端【"+msg.getData().getString("name")+"】的回应："+msg.getData().getString("content"));unbindService(serviceConnection);break;}}}@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_main);MyApplication.value = 8;//此处修改值Log.e("appvalue","MainActivity中获取到的value："+MyApplication.value);/*绑定服务*/bindRemoteService();msngerCurrent = new Messenger(new MessengerHandler());findViewById(R.id.btn_requestServer).setOnClickListener(new View.OnClickListener() {@Overridepublic void onClick(View v) {Intent intent = new Intent(MainActivity.this,ServerActivity.class);startActivity(intent);}});}///服务链接状态监听private ServiceConnection serviceConnection = new ServiceConnection() {@Overridepublic void onServiceConnected(ComponentName name, IBinder service) {Messenger messengerClient = new Messenger(service);/*封装消息体*/Message msg = Message.obtain(null,MessengerService.FROM_CLIENT);//对应服务端接受码Bundle bundle = new Bundle();bundle.putString("name","张山");bundle.putString("content","我修改了我们的共享值，请你务必修改！");bundle.putInt("value",MyApplication.value);msg.setData(bundle);msg.replyTo=msngerCurrent;//发送try{messengerClient.send(msg);}catch (Exception e){}}@Overridepublic void onServiceDisconnected(ComponentName name) {}};public void bindRemoteService(){Intent intent = new Intent(this, MessengerService.class);bindService(intent,serviceConnection, Context.BIND_AUTO_CREATE);}@Overrideprotected void onDestroy() {unbindService(serviceConnection);super.onDestroy();}
}

我们详细解释一下工作流程
- 我们首先得创建一个ServiceConnection 用于检测服务绑定后或者断开后的操作如下图，绑定服务链接后，回掉调nServiceConnected方法，在这个方法中，我们构造一个客户端Messenger
并用message封装数据，然后用这个Messenger发送消息即可

发送消息后，MessengerService便可以接收到消息处理，修改当前进程的appvalue值，并回传附加消息给客户端，注意这里回传的Messenger，直接在获取消息体中用msg.replyTo获取，前提是客户端相应的在传过来的msg中replyTo赋值Mesenger，此messenger在客户端也用来处理服务端响应回来的数据。

5.结果 我们重启应用，重新打印两个值

发现在主进程修改appvalue后，另一个进程获取到的值也及时得到同步了。

End注意：Messenger通信，可使用它进行进程间的通信，而Messenger对Service的请求采用队列的方式，因此它不支持多线程通信。

这篇关于随笔Android IPC进程通信之——Messenger的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---