Android中Messenger原理及基本用法详解

发布时间 - 2026-01-11 00:12:56    点击率:

这边博客主要记录一下Android中Messenger的基本原理和用法。

简单来讲,Messenger其实就是Binder通信的包装器,是一种基于消息传递的进程间通信工具。

//Messenger实现了Parcelable接口,因此可以跨进程传输
public final class Messenger implements Parcelable {
 ...............
}

通常情况下,我们可以在A进程中创建一个Messenger,然后将该Messenger传递给B进程。
于是,B进程就可以通过Messenger与A进程通信了。

Messenger通常与Handler一起使用,我们看看对应的源码:

public final class Messenger implements Parcelable {
 private final IMessenger mTarget;

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

跟进一下Handler的getIMessenger函数:

 .............
 final IMessenger getIMessenger() {
  synchronized (mQueue) {
   if (mMessenger != null) {
    return mMessenger;
   }
   //返回的是Handler中定义的MessengerImpl
   mMessenger = new MessengerImpl();
   return mMessenger;
  }
 }

 //此处MessengerImpl继承自IMessenger.Stub
 //容易看出MessengerImpl将作为Binder通信的接收端
 private final class MessengerImpl extends IMessenger.Stub {
  public void send(Message msg) {
   msg.sendingUid = Binder.getCallingUid();
   Handler.this.sendMessage(msg);
  }
 }

从上述代码可以看出,Messenger实际上作为了一个Binder服务端的wrapper。

当我们在A进程中创建Messenger,然后传递给B进程时,Messenger需要执行Parcelable接口定义的操作,于是:

 //在A进程中将Binder信息写入到Parcel中
 public void writeToParcel(Parcel out, int flags) {
  out.writeStrongBinder(mTarget.asBinder());
 }

 public static final Parcelable.Creator<Messenger> CREATOR
   = new Parcelable.Creator<Messenger>() {
  //在B进程中,重新创建Binder
  public Messenger createFromParcel(Parcel in) {
   IBinder target = in.readStrongBinder();

   //调用Messenger的另一个构造函数
   return target != null ? new Messenger(target) : null;
  }

  public Messenger[] newArray(int size) {
   return new Messenger[size];
  }
 };

跟进一下Messenger的另一个构造函数:

public Messenger(IBinder target) {
 //得到的是Binder通信的客户端
 mTarget = IMessenger.Stub.asInterface(target);
}

因此,当Messenger从进程A传递到进程B时,它就变为了Binder通信客户端的wrapper。

当在进程B中使用Messenger的接口时:

public void send(Message message) throws RemoteException {
 //mTarget为Binder通信的客户端,将消息发送给服务端的send函数
 //即服务端Handler的MessengerImpl的send函数
 //上文已经附上了对应代码,可以看到对应的消息将递交给Handler处理
 mTarget.send(message);
}

以上就是Messenger通信的原理,现在实际测试一下。
我们定义一个简单的demo,包含一个Activity和一个Service,其中Service与Activity处在不同的进程中。

AndroidManifest.xml中的定义如下:

  .....................
  <activity android:name=".MainActivity">
   <intent-filter>
    <action android:name="android.intent.action.MAIN"/>

    <category android:name="android.intent.category.LAUNCHER"/>
   </intent-filter>
  </activity>

  <service
   android:name=".RemoteService"
   android:enabled="true"
   android:exported="true"
   <!--指定服务运行在其它进程-->
   android:process=".remote">
  </service>
  ..............

Activity的界面很简单,当点击时就会像Service发送消息,Activity代码如下:

public class MainActivity extends AppCompatActivity {
 private Button mButton;

 @Override
 protected void onCreate(Bundle savedInstanceState) {
  super.onCreate(savedInstanceState);
  setContentView(R.layout.activity_main);

  //打印Activity的pid及所在进程名称
  Log.d("ZJTest", "Activity, pid: " + Process.myPid() +
    ", name: " + Util.getProcessName(this));

  //启动服务
  startService();

  //绑定服务
  bindService();

  mButton = (Button) findViewById(R.id.test_button);
  mButton.setEnabled(false);
  //点击按键后,利用Messenger向Service发送消息
  mButton.setOnClickListener(new View.OnClickListener() {
   @Override
   public void onClick(View v) {
    if (mMessenger != null) {
     try {
      Message msg = Message.obtain();
      msg.what = 1;
      mMessenger.send(msg);
     } catch (RemoteException e) {
      Log.d("ZJTest", e.toString());
     }
    }
   }
  });
 }

 @Override
 public void onDestroy() {
  super.onDestroy();
  unBindService();
  stopService();
 }

 private Intent mIntent;
 private void startService() {
  mIntent = new Intent(this, RemoteService.class);
  this.startService(mIntent);
 }

 private ServiceConnection mServiceConnection;
 private void bindService() {
  mServiceConnection = new LocalServiceConnection();
  this.bindService(mIntent, mServiceConnection, BIND_AUTO_CREATE);
 }

 Messenger mMessenger;
 private class LocalServiceConnection implements android.content.ServiceConnection {
  @Override
  public void onServiceConnected(ComponentName name, IBinder service) {
   //绑定服务后,获得Messenger并激活Button
   mMessenger = new Messenger(service);
   mButton.setEnabled(true);
  }

  @Override
  public void onServiceDisconnected(ComponentName name) {
   mButton.setEnabled(false);
  }
 }

 private void stopService() {
  stopService(mIntent);
 }

 private void unBindService() {
  unbindService(mServiceConnection);
 }
}

Service对应的代码如下:

public class RemoteService extends Service {
 private Messenger mMessenger;

 @Override
 public void onCreate() {
  super.onCreate();

  //同样打印进程号及名称
  Log.d("ZJTest", "Service, pid: " + Process.myPid()
    + ", name: " + Util.getProcessName(this));

  LocalHandler mHandler = new LocalHandler();

  mMessenger = new Messenger(mHandler);
 }

 private static class LocalHandler extends Handler{
  @Override
  public void handleMessage(Message msg) {
   Log.d("ZJTest", "receive msg: " + msg.what);
  }
 }

 @Override
 public IBinder onBind(Intent intent) {
  //被绑定时,返回Messenger
  return mMessenger.getBinder();
 }
}

获取进程名的代码如下:

class Util {
 static String getProcessName(Context context) {
  int pid = Process.myPid();
  ActivityManager am = (ActivityManager) context
    .getSystemService(Context.ACTIVITY_SERVICE);

  for (ActivityManager.RunningAppProcessInfo appProcessInfo:
    am.getRunningAppProcesses()) {
   if (appProcessInfo.pid == pid) {
    return appProcessInfo.processName;
   }
  }

  return null;
 }
}

上述代码都是比较简单的,现在来看看运行结果:

02-20 21:25:15.760 D/ZJTest  (30460): Activity, pid: 30460, name: stark.a.is.zhang.messengertest
02-20 21:25:15.769 D/ZJTest  (30428): Service, pid: 30428, name: .remote
02-20 21:25:32.111 D/ZJTest  (30428): receive msg: 1

从log可以看出,Activity与Servie运行在不同的进程中,Messenger确实可以在不同进程间传递消息。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。


# Android  # Messenger  # Android进程通信之Messenger和AIDL使用详解  # Android 跨进程通Messenger(简单易懂)  # Android IPC机制利用Messenger实现跨进程通信  # Android使用Messenger实现service与activity交互  # android使用Messenger绑定Service的多种实现方法  # 的是  # 服务端  # 客户端  # 可以看出  # 绑定  # 都是  # 发送消息  # 是一种  # 上了  # 我们可以  # 很简单  # 可以看到  # 来看看  # 时就  # 当我们  # 它就  # 会像  # 将该  # 创建一个  # 大家多多 


相关栏目: 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571


相关推荐: Laravel怎么实现观察者模式Observer_Laravel模型事件监听与解耦开发【指南】  Laravel怎么做数据加密_Laravel内置Crypt门面的加密与解密功能  ai格式如何转html_将AI设计稿转换为HTML页面流程【页面】  如何使用 jQuery 正确渲染 Instagram 风格的标签列表  Laravel广播系统如何实现实时通信_Laravel Reverb与WebSockets实战教程  如何用美橙互联一键搭建多站合一网站?  Laravel怎么实现API接口鉴权_Laravel Sanctum令牌生成与请求验证【教程】  简历没回改:利用AI润色让你的文字更专业  JavaScript如何实现错误处理_try...catch如何捕获异常?  如何在IIS管理器中快速创建并配置网站?  图片制作网站免费软件,有没有免费的网站或软件可以将图片批量转为A4大小的pdf?  javascript基本数据类型及类型检测常用方法小结  如何在云指建站中生成FTP站点?  html5的keygen标签为什么废弃_替代方案说明【解答】  专业企业网站设计制作公司,如何理解商贸企业的统一配送和分销网络建设?  新三国志曹操传主线渭水交兵攻略  Laravel如何使用withoutEvents方法临时禁用模型事件  HTML5空格在Angular项目里怎么处理_Angular中空格的渲染问题【详解】  Android 常见的图片加载框架详细介绍  Laravel怎么使用Markdown渲染文档_Laravel将Markdown内容转HTML页面展示【实战】  如何快速登录WAP自助建站平台?  Android okhttputils现在进度显示实例代码  Java解压缩zip - 解压缩多个文件或文件夹实例  IOS倒计时设置UIButton标题title的抖动问题  手机网站制作平台,手机靓号代理商怎么制作属于自己的手机靓号网站?  专业型网站制作公司有哪些,我设计专业的,谁给推荐几个设计师兼职类的网站?  Laravel如何使用Scope本地作用域_Laravel模型常用查询逻辑封装技巧【手册】  SQL查询语句优化的实用方法总结  Android GridView 滑动条设置一直显示状态(推荐)  韩国代理服务器如何选?解析IP设置技巧与跨境访问优化指南  Python文件异常处理策略_健壮性说明【指导】  网站制作软件有哪些,制图软件有哪些?  香港服务器建站指南:外贸独立站搭建与跨境电商配置流程  香港代理服务器配置指南:高匿IP选择、跨境加速与SEO优化技巧  Edge浏览器如何截图和滚动截图_微软Edge网页捕获功能使用教程【技巧】  高配服务器限时抢购:企业级配置与回收服务一站式优惠方案  详解阿里云nginx服务器多站点的配置  开心动漫网站制作软件下载,十分开心动画为何停播?  php中::能调用final静态方法吗_final修饰静态方法调用规则【解答】  深圳网站制作平台,深圳市做网站好的公司有哪些?  北京网站制作的公司有哪些,北京白云观官方网站?  Laravel怎么配置S3云存储驱动_Laravel集成阿里云OSS或AWS S3存储桶【教程】  Laravel如何自定义错误页面(404, 500)?(代码示例)  php静态变量怎么调试_php静态变量作用域调试技巧【解答】  如何在阿里云完成域名注册与建站?  使用Dockerfile构建java web环境  教你用AI将一段旋律扩展成一首完整的曲子  Laravel如何与Docker(Sail)协同开发?(环境搭建教程)  Laravel的路由模型绑定怎么用_Laravel Route Model Binding简化控制器逻辑  Laravel怎么进行数据库事务处理_Laravel DB Facade事务操作确保数据一致性