Kotlin进程通信------Messenger

Posted 2021-08-09 战国剑

进程通信原理与Binder底层说明，可参考：https://zhuanlan.zhihu.com/p/35519585

本文主要介绍应用层上如何用Kotlin来使用Messenger进行进程通讯。

Messenger是对底层Binder进行封装后的一套系统框架，在进程间通讯的表现是串行通讯。假设有进程A和进程B。如果要进行多次数据通讯，会是A-B-A-B-......这样的模式。

Messenger的做法，简要说明就是：两个进程A（client）、B（service），A将一个Messenger信息发送到B，B通过handler来接收来自A的信息，并将想要返回的信息返回A。

一、server服务端

代码如下，这里比较绕的是这句代码：

val fromClient = msg.replyTo

此处的 msg.replyTo，是客户端发送过来的包含客户端handler的Messenger对象。

那么，后续的fromClient.send(any)，做的就是把数据传回给客户端的handler做处理。

class MessengerService :Service() {


    private val handler: Handler = @SuppressLint("HandlerLeak")
    object:Handler(){
        override fun handleMessage(msg: Message) {
           when(msg.what){
               MSG_FROM_CLIENT -> {
                   println("接收到客户端信息")
                   println(msg.data.get("TestKey"))

                   val fromClient = msg.replyTo
                   val currentMsg:Message = Message.obtain(null, MSG_FROM_CLIENT)
                   val bundle:Bundle = Bundle()
                   bundle.putString("KeyFromServer","这是服务端的回复")
                   currentMsg.data = bundle
                   fromClient.send(currentMsg)
               }
               else -> println("其他信息")
           }
        }
    }

    override fun onBind(intent: Intent?): IBinder? {
        return Messenger(handler).binder
    }


}

二、client客户端

客户端要做的操作，一是连接服务端，二是发送信息给服务端，并得到服务端的返回

代码中，需要注意的代码块是：

               

override fun onServiceConnected(name: ComponentName?, service: IBinder?) {
    
    messenger = Messenger(service)
    val msg: Message = Message.obtain(null, MSG_FROM_CLIENT)

    val bundle:Bundle = Bundle()
    bundle.putString("TestKey","TestValue")
    msg.data = bundle
    msg.replyTo = Messenger(handler)
    messenger.send(msg)

}

1、messenger = Messenger(service)，该service是服务端Hander被Binder包装后返回的（具体看服务端的OnBinder方法）。因此，经此发送的数据，将被服务端的Handler接收与处理

2、msg.replyTo = Messenger(handler)，告知服务端，客户端处处理，服务端返回数据的，是哪个Handler。

整体代码如下：

class MessengerActivity : AppCompatActivity() {
    lateinit var messenger: Messenger
    lateinit var serviceConnection:ServiceConnection

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_messenger)
        messengerTest.setOnClickListener { testSendMessageByMessenger() }
    }

    private fun testSendMessageByMessenger(){
        val intent = Intent(this, MessengerService::class.java)
        serviceConnection = object : ServiceConnection {
            override fun onServiceDisconnected(name: ComponentName?) {
                println("onServiceDisconnected $name")
            }

            override fun onServiceConnected(name: ComponentName?, service: IBinder?) {
                messenger = Messenger(service)
                val msg: Message = Message.obtain(null, MSG_FROM_CLIENT)

                val bundle:Bundle = Bundle()
                bundle.putString("TestKey","TestValue")
                msg.data = bundle
                msg.replyTo = Messenger(handler)
                messenger.send(msg)

            }
        }
        val type = Context.BIND_AUTO_CREATE
        bindService(intent,serviceConnection,type)
    }

    override fun onDestroy() {
        super.onDestroy()
        serviceConnection?.let { unbindService(serviceConnection) }
    }

    val handler:Handler =@SuppressLint("HandlerLeak") object :Handler(){
        override fun handleMessage(msg: Message) {
             println("收到service服务端消息")
            when(msg.what){
                MSG_FROM_CLIENT -> {
                    println("${msg.data.getString("KeyFromServer")}")
                }
            }
        }
    }
}

最后，在manifest中加上配置即可

<service
            android:name=".messenger.MessengerService"
            android:label="@string/messenger_name"
            android:process=":messenger_remote" />