现在的位置: 首页 > 综合 > 正文

Android IPC进程通信——Messager方式

2018年02月15日 ⁄ 综合 ⁄ 共 2695字 ⁄ 字号 评论关闭

在看Pedometer的源码,中间有关于这方面的东西,所以就搜集了些资料,学习一下,以前没有用到过。

用法介绍,来源不清楚

如果你需要在不同进程间通信,你可以在Service中使用Messenger来实现进程中通信。

如果使用这种方式,Service中需要定义一个Handler对象(负责对客户端发送过来的Message进行响应)。

Messenger可以共享给client一个IBinder对象,client通过这个IBinder对象向Service发送Message,而前面提到的Handler对象是这一切的基础。

注:使用这种方式进行通信是不支持多线程的。

那就让我们来看看使用这种方式进行通信吧!

注:Service在声明时必须对外开放,即android:exported="true",且本文是通过Intent启动的Service,所以在声明时该Service可以接收特定的Action。

1、在Service中创建一个Handler对象,来处理从client发过来的Message

2、根据创建的Handler对象创建一个Messenger对象

3、使用Messenger的getBinder方法得到一个IBinder对象,并在Service的onBind方法中将其反出去

4、client在onServiceConnected中根据IBinder参数创建一个Messenger对象(可参考Messenger的构造函数)

5、client可以使用上一步得到的Messenger对象来给Service发送Message了

经过上面的五部我们就能让client与Service进行通信。client使用Messenger对象给Service发送Message后,Service中的Handler将会对消息作出响应。

上面实现的仅仅是单向通信,即client给Service发送消息,如果我需要Service给client发送消息又该怎样做呢?

其实,这也是很容易实现的,下面就让我们接着上面的步骤来实现双向通信吧~

6、在client中创建一个Handler对象,用于处理Service发过来的消息

7、根据client中的Handler对象创建一个client自己的Messenger对象

8、我们在第5步的时候获得了Service的Messenger对象,并通过它来给Service发送消息。这时候,我们将client的Messenger对象赋给待发送的Message对象的replyTo字段

9、在Service的Handler处理Message时将client的Messenger解析出来,并使用client的Messenger对象给client发送消息

这样我们就实现了client和Service的双向通信。client和Service都有自己的Handler和Messenger对象,使得对方可以给自己发送消息,值得注意的是client的Messenger是通过Message的replyTo传递给Service的。

下面代码Copy 自开源项目Pedometer 。

地址https://github.com/j4velin/Pedometer 一个简单的计步器。

Service

public class SensorListener extends Service implements SensorEventListener {

	
	private static int goal, today_offset;

	private static Messenger messenger = new Messenger(new Handler() {
		// received a message, reply with the current step value
		public void handleMessage(Message msg) {
			Message m = Message.obtain();
			m.arg1 = steps;
			try {
				msg.replyTo.send(m);
			} catch (RemoteException e) {
				if (Logger.LOG)
					Logger.log(e);
				e.printStackTrace();
			}
		};
	});

        /** 无关代码*/

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

Client在onresume中的写法

getActivity().bindService(new Intent(getActivity(), SensorListener.class), new ServiceConnection() {
			@Override
			public void onServiceDisconnected(ComponentName name) {

			}

			@SuppressLint("HandlerLeak")
			@Override
			public void onServiceConnected(ComponentName name, IBinder service) {
				Messenger messenger = new Messenger(service);
				try {
					final ServiceConnection conn = this;
					Messenger incoming = new Messenger(new Handler() {
						public void handleMessage(Message msg) {
							if (Logger.LOG)
								Logger.log("SensorListener.steps: " + msg.arg1);
							since_boot = msg.arg1;
							updateSteps();
							getActivity().unbindService(conn);
						}
					});
					Message msg = Message.obtain();
					msg.replyTo = incoming;
					messenger.send(msg);
				} catch (RemoteException e) {
					if (Logger.LOG)
						Logger.log(e);
					e.printStackTrace();
				}
			}
		}, 0);

manifest

<service
            android:name="de.j4velin.pedometer.background.SensorListener"
            android:process=":background" >
        </service>

更加深入一些的参考:http://blog.csdn.net/chenfeng0104/article/details/7010244

抱歉!评论已关闭.