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

Posted 战国剑

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Kotlin进程通信------Messenger相关的知识,希望对你有一定的参考价值。

进程通信原理与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" />

以上是关于Kotlin进程通信------Messenger的主要内容,如果未能解决你的问题,请参考以下文章

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

Kotlin进程通信------AIDL

Kotlin进程通信------AIDL

Kotlin进程通信------AIDL

Android进程间的通信之Messenger

Android进程间的通信之Messenger