Android IPC机制(二)用Messenger进行进程间通信
2016-01-03 00:49
615 查看
本来想写Binder的,笔者很多年前研究Android Native Framework时才了解到的,实话说对应用层的开发帮助不大,网上文章也比较多,如果想了解可以参考Android Bander设计与实现 - 设计篇这篇文章。另外在看这篇文章前最好看一下本文章的前篇Android IPC机制(一)开启多进程。
首先我们先写服务端(MessengerService.java),在onBind方法中创建Messenger,关联接收消息的Handler调用getBinder来获取Binder对象,在handleMessage方法中接收客户端发来的信息。
当然别忘了注册servce时要另开一个进程:
接下来创建客户端(MessengerActivity.java),绑定另一个进程的servce,绑定成功以后根据服务端返回的Binder对象创建Messenger,并用Messenger向服务端发送信息。
我们运行程序,log显示
服务端现在收到了客户端的消息,但是服务端现在无法回应客户端,现在我们来修改代码使服务端回应客户端,客户端也能收到服务端的回应。
首先我们修改服务端(MessengerService.java),在handleMessage回调中收到客户端信息时,我们调用Message.replyTo得到客户端传过来的Messenger对象,创建消息并通过Messenger发送给客户端。
最后我们修改客户端(MessengerActivity.java),客户端需要创建一个Handler来接收服务端的信息
前面我们在服务端调用Message.replyTo得到客户端传过来的Messenger对象,可是客户端并没有传送Messenger对象啊,现在我们加上这段代码将Messenger对象传给服务端,当然需要关联我们定义的Handler。(MessengerActivity.java)
运行代码查看Log,大功告成。
github源码下载
首先我们先写服务端(MessengerService.java),在onBind方法中创建Messenger,关联接收消息的Handler调用getBinder来获取Binder对象,在handleMessage方法中接收客户端发来的信息。
[code]import android.app.Service; import android.content.Intent; import android.os.Handler; import android.os.IBinder; import android.os.Message; import android.os.Messenger; import android.util.Log; public class MessengerService extends Service { public static final String TAG = "MoonMessenger"; public static final int MSG_FROMCLIENT=1000; private Handler mHandler = new Handler() { @Override public void handleMessage(Message msg) { switch (msg.what) { case MSG_FROMCLIENT: Log.i(TAG,"收到客户端信息-------"+msg.getData().get("msg")); break; } } }; @Override public IBinder onBind(Intent intent) { return new Messenger(mHandler).getBinder(); } }
当然别忘了注册servce时要另开一个进程:
[code] <service android:name=".MessengerService" android:process=":remote"></service>
接下来创建客户端(MessengerActivity.java),绑定另一个进程的servce,绑定成功以后根据服务端返回的Binder对象创建Messenger,并用Messenger向服务端发送信息。
[code]import android.content.ComponentName; import android.content.Context; import android.content.Intent; import android.content.ServiceConnection; import android.os.IBinder; import android.os.Message; import android.os.Messenger; import android.os.RemoteException; import android.support.v7.app.AppCompatActivity; import android.os.Bundle; public class MessengerActivity extends AppCompatActivity { private Messenger mMessenger; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_messenger); Intent intent=new Intent(MessengerActivity.this,MessengerService.class); bindService(intent,mServiceConnection, Context.BIND_AUTO_CREATE); } private ServiceConnection mServiceConnection=new ServiceConnection() { @Override public void onServiceConnected(ComponentName name, IBinder service) { mMessenger=new Messenger(service); Message mMessage=Message.obtain(null,MessengerService.MSG_FROMCLIENT); Bundle mBundle=new Bundle(); mBundle.putString("msg","这里是客户端,收到了嘛服务端"); mMessage.setData(mBundle); try { mMessenger.send(mMessage); } catch (RemoteException e) { e.printStackTrace(); } } @Override public void onServiceDisconnected(ComponentName name) { } }; @Override protected void onDestroy() { super.onDestroy(); unbindService(mServiceConnection); } }
我们运行程序,log显示
服务端现在收到了客户端的消息,但是服务端现在无法回应客户端,现在我们来修改代码使服务端回应客户端,客户端也能收到服务端的回应。
首先我们修改服务端(MessengerService.java),在handleMessage回调中收到客户端信息时,我们调用Message.replyTo得到客户端传过来的Messenger对象,创建消息并通过Messenger发送给客户端。
[code] private Handler mHandler = new Handler() { @Override public void handleMessage(Message msg) { switch (msg.what) { case MSG_FROMCLIENT: Log.i(TAG,"收到客户端信息-------"+msg.getData().get("msg")); //得到客户端传来的Messenger对象 Messenger mMessenger=msg.replyTo; Message mMessage=Message.obtain(null,MessengerService.MSG_FROMCLIENT); Bundle mBundle=new Bundle(); mBundle.putString("rep","这里是服务端,我们收到信息了"); mMessage.setData(mBundle); try { mMessenger.send(mMessage); } catch (RemoteException e) { e.printStackTrace(); } break; } } };
最后我们修改客户端(MessengerActivity.java),客户端需要创建一个Handler来接收服务端的信息
[code] private Handler mHandler = new Handler() { @Override public void handleMessage(Message msg) { switch (msg.what){ case MessengerService.MSG_FROMCLIENT: Log.i(MessengerService.TAG, "收到服务端信息-------" + msg.getData().get("rep")); break; } } };
前面我们在服务端调用Message.replyTo得到客户端传过来的Messenger对象,可是客户端并没有传送Messenger对象啊,现在我们加上这段代码将Messenger对象传给服务端,当然需要关联我们定义的Handler。(MessengerActivity.java)
[code]private ServiceConnection mServiceConnection=new ServiceConnection() { @Override public void onServiceConnected(ComponentName name, IBinder service) { mMessenger=new Messenger(service); Message mMessage=Message.obtain(null,MessengerService.MSG_FROMCLIENT); Bundle mBundle=new Bundle(); mBundle.putString("msg", "这里是客户端,收到了嘛服务端"); mMessage.setData(mBundle); //将Messenger传递给服务端 mMessage.replyTo=new Messenger(mHandler); try { mMessenger.send(mMessage); } catch (RemoteException e) { e.printStackTrace(); } }
运行代码查看Log,大功告成。
github源码下载
相关文章推荐
- Android笔记(七十二) Style和Theme
- Android Tab实现之FragmentManager+Fragment
- Android的context
- Android实现推送方式解决方案
- Android Tab实现总结之Viewpager
- ViewDragHelper使用详解
- Android应用性能优化的小技巧
- Android中ListView异步加载图片错位、重复、闪烁问题分析及解决方案
- 解决当使用hide()和show()在多个Fragment 切换时,出现的重叠问题
- [置顶] 【Android高级】一些难点问题简介,很有意思的问题。
- 通过Observer(观察者模式)来看Android的MVC
- android 使用layer-list
- android 动画使用
- 【转】Android Studio安装配置学习教程指南 Gradle基础--不错
- Android开发之 adb 启动问题或是部署应用不成功,出现“The connection to adb is down, and a severe error has occured.”错误
- Android studio Introduction No.4 -- Gradle
- android studio introduction No.3 hotkey
- andriod进程的优先级,已经android内存不够时,清除进程的机制
- 解决:Android Studio 不能预览
- Android开发之bindService()侦听service内部状态