简单聊聊Android AIDL之Messenger

哈喽，大家好，接触Android的同学们对AIDL这个概念肯定不会陌生，就算没用过，那肯定也是听过。很多刚开始接触Android的朋友可能会感觉AIDL很难。今天，就用Messenger来教大家如何简单的实现跨进程通信。

Messenger

Messenger翻译为信使，通过它可以在不同的进程中传递Message对象。Messenger就一种轻量级的IPC方案，它的底层实现还是AIDL，只是Android帮我们把大部分方法都封装在了里面，这样使用起来会更加方便。

下面用一个简单的例子来看看Messenger是如何实现跨进程通信的。
在写代码之前，先理一理Messenger跨进程通信的步骤：

服务端

• 首先我们要在服务端创建一个Service来处理客户的连接请求。
• 在Service中创建一个Handler并通过它创建一个Messenger。
• 通过Service的onBind方法将Messenger对象底层的Binder返回。

客户端

• 首先需要绑定服务端Service。
• 用服务端返回的Binder对象创建一个Messenger。
• 然后就可以用Messenger给服务的发送消息。

服务端：

public class OtherService extends Service {

    public static final int SERVICE_GET_MESSAGE = 0;

    @Override
    public IBinder onBind(Intent intent) {
        //将messenger底层的Binder对象返回给客户端。
        return messenger.getBinder();
    }

    private static class MessageHandler extends Handler {
        @Override
        public void handleMessage(Message msg) {
            switch (msg.what) {
                case SERVICE_GET_MESSAGE:
                     //接受到客户端发送的消息。
                    Log.d("Test", "get message = " + msg.getData().getString("msg"));
                    break;
                default:
                    super.handleMessage(msg);
            }
        }
    }

    private final Messenger messenger = new Messenger(new MessageHandler());
}

客户端:

public class MainActivity extends AppCompatActivity {
    
    private Messenger messenger;
    public static final int ACTIVITY_HANDLER_MSG = 0;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        //绑定服务
        Intent intent = new Intent(this, OtherService.class);
        bindService(intent, connection, Context.BIND_AUTO_CREATE);
    }

    private ServiceConnection connection = new ServiceConnection() {
        @Override
        public void onServiceConnected(ComponentName name, IBinder service) {
            //用服务端返回的Binder对象创建新的Messenger对象
            messenger = new Messenger(service);
            Message sendMsg = Message.obtain(null, OtherService.SERVICE_GET_MESSAGE);
            Bundle bundle = new Bundle();
            bundle.putString("msg", "this is a msg");
            sendMsg.setData(bundle);
            try {
                //客户端给服务端发送消息
                messenger.send(sendMsg);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }

        @Override
        public void onServiceDisconnected(ComponentName name) {

        }
    };
}

上面是一个很简单的例子，在启动应用后，客户端绑定服务端，然后服务端接收到客户端发送的消息。一些相关注释已经标在了代码中，大家可以简单看看。

---

上面的例子是客户端单方面给服务端发送消息，如果服务端想要回复客户端该怎么办呢。这个时候我们可以在客户端创建一个Handler，然后用Handler生成一个Messenger对象，最后用Message的replyTo将Messenger对象传递给服务端，这时候服务端就可以用客户端传递过来的Messenger对象来给客户端发送消息了。

下面我们来看看如何修改代码
服务端：

    private static class MessageHandler extends Handler {
        @Override
        public void handleMessage(Message msg) {
            switch (msg.what) {
                case SERVICE_GET_MESSAGE:
                    Log.d("Test", "get message = " + msg.getData().getString("msg"));
                    //获取客户端传递过来的Messenger对象
                    Messenger activityMessager = msg.replyTo;
                    Message message = Message.obtain(null, MainActivity.ACTIVITY_HANDLER_MSG);
                    Bundle bundle = new Bundle();
                    bundle.putString("msg", "客户端发送消息成功");
                    message.setData(bundle);
                    try {
                        //给客户端发送消息
                        activityMessager.send(message);
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                    break;
                default:
                    super.handleMessage(msg);
            }
        }
    }

服务端的改动很小，就是接收到客户端传递过来的Messenger后用这个Messenger来和客户端通信。

客户端：

    private static class MessageHandler extends Handler {
        @Override
        public void handleMessage(Message msg) {
            switch (msg.what) {
                case ACTIVITY_HANDLER_MSG:
                    Log.d("Test", "服务端消息:" + msg.getData().getString("msg"));
                    break;
                default:
                    super.handleMessage(msg);
            }
        }
    }

    private final Messenger serviceMessage = new Messenger(new MessageHandler());

首先我们创建客户端接收消息的Handler和发送消息的Messenger。

    private ServiceConnection connection = new ServiceConnection() {
        @Override
        public void onServiceConnected(ComponentName name, IBinder service) {
            messenger = new Messenger(service);
            Message sendMsg = Message.obtain(null, OtherService.SERVICE_GET_MESSAGE);
            Bundle bundle = new Bundle();
            bundle.putString("msg", "this is a msg");
            sendMsg.setData(bundle);
            //将客户端的Messenger传递给服务端
            sendMsg.replyTo = serviceMessage;
            try {
                messenger.send(sendMsg);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }

        @Override
        public void onServiceDisconnected(ComponentName name) {

        }
    };

然后在绑定成功Service的时候将客户端的Messenger对象传递给服务端。

这样就实现了客户端与服务端的双方通信。

---

到这里就讲完了Messenger的简单使用，如果文中有错误的地方欢迎大家指正，如果有疑惑的地方，欢迎大家留言讨论。

3Q