Android 进程间通信(四) - Messenger 以及源码分析

2024-06-07 20:08

本文主要是介绍Android 进程间通信(四) - Messenger 以及源码分析,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

在上几篇文章中,我们已经学习了Binder 这种通信模式,这章中,我们来学习 Messenger;

Messenger可以翻译为信使,它可以在不同进程间传递 Message 对象。Messenger 是一种轻量的 IPC 防范,它的底层实现是 AIDL,后面我们会分析它的源码;

Messenger 一次只能处理一个请求,因此并不适合高并发的问题,也不用考虑线程同步的问题,因为服务端中不存在并发执行的情形。

一. 实现Messenger通信

从上面可以知道,可以传递 Message,一些简单的数据,我们就可以通过这种方式去实现了。下面我们一起来实现它。
今天的效果是,客户端发送两个数字,服务端返回两数之和:
在这里插入图片描述

1.1. 服务端

在服务端中,我们可以直接 new 一个 Messenger ,传递一个 Handler,如下:

public class MessengerService extends Service {private static final String TAG = "MessageService";public MessengerService() {}Messenger mMessenger = new Messenger(new Handler(Looper.getMainLooper()){@Overridepublic void handleMessage(@NonNull Message msg) {super.handleMessage(msg);}});@Overridepublic IBinder onBind(Intent intent) {return mMessenger.getBinder();}
}

可以看到,Messenger 的构造方法中,传递了一个 Handler,当接收到客户端的 Message 消息时,会在 handleMessage() 方法中处理,并通过 mMessenger.getBinder() 返回 binder 对象。

接着,需要通过 Message 拿到两个数字,并返回相加的结果,如下:

        @Overridepublic void handleMessage(@NonNull Message msg) {super.handleMessage(msg);try {int num = msg.arg1 + msg.arg2;Message message = Message.obtain();message.what = 2;message.arg1 = num;//通过客户端的 Messenger 来把数据发送回去msg.replyTo.send(message);} catch (RemoteException e) {e.printStackTrace();}}

需要注意的是,数据在返回的时候,需要通过 msg.replyTo 去发送,它的对象为 Messenger 。
这样,服务端就写好了。

1.2. 客户端

接着,我们新建一个moudle,通过包名加类名的方式去 bind 这个服务。如下:

Intent intent = new Intent();
//绑定 服务
intent.setClassName("com.example.ipcdemo","com.example.ipcdemo.service.MessengerService");
mRemoteService = new RemoteService();
bindService(intent,mRemoteService, Service.BIND_AUTO_CREATE);

在连接的时候,创建 Messenger :

    class RemoteService implements ServiceConnection {@Overridepublic void onServiceConnected(ComponentName name, IBinder service) {mBinder = new Messenger(service);mSb.append("连接上服务端").append("\n");mTextView.setText(mSb.toString());}@Overridepublic void onServiceDisconnected(ComponentName name) {mBinder = null;}}

这样,我们就拿到了服务端mBinder的实例了,然后通过点击事件,把数据发送过去:

    public void testBtn(View view) {Message msg = Message.obtain();msg.arg1 = (int) (Math.random() * 100+1);msg.arg2 = (int) (Math.random() * 100+1);mTextView.setText(mSb.toString());//传递 client 的 messenger ,实现服务端与客户端通信msg.replyTo = mMessenger;if (mBinder != null) {try {mBinder.send(msg);} catch (RemoteException e) {e.printStackTrace();}}}

同时,也要注意,把要接受服务端信息的 Messenger 绑定到 msg.replyTo 中。客户端的 Messenger 如下:

    Messenger mMessenger = new Messenger(new Handler(Looper.getMainLooper()){@Overridepublic void handleMessage(@NonNull Message msg) {super.handleMessage(msg);mSb.append(msg.arg1).append("\n");mTextView.setText(mSb.toString());}});

这样,我们就实现所有功能了。效果如下面的 gif 。

使用 Messenger 的优缺点如下:

优点缺点使用场景
功能一般,支持一对多穿行通信,支持实时通信不能很好的处理高并发情形,不支持RPC,数据通过Message传输,因此只能传输Bundle支持的数据类型,比如 msg.setData()低并发的一对多及即时通信,无RPC需求,或者无需要返回结果的RPC需求

二. 源码分析

上面说到,Messenger 是基于 AIDL 的,怎么得出来的呢?它的构造方法传递要求传入的 Handler,进入到里面看一下:

    public Messenger(Handler target) {mTarget = target.getIMessenger();}

然后,去到 Handler ,找到 getIMessage() 方法:
在这里插入图片描述
可以看到,mMessenger 的实现类为 MessengerImpl ,而它继承自 IMessenger.Stub ;看到这里有没有很熟悉? 没错,跟我们的 AIDL 的实现类一样,通过源码也知道,IMessenger 确实是个 AIDL 接口:

package android.os;import android.os.Message;/** @hide */
oneway interface IMessenger {void send(in Message msg);
}

在它的 send 方法中,把数据又通过 Handler 的 sendMessage 方法,发送给自身,从而当有数据来的时候,就会调用它的 handleMessage()方法。

而在客户端的绑定数据中,也验证了这个问题,比如:
在这里插入图片描述
去到构造方法中,可以看到:
在这里插入图片描述
通过 asInterface 拿到binder。

这样,我们就了解清楚了。

这篇关于Android 进程间通信(四) - Messenger 以及源码分析的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



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

相关文章

MyBatis Plus 中 update_time 字段自动填充失效的原因分析及解决方案(最新整理)

《MyBatisPlus中update_time字段自动填充失效的原因分析及解决方案(最新整理)》在使用MyBatisPlus时,通常我们会在数据库表中设置create_time和update... 目录前言一、问题现象二、原因分析三、总结:常见原因与解决方法对照表四、推荐写法前言在使用 MyBATis

Windows的CMD窗口如何查看并杀死nginx进程

《Windows的CMD窗口如何查看并杀死nginx进程》:本文主要介绍Windows的CMD窗口如何查看并杀死nginx进程问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地... 目录Windows的CMD窗口查看并杀死nginx进程开启nginx查看nginx进程停止nginx服务

Python主动抛出异常的各种用法和场景分析

《Python主动抛出异常的各种用法和场景分析》在Python中,我们不仅可以捕获和处理异常,还可以主动抛出异常,也就是以类的方式自定义错误的类型和提示信息,这在编程中非常有用,下面我将详细解释主动抛... 目录一、为什么要主动抛出异常?二、基本语法:raise关键字基本示例三、raise的多种用法1. 抛

github打不开的问题分析及解决

《github打不开的问题分析及解决》:本文主要介绍github打不开的问题分析及解决,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、找到github.com域名解析的ip地址二、找到github.global.ssl.fastly.net网址解析的ip地址三

Mysql的主从同步/复制的原理分析

《Mysql的主从同步/复制的原理分析》:本文主要介绍Mysql的主从同步/复制的原理分析,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录为什么要主从同步?mysql主从同步架构有哪些?Mysql主从复制的原理/整体流程级联复制架构为什么好?Mysql主从复制注意

Java进程CPU使用率过高排查步骤详细讲解

《Java进程CPU使用率过高排查步骤详细讲解》:本文主要介绍Java进程CPU使用率过高排查的相关资料,针对Java进程CPU使用率高的问题,我们可以遵循以下步骤进行排查和优化,文中通过代码介绍... 目录前言一、初步定位问题1.1 确认进程状态1.2 确定Java进程ID1.3 快速生成线程堆栈二、分析

java -jar命令运行 jar包时运行外部依赖jar包的场景分析

《java-jar命令运行jar包时运行外部依赖jar包的场景分析》:本文主要介绍java-jar命令运行jar包时运行外部依赖jar包的场景分析,本文给大家介绍的非常详细,对大家的学习或工作... 目录Java -jar命令运行 jar包时如何运行外部依赖jar包场景:解决:方法一、启动参数添加: -Xb

Android学习总结之Java和kotlin区别超详细分析

《Android学习总结之Java和kotlin区别超详细分析》Java和Kotlin都是用于Android开发的编程语言,它们各自具有独特的特点和优势,:本文主要介绍Android学习总结之Ja... 目录一、空安全机制真题 1:Kotlin 如何解决 Java 的 NullPointerExceptio

Apache 高级配置实战之从连接保持到日志分析的完整指南

《Apache高级配置实战之从连接保持到日志分析的完整指南》本文带你从连接保持优化开始,一路走到访问控制和日志管理,最后用AWStats来分析网站数据,对Apache配置日志分析相关知识感兴趣的朋友... 目录Apache 高级配置实战:从连接保持到日志分析的完整指南前言 一、Apache 连接保持 - 性

Linux中的more 和 less区别对比分析

《Linux中的more和less区别对比分析》在Linux/Unix系统中,more和less都是用于分页查看文本文件的命令,但less是more的增强版,功能更强大,:本文主要介绍Linu... 目录1. 基础功能对比2. 常用操作对比less 的操作3. 实际使用示例4. 为什么推荐 less?5.