Android中使用 Messenger 实现进程间通信小案例与分析说明

首先给出 activity 中的代码，如下：

package com.example.messengerdemo.activity;
import androidx.appcompat.app.AppCompatActivity;
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.Looper;
import android.os.Message;
import android.os.Messenger;
import android.os.RemoteException;
import android.util.Log;
import android.view.View;
import com.example.messengerdemo.R;
import com.example.messengerdemo.constant.MyConstant;
import com.example.messengerdemo.service.MessengerService;
public class MainActivity extends AppCompatActivity{
    // 服务端通过获取客户端的 Messenger 对象 回复消息给客户端 所以客户端也需要声明这么一个 Messenger 对象
    private Messenger getReplyMessenger = new Messenger(new MessengerHandle());
    private static class MessengerHandle extends Handler{
        @Override
        public void handleMessage(Message msg) {
            switch (msg.what){
                case MyConstant.MSG_FROM_SERVER:
                    Log.e("TAG", "receive msg from server:" +
                            msg.getData().getString(MyConstant.REPLY));
                    break;
            }
        }
    }
    private Messenger messenger = null;// 声明 Messenger 对象，初始化获取服务端的Messenger对象用
    // 创建 ServiceConnection 对象
    private ServiceConnection connection = new ServiceConnection() {
        @Override
        public void onServiceConnected(ComponentName componentName, IBinder iBinder) {
            messenger = new Messenger(iBinder);// 通过服务端返回的 binder 创建 Messenger 对象
            // 创建Message对象并设置携带的数据
            Message message = Message.obtain(null, MyConstant.MSG_FROM_CLIENT);
            Bundle bundle = new Bundle();
            bundle.putString(MyConstant.MSG, "imxiaoqi, enjoy coding.");
            message.setData(bundle);
            message.replyTo = getReplyMessenger;// 保证服务端处理消息的时候，能获取到客户端的Messenger对象
            try {
                messenger.send(message);// 通过服务端的Messenger对象发送消息给服务端
            } catch (RemoteException e) {
                e.printStackTrace();
            }
        }
        // 在正常情况下该方法是不被调用的，它的调用时机是当Service服务被异外销毁时，权例如内存的资源不足时
        @Override
        public void onServiceDisconnected(ComponentName componentName) {
            Log.e("TAG", "MainActivity onServiceDisconnected callback");
        }
    };
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        // 绑定服务，开启了新的服务进程（后面统一称服务端）
        Intent intent = new Intent(MainActivity.this, MessengerService.class);
        bindService(intent, connection, Context.BIND_AUTO_CREATE);
    }
    @Override
    protected void onDestroy() {
        super.onDestroy();
        // 活动销毁，记得解绑服务
        unbindService(connection);
    }
}

在onCreate() 方法中，我们绑定服务开启服务端进程，如下图示：

onDestory() 方法就是正常的解绑服务的操作，没什么好说的；

这里同学们应该有注意到，绑定服务的代码中有一个 connection 参数，这个参数其实一个 ServiceConnection 对象，所以我们还需要创建一个 ServiceConnection 对象，这个对象的作用是用来获取服务端的 Messenger 对象并给服务端发送消息，这些操作是在 onServiceConnected() 方法中实现，正常通过绑定方式启动服务并建立连接后，会回调该方法，如下图示：

上图中创建 Message 对象并设置携带的数据以及通过服务端的 Messenger 对象发送消息给服务端大家都比较好理解。

但是有一行代码可能同学们会存在疑惑，就是

message.replyTo = getReplyMessenger;// 保证服务端处理消息的时候，能获取到客户端的Messenger对象

所以，如果服务端需要回复消息给客户端，那么我们的客户端肯定也是需要有一个 Messenger 对象和 一个 Handler 对象的，只有存在这两个对象才可以接收到服务端的消息并作处理，如下图示：

服务端获取客户端的 Messenger 对象代码，如下图示：

com.example.messengerdemo

com.example.messengerdemo:remote