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

相关文章

使用Java解析JSON数据并提取特定字段的实现步骤(以提取mailNo为例)

《使用Java解析JSON数据并提取特定字段的实现步骤(以提取mailNo为例)》在现代软件开发中,处理JSON数据是一项非常常见的任务,无论是从API接口获取数据,还是将数据存储为JSON格式,解析... 目录1. 背景介绍1.1 jsON简介1.2 实际案例2. 准备工作2.1 环境搭建2.1.1 添加

如何使用celery进行异步处理和定时任务(django)

《如何使用celery进行异步处理和定时任务(django)》文章介绍了Celery的基本概念、安装方法、如何使用Celery进行异步任务处理以及如何设置定时任务,通过Celery,可以在Web应用中... 目录一、celery的作用二、安装celery三、使用celery 异步执行任务四、使用celery

使用Python绘制蛇年春节祝福艺术图

《使用Python绘制蛇年春节祝福艺术图》:本文主要介绍如何使用Python的Matplotlib库绘制一幅富有创意的“蛇年有福”艺术图,这幅图结合了数字,蛇形,花朵等装饰,需要的可以参考下... 目录1. 绘图的基本概念2. 准备工作3. 实现代码解析3.1 设置绘图画布3.2 绘制数字“2025”3.3

Jsoncpp的安装与使用方式

《Jsoncpp的安装与使用方式》JsonCpp是一个用于解析和生成JSON数据的C++库,它支持解析JSON文件或字符串到C++对象,以及将C++对象序列化回JSON格式,安装JsonCpp可以通过... 目录安装jsoncppJsoncpp的使用Value类构造函数检测保存的数据类型提取数据对json数

python使用watchdog实现文件资源监控

《python使用watchdog实现文件资源监控》watchdog支持跨平台文件资源监控,可以检测指定文件夹下文件及文件夹变动,下面我们来看看Python如何使用watchdog实现文件资源监控吧... python文件监控库watchdogs简介随着Python在各种应用领域中的广泛使用,其生态环境也

Python中构建终端应用界面利器Blessed模块的使用

《Python中构建终端应用界面利器Blessed模块的使用》Blessed库作为一个轻量级且功能强大的解决方案,开始在开发者中赢得口碑,今天,我们就一起来探索一下它是如何让终端UI开发变得轻松而高... 目录一、安装与配置:简单、快速、无障碍二、基本功能:从彩色文本到动态交互1. 显示基本内容2. 创建链

springboot整合 xxl-job及使用步骤

《springboot整合xxl-job及使用步骤》XXL-JOB是一个分布式任务调度平台,用于解决分布式系统中的任务调度和管理问题,文章详细介绍了XXL-JOB的架构,包括调度中心、执行器和Web... 目录一、xxl-job是什么二、使用步骤1. 下载并运行管理端代码2. 访问管理页面,确认是否启动成功

使用Nginx来共享文件的详细教程

《使用Nginx来共享文件的详细教程》有时我们想共享电脑上的某些文件,一个比较方便的做法是,开一个HTTP服务,指向文件所在的目录,这次我们用nginx来实现这个需求,本文将通过代码示例一步步教你使用... 在本教程中,我们将向您展示如何使用开源 Web 服务器 Nginx 设置文件共享服务器步骤 0 —

Java中switch-case结构的使用方法举例详解

《Java中switch-case结构的使用方法举例详解》:本文主要介绍Java中switch-case结构使用的相关资料,switch-case结构是Java中处理多个分支条件的一种有效方式,它... 目录前言一、switch-case结构的基本语法二、使用示例三、注意事项四、总结前言对于Java初学者

Golang使用minio替代文件系统的实战教程

《Golang使用minio替代文件系统的实战教程》本文讨论项目开发中直接文件系统的限制或不足,接着介绍Minio对象存储的优势,同时给出Golang的实际示例代码,包括初始化客户端、读取minio对... 目录文件系统 vs Minio文件系统不足:对象存储:miniogolang连接Minio配置Min