Android 进阶10:进程通信之 Messenger 使用与解析

2024-06-02 07:18

本文主要是介绍Android 进阶10:进程通信之 Messenger 使用与解析,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

读完本文你将了解:

    • Messenger 简介
    • Messenger 的使用
      • 服务端
      • 客户端
      • 运行效果
      • 使用小结
    • 总结
    • 代码地址
    • Thanks

前面我们介绍了 AIDL 的使用与原理,这篇文章来介绍下 Android 中另一种 IPC 方式:Messenger。

Messenger 简介

Messenger “信使”,顾名思义,它的作用就是传递信息。

Messenger 有两个构造函数:

  1. 以 Handler 为参数
  2. 以 Binder 为参数
private final IMessenger mTarget;
public Messenger(Handler target) {mTarget = target.getIMessenger();
}
public Messenger(IBinder target) {mTarget = IMessenger.Stub.asInterface(target);    //和前面的 AIDL 很相似吧
}

看下 Handler.getIMessenger() 源码:

final IMessenger getIMessenger() {synchronized (mQueue) {if (mMessenger != null) {return mMessenger;}mMessenger = new MessengerImpl();return mMessenger;}
}

这个 IMessanger 应该也是个 AIDL 生成的类吧,看下源码,果然是:

public interface IMessenger extends android.os.IInterface {/** Local-side IPC implementation stub class. */public static abstract class Stub extends android.os.Binder implementsandroid.os.IMessenger {private static final java.lang.String DESCRIPTOR = "android.os.IMessenger";public Stub() {this.attachInterface(this, DESCRIPTOR);}public static android.os.IMessenger asInterface(...}public android.os.IBinder asBinder() {return this;}@Overridepublic boolean onTransact(int code, android.os.Parcel data,android.os.Parcel reply, int flags)throws android.os.RemoteException {...}private static class Proxy implements android.os.IMessenger {...}public void send(android.os.Message msg)throws android.os.RemoteException;
}

IMessenger 是 AIDL 生成的跨进程接口,里面定义了一个发送消息的方法:

    public void send(android.os.Message msg)throws android.os.RemoteException;

HandlerMessengerImpl 实现了这个方法,就是使用 Handler 将消息发出去:

private final class MessengerImpl extends IMessenger.Stub {public void send(Message msg) {msg.sendingUid = Binder.getCallingUid();Handler.this.sendMessage(msg);}
}

这就解释了为什么我们的消息来得时候会出现在 Handler.handlerMessage()

接着再看下 Messenger 另一个重要的方法,send()

public void send(Message message) throws RemoteException {mTarget.send(message);
}

Messenger 中持有一个 IMessenger 的引用,在构造函数中可以通过 Handler 或者 Binder 的形式获得最终的 IMessenger 实现,然后调用它的 send() 方法。

Messenger 其实就是 AIDL 的简化版,它把接口都封装好,我们只需在一个进程创建一个 Handler 传递给 Messenger,Messenger 帮我们把消息跨进程传递到另一个进程,我们在另一个进程的 Handler 在处理消息就可以了。

Messenger 的使用

Messenger 的使用需要结合 Handler, Message, Bundle

下面我们将写一个客户端跨进程发送消息到服务端的例子,服务端在收到消息后会回复,由于在 Messenger 中一个对象对应一个 Handler,所以我们需要在客户端、服务端分别创建一个 Messenger:

这里写图片描述

服务端在收到消息后会使用 Message.replyTo 对应的信使回复消息。

服务端

服务端只需要创建一个 Messenger 对象,然后给它传递一个 Handler,在 Handler 中处理消息:

public class MessengerService extends BaseService {private final String TAG = this.getClass().getSimpleName();Messenger mMessenger = new Messenger(new Handler() {@Overridepublic void handleMessage(final Message msg) {if (msg != null && msg.arg1 == ConfigHelper.MSG_ID_CLIENT) {if (msg.getData() == null) {return;}String content = (String) msg.getData().get(ConfigHelper.MSG_CONTENT);  //接收客户端的消息LogUtils.d(TAG, "Message from client: " + content);//回复消息给客户端Message replyMsg = Message.obtain();replyMsg.arg1 = ConfigHelper.MSG_ID_SERVER;Bundle bundle = new Bundle();bundle.putString(ConfigHelper.MSG_CONTENT, "听到你的消息了,请说点正经的");replyMsg.setData(bundle);try {msg.replyTo.send(replyMsg);     //回信} catch (RemoteException e) {e.printStackTrace();}}}});@Nullable@Overridepublic IBinder onBind(final Intent intent) {return mMessenger.getBinder();}
}

客户端

public class IPCTestActivity extends BaseActivity {private final String TAG = this.getClass().getSimpleName();@BindView(R.id.tv_result)TextView mTvResult;@BindView(R.id.btn_add_person)Button mBtnAddPerson;@BindView(R.id.et_msg_content)EditText mEtMsgContent;@BindView(R.id.btn_send_msg)Button mBtnSendMsg;/*** 客户端的 Messenger*/Messenger mClientMessenger = new Messenger(new Handler() {@Overridepublic void handleMessage(final Message msg) {if (msg != null && msg.arg1 == ConfigHelper.MSG_ID_SERVER){if (msg.getData() == null){return;}String content = (String) msg.getData().get(ConfigHelper.MSG_CONTENT);LogUtils.d(TAG, "Message from server: " + content);}}});//服务端的 Messengerprivate Messenger mServerMessenger;private ServiceConnection mMessengerConnection = new ServiceConnection() {@Overridepublic void onServiceConnected(final ComponentName name, final IBinder service) {mServerMessenger = new Messenger(service);}@Overridepublic void onServiceDisconnected(final ComponentName name) {mServerMessenger = null;}};@Overrideprotected void onCreate(@Nullable Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_aidl);ButterKnife.bind(this);bindAIDLService();bindMessengerService();}private void bindMessengerService() {Intent intent = new Intent(this, MessengerService.class);bindService(intent, mMessengerConnection, BIND_AUTO_CREATE);}@OnClick(R.id.btn_send_msg)public void sendMsg() {String msgContent = mEtMsgContent.getText().toString();msgContent = TextUtils.isEmpty(msgContent) ? "默认消息" : msgContent;Message message = Message.obtain();message.arg1 = ConfigHelper.MSG_ID_CLIENT;Bundle bundle = new Bundle();bundle.putString(ConfigHelper.MSG_CONTENT, msgContent);message.setData(bundle);message.replyTo = mClientMessenger;     //指定回信人是客户端定义的try {mServerMessenger.send(message);} catch (RemoteException e) {e.printStackTrace();}}@Overrideprotected void onDestroy() {super.onDestroy();unbindService(mMessengerConnection);}}

运行效果

这里写图片描述

发送后,服务端进程收到消息:
这里写图片描述

然后进行了答复:
这里写图片描述

使用小结

可以看到客户端的操作主要有 3 步:

  1. 创建客户端的 Messenger,传递一个 Handler 处理消息
  2. bindService,在 ServiceConnection 回调中拿到服务端的 Messenger
  3. 发送消息
    • Message.obtain() 消息池里获取一个空闲消息对象
    • 使用 message.setData(bundle) 设置数据
    • 指定回信的信使 message.replyTo = mClientMessenger
    • 调用服务端信使,发射!mServerMessenger.send(message)

总结

Messenger 对 AIDL 进行了封装,也就是对 Binder 的封装,我们可以使用它的实现来完成基于消息的跨进程通信,就和使用 Handler 一样简单。

使用步骤:

  1. 客户端创建一个 Messenger,传递一个 Handler 处理消息
  2. 服务端也一样

如果需要回信,给 Message 设置一个用于回信的 Messenger 即可:

message.replyTo = mClientMessenger;

客户端在调用send()方法之后,就会走 Binder 跨进程通信机制 ,最后到服务端的 Handler 中得到处理。

借用鸿洋的图表达一下:

使用时和 Binder 一样,建议在四大组件中使用,那样可以提高优先级,让系统不随便关闭当前进程。

代码地址

Thanks

https://developer.android.com/reference/android/os/Messenger.html
http://book2s.com/java/src/package/android/os/imessenger.html
http://www.jianshu.com/p/af8991c83fcb
http://blog.csdn.net/lmj623565791/article/details/47017485

这篇关于Android 进阶10:进程通信之 Messenger 使用与解析的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1023304

相关文章

nginx -t、nginx -s stop 和 nginx -s reload 命令的详细解析(结合应用场景)

《nginx-t、nginx-sstop和nginx-sreload命令的详细解析(结合应用场景)》本文解析Nginx的-t、-sstop、-sreload命令,分别用于配置语法检... 以下是关于 nginx -t、nginx -s stop 和 nginx -s reload 命令的详细解析,结合实际应

MyBatis中$与#的区别解析

《MyBatis中$与#的区别解析》文章浏览阅读314次,点赞4次,收藏6次。MyBatis使用#{}作为参数占位符时,会创建预处理语句(PreparedStatement),并将参数值作为预处理语句... 目录一、介绍二、sql注入风险实例一、介绍#(井号):MyBATis使用#{}作为参数占位符时,会

Linux下进程的CPU配置与线程绑定过程

《Linux下进程的CPU配置与线程绑定过程》本文介绍Linux系统中基于进程和线程的CPU配置方法,通过taskset命令和pthread库调整亲和力,将进程/线程绑定到特定CPU核心以优化资源分配... 目录1 基于进程的CPU配置1.1 对CPU亲和力的配置1.2 绑定进程到指定CPU核上运行2 基于

使用Python删除Excel中的行列和单元格示例详解

《使用Python删除Excel中的行列和单元格示例详解》在处理Excel数据时,删除不需要的行、列或单元格是一项常见且必要的操作,本文将使用Python脚本实现对Excel表格的高效自动化处理,感兴... 目录开发环境准备使用 python 删除 Excphpel 表格中的行删除特定行删除空白行删除含指定

深入理解Go语言中二维切片的使用

《深入理解Go语言中二维切片的使用》本文深入讲解了Go语言中二维切片的概念与应用,用于表示矩阵、表格等二维数据结构,文中通过示例代码介绍的非常详细,需要的朋友们下面随着小编来一起学习学习吧... 目录引言二维切片的基本概念定义创建二维切片二维切片的操作访问元素修改元素遍历二维切片二维切片的动态调整追加行动态

prometheus如何使用pushgateway监控网路丢包

《prometheus如何使用pushgateway监控网路丢包》:本文主要介绍prometheus如何使用pushgateway监控网路丢包问题,具有很好的参考价值,希望对大家有所帮助,如有错误... 目录监控网路丢包脚本数据图表总结监控网路丢包脚本[root@gtcq-gt-monitor-prome

Python通用唯一标识符模块uuid使用案例详解

《Python通用唯一标识符模块uuid使用案例详解》Pythonuuid模块用于生成128位全局唯一标识符,支持UUID1-5版本,适用于分布式系统、数据库主键等场景,需注意隐私、碰撞概率及存储优... 目录简介核心功能1. UUID版本2. UUID属性3. 命名空间使用场景1. 生成唯一标识符2. 数

SpringBoot中如何使用Assert进行断言校验

《SpringBoot中如何使用Assert进行断言校验》Java提供了内置的assert机制,而Spring框架也提供了更强大的Assert工具类来帮助开发者进行参数校验和状态检查,下... 目录前言一、Java 原生assert简介1.1 使用方式1.2 示例代码1.3 优缺点分析二、Spring Fr

Android kotlin中 Channel 和 Flow 的区别和选择使用场景分析

《Androidkotlin中Channel和Flow的区别和选择使用场景分析》Kotlin协程中,Flow是冷数据流,按需触发,适合响应式数据处理;Channel是热数据流,持续发送,支持... 目录一、基本概念界定FlowChannel二、核心特性对比数据生产触发条件生产与消费的关系背压处理机制生命周期

java使用protobuf-maven-plugin的插件编译proto文件详解

《java使用protobuf-maven-plugin的插件编译proto文件详解》:本文主要介绍java使用protobuf-maven-plugin的插件编译proto文件,具有很好的参考价... 目录protobuf文件作为数据传输和存储的协议主要介绍在Java使用maven编译proto文件的插件