Android 进程间通信中 Messager 的简单使用

Messenger 是 Android 中一种简单且高效的进程间通信（IPC）机制。它基于 Binder 和 Handler 实现，适用于轻量级的跨进程通信场景。相比 AIDL（Android Interface Definition Language），Messenger 更加简单易用，但功能相对有限。

以下是 Messenger 的详细用法和实现步骤：

1. Messenger 的工作原理

Messenger 的核心思想是通过消息队列在不同进程之间传递消息：

服务端：创建一个 Handler 来处理客户端发送的消息，并通过 Messenger 将 Handler 暴露给客户端。
客户端：通过绑定到服务端的 Service，获取服务端的 Messenger 对象，并使用它发送消息。
消息格式：所有消息都封装在 Message 对象中，支持携带简单的数据（如整数、字符串等）或 Bundle。

2. 使用 Messenger 的步骤

(1) 服务端实现

服务端需要创建一个 Service，并在其中定义一个 Handler 来处理客户端发送的消息。

示例代码：

import android.app.Service;
import android.content.Intent;
import android.os.Bundle;
import android.os.Handler;
import android.os.IBinder;
import android.os.Message;
import android.os.Messenger;
import android.util.Log;public class MessengerService extends Service {private static final String TAG = "MessengerService";// 定义 Handler 处理客户端消息private final Handler handler = new Handler(msg -> {Log.d(TAG, "Received message from client: " + msg.what);// 解析消息内容Bundle data = msg.getData();if (data != null) {String clientMessage = data.getString("key");Log.d(TAG, "Client message: " + clientMessage);}// 回复客户端消息Messenger clientMessenger = msg.replyTo;if (clientMessenger != null) {Message replyMessage = Message.obtain(null, 2); // 回复消息的 what 值为 2Bundle replyData = new Bundle();replyData.putString("reply_key", "Hello from server");replyMessage.setData(replyData);try {clientMessenger.send(replyMessage);} catch (Exception e) {e.printStackTrace();}}return true;});// 创建 Messenger 对象private final Messenger messenger = new Messenger(handler);@Overridepublic IBinder onBind(Intent intent) {Log.d(TAG, "Service bound");return messenger.getBinder(); // 返回 Binder 对象}
}

(2) 客户端实现

客户端通过绑定到服务端的 Service，获取服务端的 Messenger 对象，并使用它发送消息。

示例代码：

import android.content.ComponentName;
import android.content.Context;
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;public class MessengerClient {private static final String TAG = "MessengerClient";private Messenger serviceMessenger; // 服务端的 Messengerprivate boolean isBound = false;// 定义 Handler 处理服务端回复的消息private final Handler handler = new Handler(msg -> {Log.d(TAG, "Received reply from server: " + msg.what);// 解析回复消息Bundle data = msg.getData();if (data != null) {String serverReply = data.getString("reply_key");Log.d(TAG, "Server reply: " + serverReply);}return true;});// 创建客户端的 Messengerprivate final Messenger clientMessenger = new Messenger(handler);// 定义 ServiceConnectionprivate final ServiceConnection connection = new ServiceConnection() {@Overridepublic void onServiceConnected(ComponentName name, IBinder service) {Log.d(TAG, "Service connected");serviceMessenger = new Messenger(service); // 获取服务端的 MessengerisBound = true;// 发送消息给服务端sendMessageToService("Hello from client");}@Overridepublic void onServiceDisconnected(ComponentName name) {Log.d(TAG, "Service disconnected");serviceMessenger = null;isBound = false;}};// 绑定到服务端public void bindToService(Context context) {Intent intent = new Intent();intent.setComponent(new ComponentName("com.example.server", "com.example.server.MessengerService"));context.bindService(intent, connection, Context.BIND_AUTO_CREATE);}// 解绑服务public void unbindFromService(Context context) {if (isBound) {context.unbindService(connection);isBound = false;}}// 发送消息给服务端private void sendMessageToService(String message) {if (!isBound) return;// 创建消息Message msg = Message.obtain(null, 1); // 消息的 what 值为 1Bundle data = new Bundle();data.putString("key", message);msg.setData(data);// 设置回复 Messengermsg.replyTo = clientMessenger;try {serviceMessenger.send(msg); // 发送消息} catch (RemoteException e) {e.printStackTrace();}}
}

3. 配置 AndroidManifest.xml

确保服务端的 Service 在 AndroidManifest.xml 中正确声明，并设置为可导出。

示例代码：

<serviceandroid:name=".MessengerService"android:exported="true"><intent-filter><action android:name="com.example.server.MessengerService" /></intent-filter>
</service>