Android 的进程间通信 Binder——Messenger的入门使用

进程间通信系列

AIDL的入门使用(一)
AIDL的入门使用(二)
AIDL的入门使用(三)
Messenger的入门使用
序言:Messenger是Google为我们封装好的简洁版的AIDL,当面对少量的并发进程间通信更适用。而且不用考虑线程同步问题。

Messenger进程间通信服务端

1、创建服务端Module “messenger_server”,并创建Service文件:右键单击包名——>New——>Service——>Service——>命名为MyServerService——>Finish;

image.png
image.png

2、在服务端的Service中创建一个Handler对象用于接收客户端发送过来的消息,使用handler对象创建一个服务端的Messenger,并在onBind方法中返回messenger.getBinder()

package com.ljp.messenger_server;
import android.app.Service;
import android.content.Intent;
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;
public class MyServerService extends Service {
    private static final String TAG = "messenger";
    //1、用于接收客户端发送过来的消息
    Handler mServerHandler = new Handler() {
        @Override
        public void handleMessage(Message msg) {
            switch (msg.what) {
                case 1:
                    //获取来自客户端的消息
                    Bundle data = msg.getData();
                    String clientMsg = data.getString("clientMsg");
                    Log.e(TAG, "handleMessage: 收到来自客户端的消息:clientMsg=" + clientMsg);
                    // 向客户端回复消息
                    Messenger clientMessenger = msg.replyTo; //获取到客户端的 Messenger,这里可以保存为全局变量,以后就不用每次都去获取了
                    Message toClientMsg = Message.obtain();
                    toClientMsg.what=1;
                    Bundle bundle = new Bundle();
                    bundle.putString("serverMsg", "我是服务端,已经收到你的消息了");
                    toClientMsg.setData(bundle);
                    try {
                        clientMessenger.send(toClientMsg);//回复客户端
                    } catch (RemoteException e) {
                        e.printStackTrace();
                    }
                    break;
                default:
                    super.handleMessage(msg);
                    break;
            }
        }
    };
    //2、使用Handler创建Messenger。
    Messenger mServerMessenger = new Messenger(mServerHandler);
    @Override
    public IBinder onBind(Intent intent) {
        return mServerMessenger.getBinder();//3、向客户端返回服务端的Binder
    }
    @Override
    public void onDestroy() {
        super.onDestroy();
        Log.e(TAG, "onDestroy: MyServerService销毁" );
    }
}

3、在AndroidMainfest文件中注册Service并添加对应的Action并对外暴露使用。

        <!--注:服务端的包名为:com.ljp.messenger_server,客户端绑定Service的时候是使用程序的包名,不是使用MyServerService类的包名-->
        <service
            android:name=".MyServerService"
            android:enabled="true"
            android:exported="true">
            <intent-filter>
                <action android:name="com.ljp.messenger_server.server.action"/>
            </intent-filter>
        </service>

服务端的创建完成了,再来看看客户端。

Messenger进程间通信客户端

1、创建服务端Module “messenger_client”,创建一个客户端Handler对象用于接收服务端发送过来的消息,使用handler对象创建一个客户端的Messenger,在bindService成功后保存服务端的Messenger并用此向服务端发送消息,代码中有详细的步骤。

package com.ljp.messenger_client;
import android.content.ComponentName;
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.support.v7.app.AppCompatActivity;
import android.util.Log;
import android.view.View;
public class MainActivity extends AppCompatActivity {
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
    }
    Messenger mServerMessenger = null;
    ServiceConnection mConnection = new ServiceConnection() {
        @Override
        public void onServiceConnected(ComponentName name, IBinder service) {
            mServerMessenger = new Messenger(service);
            Log.e(TAG, "onServiceConnected: 绑定服务端成功");
        }
        @Override
        public void onServiceDisconnected(ComponentName name) {//注:unbindService不会调用此方法
            mServerMessenger = null;
            Log.e(TAG, "onServiceDisconnected: 与服务端断开联系");
        }
    };
    //3、绑定服务端并在回调方法onServiceConnected中保存下服务端的Messenger
    public void bind(View view) {
        Intent intent = new Intent();
        intent.setPackage("com.ljp.messenger_server");
        intent.setAction("com.ljp.messenger_server.server.action");
        boolean bindService = bindService(intent, mConnection, BIND_AUTO_CREATE);
        Log.e(TAG, "bind: bindService=" + bindService);
    }
    private static final String TAG = "messenger";
    //1、创建一个Handler用于接收服务端发送过来的消息
    Handler mClientHandler = new Handler() {
        @Override
        public void handleMessage(Message msg) {
            switch (msg.what) {
                case 1:
                    //获取来自服务端的消息
                    Bundle data = msg.getData();
                    String serverMsg = data.getString("serverMsg");
                    Log.e(TAG, "handleMessage: 收到来自服务端的消息:serverMsg=" + serverMsg);
                    break;
                default:
                    super.handleMessage(msg);
                    break;
            }
        }
    };
    //2、构建一个客户端的Messenger,方便服务端使用
    Messenger mClientMessenger = new Messenger(mClientHandler);
    //4、使用服务端的Messenger发送消息给服务端,并携带上客户端的Messenger。
    public void sendMessageToServer(View view) {
        if (mServerMessenger == null) return;
        // 向服务端发送消息
        Message toServerMsg = Message.obtain();
        toServerMsg.what = 1;
        toServerMsg.replyTo = mClientMessenger;//将客户端的Messenger携带上,服务端可以用来回复客户端的消息
        Bundle bundle = new Bundle();
        bundle.putString("clientMsg", "你好,服务端*~*");
        toServerMsg.setData(bundle);
        try {
            mServerMessenger.send(toServerMsg);//使用服务端的Messenger发送消息给服务端
            Log.e(TAG, "sendMessageToServer: ");
        } catch (RemoteException e) {
            e.printStackTrace();
        }
    }
    public void unBind(View view) {
        if (mServerMessenger != null) {
            unbindService(mConnection);
            mServerMessenger = null;
        }
        Log.e(TAG, "unBind: ");
    }
    @Override
    protected void onDestroy() {
        super.onDestroy();
        unBind(null);
    }
}

测试结果如下:

11-30 10:38:33.543 27094-27094/com.ljp.messenger_client E/messenger: bind: bindService=true
11-30 10:38:33.553 27094-27094/com.ljp.messenger_client E/messenger: onServiceConnected: 绑定服务端成功
11-30 10:38:35.313 26811-26811/com.ljp.messenger_server E/messenger: handleMessage: 收到来自客户端的消息:clientMsg=你好,服务端*~*
11-30 10:38:35.323 27094-27094/com.ljp.messenger_client E/messenger: sendMessageToServer: 
11-30 10:38:35.323 27094-27094/com.ljp.messenger_client E/messenger: handleMessage: 收到来自服务端的消息:serverMsg=我是服务端,已经收到你的消息了
11-30 10:38:37.113 27094-27094/com.ljp.messenger_client E/messenger: unBind: 
11-30 10:38:37.113 26811-26811/com.ljp.messenger_server E/messenger: onDestroy: MyServerService销毁

Messenger的总结

1、客户端报错:java.lang.RuntimeException: Can't marshal non-Parcelable objects across processes.;是因为发送消息时使用了msg.obj字段赋值了一个字符串,可以采用不实用msg.obj,使用Bundle传递数据,msg.setData(bundle),bundle=msg.getData();
2、Message中能使用的载体只有what、arg1、arg2、replyTo、Bundle;不要使用 obj 字段;
3、Android 5.0以后不支持隐式intent启动Service(未验证),需要将隐式的intent转换为显式的intent,转换方法为:
        Intent intent = new Intent();
        intent.setPackage("com.ljp.messenger_server");
        intent.setAction("com.ljp.messenger_server.server.action");//以上构成了隐式的intent
        PackageManager packageManager = getPackageManager();
        ResolveInfo resolveInfo = packageManager.resolveService(intent, 0); //我们先通过一个隐式的Intent获取可能会被启动的Service的信息,
        if (resolveInfo!=null){//系统中有这个意图,说明我们能通过上面隐式的Intent找到对应的Service
            String packageName = resolveInfo.serviceInfo.packageName;//得到的Service的包名
            String name = resolveInfo.serviceInfo.name;//得到的Service的类名
            ComponentName componentName=new ComponentName(packageName,name);
            intent.setComponent(componentName);//已经转为了显式的intent了
            Log.e(TAG, "bind: 已经转为了显式的intent了" );
        } 
4、Messenger的构造方法的使用
    public Messenger(Handler target) {//一般用于需要接受消息的一端。
        mTarget = target.getIMessenger();
    }
    public Messenger(IBinder target) {//一般使用在客户端。
        mTarget = IMessenger.Stub.asInterface(target);
    }
5、使用场景:少量的一对多的串行进程间通信,支持实时通信,使用比较简单,不支持直接调用服务端的方法(可以通过msg.what进行间接调用并返回调用结果)。

我的CSDN博客地址:http://blog.csdn.net/wo_ha/article/details/78674323

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 212,816评论 6 492
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,729评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 158,300评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,780评论 1 285
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,890评论 6 385
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,084评论 1 291
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,151评论 3 410
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,912评论 0 268
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,355评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,666评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,809评论 1 341
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,504评论 4 334
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,150评论 3 317
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,882评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,121评论 1 267
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,628评论 2 362
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,724评论 2 351