Android Messenger实现进程间双向通信

 更新时间:2021年05月21日 10:09:48   作者:Jason_Flash  
这篇文章主要为大家详细介绍了Messenger实现进程间双向通信,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下

简介

Messenger是安卓进程间通信 (IPC) 最为简单的方式,可以实现进程间双向通信。详见官网介绍

代码实现

服务端应用实现

MessengerService接收客户端发送的消息:

package com.test.messengerservice;
import android.app.Service;
import android.content.Intent;
import android.os.Handler;
import android.os.IBinder;
import android.os.Message;
import android.os.Messenger;
import android.os.RemoteException;
import android.util.Log;
import androidx.annotation.NonNull;

public class MessengerService extends Service {

    //接收客户端的消息类型
    private static final int SEND_MESSENGER = 0;
    private static final int CONFIG_NET = 1;
    private static final int CANCEL = 2;

    //发送给客户端的消息类型
    private static final int FIND_DEVICE = 10;

    public MessengerService() {
    }

    private Messenger messenger = new Messenger(new ServiceHandler());
    private static Messenger mClient;

    public class ServiceHandler extends Handler {

        @Override
        public void handleMessage(@NonNull Message msg) {
            // 处理消息
            switch(msg.what){
                case SEND_MESSENGER:
                    Log.d("service", "receive messenger");
                    mClient = msg.replyTo;
                    break;
                case CONFIG_NET:
                    Log.d("service", "config net task");
                    mClient = msg.replyTo;
                    break;
                case CANCEL:
                    Log.d("service", "cancel task");
                    mClient = msg.replyTo;
                    break;
                default:
                    break;
            }
        }
    }

    @Override
    public IBinder onBind(Intent intent) {
        Log.i("service", "service bind");
        return messenger.getBinder();
    }

    @Override
    public boolean onUnbind(Intent intent) {
        Log.i("service", "service unbind");
        mClient = null;
        return super.onUnbind(intent);
    }

 //向客户端发送消息
    public static void sendMessage() {
        if (null == mClient) {
            Log.d("service", "client is null");
            return;
        }
        try {
            Message message = Message.obtain(null, FIND_DEVICE);
            mClient.send(message);
        } catch (RemoteException e) {
            e.printStackTrace();
        }
    }
}

AndroidManifest.xml中注册messenger服务:

<service
    android:name=".MessengerService"
    android:enabled="true"
    android:exported="true">
    <intent-filter>
        <action android:name="android.intent.action.MESSENGER"/>
    </intent-filter>
</service>

MainActivity中设置按钮用于向客户端主动发送消息:

package com.test.messengerservice;

import androidx.appcompat.app.AppCompatActivity;

import android.os.Bundle;
import android.view.View;
import android.widget.Button;

public class MainActivity extends AppCompatActivity {

    private Button button;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        button = findViewById(R.id.findDeviceButton);
        button.setOnClickListener( new View.OnClickListener() {

            @Override
            public void onClick(View v) {
                MessengerService.sendMessage();
            }
        });
    }
}

客户端应用实现

MainActivity中绑定服务端的service,并设置向客户端发送消息的按钮:

package com.test.messengerclient;

import androidx.annotation.NonNull;
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.Message;
import android.os.Messenger;
import android.os.RemoteException;
import android.util.Log;
import android.view.View;
import android.widget.Button;

public class MainActivity extends AppCompatActivity {

    // 服务端的Messenger
    private Messenger mService;
    // 客户端的Messenger
    private Messenger mMessenger;

    private Button buttonConfigNet;
    private Button buttonCancel;

    //发送给服务端的消息类型
    private static final int SEND_MESSENGER = 0;
    private static final int CONFIG_NET = 1;
    private static final int CANCEL = 2;

    //接收服务端的消息类型
    private static final int FIND_DEVICE = 10;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        //客户端Messenger
        mMessenger = new Messenger(new ClientHandler());
        //绑定服务
        bindServiceInvoked();

  //设置点击事件
        buttonConfigNet = findViewById(R.id.buttonConfigNet);
        buttonCancel = findViewById(R.id.buttonCancel);
        
        buttonConfigNet.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                if(mService != null) {
                    try {
                        Log.d("client", "send config net");
                        Message message = Message.obtain(null, CONFIG_NET);
                        message.replyTo = mMessenger;
                        mService.send(message);
                    } catch (RemoteException e) {
                        e.printStackTrace();
                    }
                }
            }
        });

        buttonCancel.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                if(mService != null) {
                    try {
                        Log.d("client", "send cancel");
                        Message message = Message.obtain(null, CANCEL);
                        message.replyTo = mMessenger;
                        mService.send(message);
                    } catch (RemoteException e) {
                        e.printStackTrace();
                    }
                }
            }
        });
    }

 //接收服务连接和断开消息
    ServiceConnection serviceConnection = new ServiceConnection() {
        @Override
        public void onServiceConnected(ComponentName name, IBinder service) {
            Log.i("client", "service connected");
            mService = new Messenger(service);

   //由于绑定后服务端没有客户端的Messenger ,绑定后先将客户端Messenger发送给服务端
            if(mService != null) {
                try {
                    Log.d("client", "send messenger");
                    Message message = Message.obtain(null, SEND_MESSENGER);
                    message.replyTo = mMessenger;
                    mService.send(message);
                } catch (RemoteException e) {
                    e.printStackTrace();
                }
            }
        }

        @Override
        public void onServiceDisconnected(ComponentName name) {
            Log.i("client", "service disconnected");
            mService = null;
        }
    };

 //从服务端接收消息
    public class ClientHandler extends Handler {

        @Override
        public void handleMessage(@NonNull Message msg) {
            switch (msg.what){
                case FIND_DEVICE:
                    Log.i("client", "find device");
                    break;
            }
        }
    }

 //绑定服务端的service
    private void bindServiceInvoked()
    {
        Intent intent = new Intent();
        intent.setAction("android.intent.action.MESSENGER");
        intent.setPackage("com.test.messengerservice");
        bindService(intent, serviceConnection, Context.BIND_AUTO_CREATE);
    }
}

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

相关文章

  • Android打开GPS导航并获取位置信息返回null解决方案

    Android打开GPS导航并获取位置信息返回null解决方案

    最近在做一个 Android 项目,需要用到GPS获取位置信息,从 API 查了一下,发现获取位置信息仅需极其简单的一句即可getLastKnownLocation(LocationManager.GPS_PROVIDER)郁闷的是一直为null,于是搜集整理下,晒出来与大家分享
    2013-01-01
  • PowerManagerService之自动灭屏流程解析

    PowerManagerService之自动灭屏流程解析

    这篇文章主要为大家介绍了PowerManagerService之自动灭屏流程解析,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-10-10
  • Flutter利用Hero组件实现自定义路径效果的动画

    Flutter利用Hero组件实现自定义路径效果的动画

    本篇介绍了如何利用Hero动画组件的createRectTween属性实现自定义路径效果的动画。文中的示例代码讲解详细,感兴趣的可以了解一下
    2022-06-06
  • Kotlin扩展函数超详细介绍

    Kotlin扩展函数超详细介绍

    Kotlin 可以为一个不能修改的或来自第三方库中的类编写一个新的函数。 这个新增的函数就像那个原始类本来就有的函数一样,可以用普通的方法调用,这种机制的函数称为扩展函数
    2022-09-09
  • Android基于高德地图poi的仿微信获取位置功能实例代码

    Android基于高德地图poi的仿微信获取位置功能实例代码

    这篇文章主要介绍了Android基于高德地图poi的仿微信获取位置功能,当用户打开页面自动定位,同时搜索周边所有poi,点击搜索按钮输入关键字,获取关键字搜索结果,本文图文并茂给大家介绍的非常详细,需要的朋友参考下吧
    2017-12-12
  • Android用RecyclerView实现动态添加本地图片

    Android用RecyclerView实现动态添加本地图片

    本篇文章主要介绍了Android用RecyclerView实现动态添加本地图片,具有一定的参考价值,有兴趣的可以了解一下
    2017-08-08
  • android开发权限询问的示例代码

    android开发权限询问的示例代码

    这篇文章主要介绍了android开发权限询问的示例代码,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2018-01-01
  • Android的Touch事件处理机制介绍

    Android的Touch事件处理机制介绍

    Android的Touch事件处理机制比较复杂,特别是在考虑了多点触摸以及事件拦截之后,有需求的朋友可以参考下
    2012-11-11
  • 基于Android自定义控件实现刮刮乐效果

    基于Android自定义控件实现刮刮乐效果

    这篇文章主要介绍了基于Android自定义控件实现刮刮乐效果 的相关资料,需要的朋友可以参考下
    2015-12-12
  • Android编程之文件的读写实例详解

    Android编程之文件的读写实例详解

    这篇文章主要介绍了Android编程之文件的读写方法,结合实例形式较为详细的分析了Android针对文件操作的详细步骤,常用函数及使用技巧,需要的朋友可以参考下
    2015-12-12

最新评论