备案控制台
探索云世界
开发者社区 开发与运维 文章 正文

Messenger:使用消息的跨进程通信

2012-01-16 1169
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：

Messenger:信使

官方文档解释：它引用了一个Handler对象，以便others能够向它发送消息(使用mMessenger.send(Message msg)方法)。该类允许跨进程间基于Message的通信(即两个进程间可以通过Message进行通信)，在服务端使用Handler创建一个Messenger，客户端持有这个Messenger就可以与服务端通信了。

以前我们使用Handler+Message的方式进行通信，都是在同一个进程中，从线程持有一个主线程的Handler对象，并向主线程发送消息。

而Android既然可以使用bindler机制进行跨进行通信，所以我们当然可以将Handler与bindler结合起来进行跨进程发送消息。

查看API就可以发现，Messenger就是这种方式的实现。

一般使用方法如下：

１。远程通过

Java代码 复制代码 收藏代码
  1. mMessenger = new Messenger(mHandler) 
mMessenger = new Messenger(mHandler)

创建一个信使对象

２。客户端使用bindlerService请求连接远程

３。远程onBind方法返回一个bindler

Java代码 复制代码 收藏代码
  1. return mMessenger.getBinder(); 
return mMessenger.getBinder();

4.客户端使用远程返回的bindler得到一个信使（即得到远程信使）

Java代码 复制代码 收藏代码
  1. public void onServiceConnected(ComponentName name, IBinder service) {
  2. rMessenger = new Messenger(service);
  3. 　　　　　......
  4. } 
			public void onServiceConnected(ComponentName name, IBinder service) {
				rMessenger = new Messenger(service);
　　　　　　　　......
			}

这里虽然是new了一个Messenger，但我们查看它的实现

Java代码 复制代码 收藏代码
  1. /**
  2. * Create a Messenger from a raw IBinder, which had previously been
  3. * retrieved with {@link #getBinder}.
  4. *
  5. * @param target The IBinder this Messenger should communicate with.
  6. */
  7. public Messenger(IBinder target) {
  8. mTarget = IMessenger.Stub.asInterface(target);
  9. } 
    /**
     * Create a Messenger from a raw IBinder, which had previously been
     * retrieved with {@link #getBinder}.
     * 
     * @param target The IBinder this Messenger should communicate with.
     */
    public Messenger(IBinder target) {
        mTarget = IMessenger.Stub.asInterface(target);
    }

发现它的mTarget是通过Aidl得到的，实际上就是远程创建的那个。

５。客户端可以使用这个远程信使对象向远程发送消息：rMessenger.send(msg);

这样远程服务端的Handler对象就能收到消息了，然后可以在其handlerMessage(Message msg)方法中进行处理。（该Handler对象就是第一步服务端创建Messenger时使用的参数mHandler）.

经过这５个步骤貌似只有客户端向服务端发送消息，这样的消息传递是单向的，那么如何实现双向传递呢？

首先需要在第５步稍加修改，在send(msg)前通过msm.replyTo = mMessenger将自己的信使设置到消息中，这样服务端接收到消息时同时也得到了客户端的信使对象了，然后服务端可以通过

Java代码 复制代码 收藏代码
  1. //得到客户端的信使对象，并向它发送消息
  2. cMessenger = msg.replyTo;
  3. cMessenger.send(message); 
//得到客户端的信使对象，并向它发送消息
cMessenger = msg.replyTo;
cMessenger.send(message);

即完成了从服务端向客户端发送消息的功能，这样客服端可以在自己的Handler对象的handlerMessage方法中接收服务端发送来的message进行处理。

双向通信宣告完成。

下面改写ApiDemos工程实现Messenger通信

MessengerService.java

Java代码 复制代码 收藏代码
  1. package com.xwangly.apidemo.app;
  3. import java.util.Random;
  5. import android.app.Service;
  6. import android.content.Intent;
  7. import android.os.Handler;
  8. import android.os.IBinder;
  9. import android.os.Message;
  10. import android.os.Messenger;
  11. import android.os.RemoteException;
  12. import android.util.Log;
  14. public class MessengerService extends Service {
  15. private String TAG = "MessengerService";
  17. @Override
  18. public void onDestroy() {
  19. // TODO Auto-generated method stub
  20. Log.i(TAG, "onDestroy");
  21. cMessenger = null;
  22. super.onDestroy();
  23. }
  25. @Override
  26. public boolean onUnbind(Intent intent) {
  27. // TODO Auto-generated method stub
  28. Log.i(TAG, "onUnbind");
  29. return super.onUnbind(intent);
  30. }
  32. static final int MSG_REGISTER_CLIENT = 1;
  33. static final int MSG_UNREGISTER_CLIENT = 2;
  34. static final int MSG_SET_VALUE = 3;
  36. private Random random = new Random();
  38. private Handler mHandler = new Handler() {
  40. @Override
  41. public void handleMessage(Message msg) {
  42. // TODO Auto-generated method stub
  43. Log.i(TAG, "handleMessage");
  44. switch (msg.what) {
  45. case MSG_SET_VALUE:
  46. try {
  47. Message message = Message.obtain(null,
  48. MessengerService.MSG_SET_VALUE);
  49. message.arg1 = random.nextInt(100);
  51. //得到客户端的信使对象，并向它发送消息
  52. cMessenger = msg.replyTo;
  53. cMessenger.send(message);
  54. } catch (RemoteException e) {
  55. // TODO Auto-generated catch block
  56. e.printStackTrace();
  57. }
  58. break;
  59. default:
  60. super.handleMessage(msg);
  61. }
  63. }
  64. };
  66. /**
  67. * 自己的信使对象
  68. */
  69. private Messenger mMessenger = new Messenger(mHandler);
  71. /**
  72. * 客户的信使
  73. */
  74. private Messenger cMessenger;
  76. @Override
  77. public IBinder onBind(Intent intent) {
  78. // TODO Auto-generated method stub
  79. Log.i(TAG, "onBind");
  80. //返回自己信使的bindler,以供客户端通过这个bindler得到服务端的信使对象（通过new Messenger(bindler)）
  81. return mMessenger.getBinder();
  82. }
  84. @Override
  85. public void onRebind(Intent intent) {
  86. // TODO Auto-generated method stub
  87. Log.i(TAG, "onRebind");
  89. }
  91. } 
package com.xwangly.apidemo.app;

import java.util.Random;

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.os.RemoteException;
import android.util.Log;

public class MessengerService extends Service {
	private String TAG = "MessengerService";

	@Override
	public void onDestroy() {
		// TODO Auto-generated method stub
		Log.i(TAG, "onDestroy");
		cMessenger = null;
		super.onDestroy();
	}

	@Override
	public boolean onUnbind(Intent intent) {
		// TODO Auto-generated method stub
		Log.i(TAG, "onUnbind");
		return super.onUnbind(intent);
	}

	static final int MSG_REGISTER_CLIENT = 1;
	static final int MSG_UNREGISTER_CLIENT = 2;
	static final int MSG_SET_VALUE = 3;

	private Random random = new Random();

	private Handler mHandler = new Handler() {

		@Override
		public void handleMessage(Message msg) {
			// TODO Auto-generated method stub
			Log.i(TAG, "handleMessage");
			switch (msg.what) {
			case MSG_SET_VALUE:
				try {
					Message message = Message.obtain(null,
							MessengerService.MSG_SET_VALUE);
					message.arg1 = random.nextInt(100);
					
					//得到客户端的信使对象，并向它发送消息
					cMessenger = msg.replyTo;
					cMessenger.send(message);
				} catch (RemoteException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				break;
			default:
				super.handleMessage(msg);
			}

		}
	};

	/**
	 * 自己的信使对象
	 */
	private Messenger mMessenger = new Messenger(mHandler);

	/**
	 * 客户的信使
	 */
	private Messenger cMessenger;

	@Override
	public IBinder onBind(Intent intent) {
		// TODO Auto-generated method stub
		Log.i(TAG, "onBind");
		//返回自己信使的bindler,以供客户端通过这个bindler得到服务端的信使对象（通过new Messenger(bindler)）
		return mMessenger.getBinder();
	}

	@Override
	public void onRebind(Intent intent) {
		// TODO Auto-generated method stub
		Log.i(TAG, "onRebind");

	}

}

MessengerServiceActivities.java

Java代码 复制代码 收藏代码
  1. package com.xwangly.apidemo.app;
  3. import com.xwangly.apidemo.R;
  5. import android.app.Activity;
  6. import android.content.ComponentName;
  7. import android.content.Intent;
  8. import android.content.ServiceConnection;
  9. import android.os.Bundle;
  10. import android.os.Handler;
  11. import android.os.IBinder;
  12. import android.os.Message;
  13. import android.os.Messenger;
  14. import android.os.RemoteException;
  15. import android.util.Log;
  16. import android.view.View;
  17. import android.widget.TextView;
  19. public class MessengerServiceActivities {
  20. public static class Binding extends Activity implements
  21. View.OnClickListener {
  22. private String TAG = "Binding";
  24. TextView mCallbackText;
  26. private boolean isBound;
  28. @Override
  29. protected void onCreate(Bundle savedInstanceState) {
  30. // TODO Auto-generated method stub
  31. super.onCreate(savedInstanceState);
  32. setContentView(R.layout.messenger_service_binding);
  33. findViewById(R.id.bind).setOnClickListener(this);
  34. findViewById(R.id.unbind).setOnClickListener(this);
  36. mCallbackText = (TextView) findViewById(R.id.callback);
  37. mCallbackText.setText("Not attached.");
  39. }
  41. private Handler mHandler = new Handler() {
  42. @Override
  43. public void handleMessage(Message msg) {
  44. Log.i(TAG, "handleMessage");
  45. switch (msg.what) {
  46. case MessengerService.MSG_SET_VALUE:
  47. mCallbackText.setText("Received from service: " + msg.arg1);
  48. break;
  49. default:
  50. super.handleMessage(msg);
  51. }
  52. }
  53. };
  55. /**
  56. * 自己的信使
  57. */
  58. private Messenger mMessenger;
  60. /**
  61. * 远程服务的信使
  62. */
  63. private Messenger rMessenger;
  65. private ServiceConnection connection = new ServiceConnection() {
  67. public void onServiceConnected(ComponentName name, IBinder service) {
  68. // TODO Auto-generated method stub
  69. Log.i(TAG, "onServiceConnected");
  70. rMessenger = new Messenger(service);
  71. mMessenger = new Messenger(mHandler);
  73. sendMessage();
  74. }
  77. public void onServiceDisconnected(ComponentName name) {
  78. // TODO Auto-generated method stub
  79. rMessenger = null;
  80. }
  81. };
  83. public void onClick(View v) {
  84. // TODO Auto-generated method stub
  85. Intent intent = new Intent(
  86. "com.xwangly.apidemo.app.messenger_service");
  87. switch (v.getId()) {
  88. case R.id.bind:
  89. if (!isBound) {
  90. isBound = bindService(intent, connection, BIND_AUTO_CREATE);
  91. //isBound = true;
  92. }else {
  93. sendMessage();
  94. }
  95. break;
  96. case R.id.unbind:
  97. if (isBound) {
  98. unbindService(connection);
  99. isBound = false;
  100. }
  101. break;
  102. default:
  103. break;
  104. }
  105. }
  107. /**
  108. * 使用服务端的信使向它发送一个消息。
  109. */
  110. private void sendMessage() {
  111. // TODO Auto-generated method stub
  112. Message message = Message.obtain(null, MessengerService.MSG_SET_VALUE);
  113. message.replyTo = mMessenger;
  114. try {
  115. rMessenger.send(message);
  116. } catch (RemoteException e) {
  117. // TODO Auto-generated catch block
  118. e.printStackTrace();
  119. }
  120. }
  122. }
  124. } 
package com.xwangly.apidemo.app;

import com.xwangly.apidemo.R;

import android.app.Activity;
import android.content.ComponentName;
import android.content.Intent;
import android.content.ServiceConnection;
import android.os.Bundle;
import android.os.Handler;
import android.os.IBinder;
import android.os.Message;
import android.os.Messenger;
import android.os.RemoteException;
import android.util.Log;
import android.view.View;
import android.widget.TextView;

public class MessengerServiceActivities {
	public static class Binding extends Activity implements
			View.OnClickListener {
		private String TAG = "Binding";

		TextView mCallbackText;

		private boolean isBound;

		@Override
		protected void onCreate(Bundle savedInstanceState) {
			// TODO Auto-generated method stub
			super.onCreate(savedInstanceState);
			setContentView(R.layout.messenger_service_binding);
			findViewById(R.id.bind).setOnClickListener(this);
			findViewById(R.id.unbind).setOnClickListener(this);

			mCallbackText = (TextView) findViewById(R.id.callback);
			mCallbackText.setText("Not attached.");

		}

		private Handler mHandler = new Handler() {
			@Override
			public void handleMessage(Message msg) {
				Log.i(TAG, "handleMessage");
				switch (msg.what) {
				case MessengerService.MSG_SET_VALUE:
					mCallbackText.setText("Received from service: " + msg.arg1);
					break;
				default:
					super.handleMessage(msg);
				}
			}
		};

		/**
		 * 自己的信使
		 */
		private Messenger mMessenger;
		
		/**
		 * 远程服务的信使
		 */
		private Messenger rMessenger;
		
		private ServiceConnection connection = new ServiceConnection() {

			public void onServiceConnected(ComponentName name, IBinder service) {
				// TODO Auto-generated method stub
				Log.i(TAG, "onServiceConnected");
				rMessenger = new Messenger(service);
				mMessenger = new Messenger(mHandler);
				
				sendMessage();
			}


			public void onServiceDisconnected(ComponentName name) {
				// TODO Auto-generated method stub
				rMessenger = null;
			}
		};

		public void onClick(View v) {
			// TODO Auto-generated method stub
			Intent intent = new Intent(
					"com.xwangly.apidemo.app.messenger_service");
			switch (v.getId()) {
			case R.id.bind:
				if (!isBound) {
					isBound = bindService(intent, connection, BIND_AUTO_CREATE);
					//isBound = true;
				}else {
					sendMessage();
				}
				break;
			case R.id.unbind:
				if (isBound) {
					unbindService(connection);
					isBound = false;
				}
				break;
			default:
				break;
			}
		}
		
		/**
		 * 使用服务端的信使向它发送一个消息。
		 */
		private void sendMessage() {
			// TODO Auto-generated method stub
			Message message = Message.obtain(null, MessengerService.MSG_SET_VALUE);
			message.replyTo = mMessenger;
			try {
				rMessenger.send(message);
			} catch (RemoteException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}

	}

}

AndroidManifest.xml相关配置如下：

Xml代码 复制代码 收藏代码
  1. <service android:name=".app.MessengerService" >
  2. <intent-filter>
  3. <action android:name="com.xwangly.apidemo.app.messenger_service" />
  4. </intent-filter>
  5. </service>
  6. <activity android:name=".app.MessengerServiceActivities$Binding"
  7. android:label="@string/activity_messenger_service_binding"
  8. android:launchMode="singleTop">
  9. <intent-filter>
  10. <action android:name="android.intent.action.MAIN" />
  11. <category android:name="android.intent.category.LAUNCHER" />
  12. </intent-filter>
  13. </activity> 
		<service android:name=".app.MessengerService" >
			<intent-filter>
				<action android:name="com.xwangly.apidemo.app.messenger_service" />
			</intent-filter>
		</service>
        <activity android:name=".app.MessengerServiceActivities$Binding"
                android:label="@string/activity_messenger_service_binding"
                android:launchMode="singleTop">
            <intent-filter>
                <action android:name="android.intent.action.MAIN" />
                <category android:name="android.intent.category.LAUNCHER" />
            </intent-filter>
        </activity>

至于layout就不帖了，两个按钮一个文本域。

文章标签：
Android开发
Java
API
数据格式
XML
一叶飘舟
目录
相关文章
泡沫o0
|
30天前
|
消息中间件 Unix Linux
Linux进程间通信(IPC)介绍：详细解析IPC的执行流程、状态和通信机制
Linux进程间通信(IPC)介绍：详细解析IPC的执行流程、状态和通信机制
泡沫o0
43 1
流烟默
|
4月前
|
消息中间件 存储 Unix
进程间通信和线程间通信总结
写在前面 面试的时候一定不要疲劳战，比如上午面了一个，然后中午不休息直接赶到另外一个相距比较远的公司，影响状态。 面试的时候一定不要紧张，不管对方有几个人，总之面试的时候做好充分准备，休息好，放松心态。 好了，言归正传，开始总结。
流烟默
39 0
root8042965
|
4月前
|
消息中间件 存储 程序员
进程间的通信
进程间的通信
root8042965
33 1
蓝易云
|
5月前
|
Linux
百度搜索：蓝易云【【Linux】进程间的通信之共享内存】
总结而言，Linux中的共享内存是一种用于进程间通信的高效机制，它允许多个进程共享同一块物理内存区域，实现数据的快速交换。通过适当的创建、连接、分离和删除操作，可以实现进程对共享内存的使用和管理。
蓝易云
222 7
Want595
|
3月前
|
编解码 监控 API
操作系统：进程的控制和通信（Windows2000）
操作系统：进程的控制和通信（Windows2000）
Want595
37 0
泡沫o0
|
30天前
|
消息中间件 Linux API
跨进程通信设计：Qt 进程间通讯类全面解析
跨进程通信设计：Qt 进程间通讯类全面解析
泡沫o0
77 0
泡沫o0
|
30天前
|
消息中间件 并行计算 网络协议
探秘高效Linux C/C++项目架构：让进程、线程和通信方式助力你的代码飞跃
探秘高效Linux C/C++项目架构：让进程、线程和通信方式助力你的代码飞跃
泡沫o0
33 0
嘿嘿就是写
|
2月前
|
Python
Python多进程间通信的最佳实践
Python多进程间通信的最佳实践
嘿嘿就是写
29 0
妄北y
|
2月前
|
消息中间件 Linux
Linux下的系统编程——进程间的通信（九）
Linux下的系统编程——进程间的通信（九）
妄北y
36 1
Linux下的系统编程——进程间的通信（九）
极客李华
|
3月前
|
存储 缓存 Unix
C语言第四章（进程间的通信，管道通信，pipe()函数）
C语言第四章（进程间的通信，管道通信，pipe()函数）
极客李华
51 0

热门文章

最新文章

  • 1
    智能推荐映射关系，加速数据标准落地进程
  • 2
    深度剖析Linux进程的内部机制：一探/proc/pid的奥秘
  • 3
    跨进程通信设计：Qt 进程间通讯类全面解析
  • 4
    ⭐⭐⭐⭐⭐Linux C/C++ 进程崩溃诊断以及有效数据收集：解锁代码问题快速定位与修复的方法
  • 5
    探索 Linux 高级进程间通讯 D-Bus的神秘妙用
  • 6
    【Linux C/C++ 堆内存分布】深入理解Linux进程的堆空间管理
  • 7
    【软件设计师备考 专题 】操作系统的内核（中断控制）、进程、线程概念
  • 8
    Linux IPC 进程间通讯方式的深入对比与分析和权衡
  • 9
    掌握 SOME/IP ：访问进程数据 构建高效通信系统的关键技术
  • 10
    【Linux 进程/线程状态 】深入理解Linux C++中的进程/线程状态：阻塞，休眠，僵死
  • 1
    Serverless的发展进程
    21
  • 2
    【Linux】—— 进程程序替换
    36
  • 3
    【Linux】—— 进程等待 wait&&waitpid
    36
  • 4
    【Linux】—— 进程的环境变量
    45
  • 5
    【Linux】—— 详解进程PCB和进程状态
    50
  • 6
    《操作系统》——进程与线程
    87
  • 7
    Python教程第8章 | 线程与进程
    36
  • 8
    C/C++ 进程间通信system V IPC对象超详细讲解（系统性学习day9）
    42
  • 9
    C/C++进程超详细详解【下部分】(系统性学习day8)
    28
  • 10
    C/C++进程超详细详解【中部分】(系统性学习day07)
    30

    • 相关电子书

    更多
  • 服务上云加速大家居产业C2M进程
  • 低代码开发师（初级）实战教程
  • 阿里巴巴DevOps 最佳实践手册

    • 相关实验场景

    更多
  • 观察进程的并发性
    • 下一篇
    阿里云oss简介和使用流程
    为什么选择阿里云什么是云计算全球基础设施技术领先稳定可靠安全合规分析师报告
    产品和定价全部产品免费试用产品动态产品定价价格计算器云上成本管理
    解决方案技术解决方案
    文档与社区文档开发者社区天池大赛培训与认证
    权益中心免费试用高校计划企业扶持计划推荐返现计划
    支持与服务基础服务企业增值服务迁云服务官网公告健康看板信任中心
    关注阿里云
    关注阿里云公众号或下载阿里云APP，关注云资讯，随时随地运维管控云服务
    阿里云APP阿里云微信
    联系我们：4008013260
    法律声明Cookies政策廉正举报安全举报联系我们加入我们
    阿里巴巴集团淘宝网天猫全球速卖通阿里巴巴国际交易市场1688阿里妈妈飞猪阿里云计算AliOS万网高德UC友盟优酷钉钉支付宝达摩院淘宝海外阿里云盘饿了么
    © 2009-2024 Aliyun.com 版权所有 增值电信业务经营许可证： 浙B2-20080101 域名注册服务机构许可： 浙D3-20210002 京D3-20220015
    浙公网安备 33010602009975号浙B2-20080101-4