当前位置:   article > 正文

随笔Android IPC进程通信之——Messenger_android messenger replyto 主进程收不到消息

android messenger replyto 主进程收不到消息

随笔Android IPC进程通信之——Messenger

android中用于进程通信和数据共享的方式有多种,最基本的Bundle,文件共享,Messenger,AIDL,ContentProvider,Socket等,他们的区别和使用场景这里就不再说了,详情自行查看了解了解,本文直接介绍方式之一Messenger(信使)的使用方式。

代码为例,开始看看我们遇到的问题,模拟多进程数据同步问题

1.新建一个IPCDemo,创建一个自己的Applciation并声明一个公用变量value

这里写图片描述

2.新建两个Activity,在第一个MainActivity中修改Oncreate中修改 Application中value值为8
这里写图片描述

由MainActivity进入第二个页面(服务Activity)注意此activity在Manifest中配置中添加android:process=”:remote”,目的是让其单独运行在一个进程中,和MainActivity不同进程。
这里写图片描述

在ServerActivity中我们同样打印Applcation中的value;
结果如下:
这里写图片描述

3.引起的问题 我们知道一个应用中Application是一个重量级的,由系统创建的单一实例,其中的数据是共享的,那么这里我们在MainActivity中修改了value值,这个应用中的其他访问的地方应该都是修改后的值,但上面的结果却不是这样。

原因就在于,我们的ServerActivity配置了android:process=":remote",这会导致ServerActivity运行在另一进程中,说白了就是,MainActivity是一个应用,ServerActivity是一个应用,既然是两个不同应用,那么就会有两个不同的Application实例,Application会创建多次(这里两次),这两个实例分别位于不同进程(应用中),这就是为什么修改第一个全局值,而第二个进程中的值没有任何影响的原因。
  • 1

4.解决问题 我们如何让第一个进程修改变量值的时候,通知另一个进程同步修改对应的值?接下来就利用本文介绍的Messenger。

Messenger 运用

messenger 其实是基于消息的进程通信方式,最基本的理解就是有客户端,服务端如下图:
这里写图片描述

接下来代码介绍:
我们的MainActivity用来充当客户端,ServerActivity充当服务端,因为两个页面完全运行在不同的进程中。

首先,创建一个MessengerService,并在manifest中配置成和ServerActivity中相同的进程。代码如下:

/**
 * Created by Frosty on 2017/6/13.
 *//

public class    MessengerService extends Service{
    public static String TAG = MessengerService.class.getSimpleName();
    public final static int FROM_CLIENT = 1;//来此客户端请求
    public final static int FROM_SERVICE= 2;//来此服务端请求
    private Messenger msngerCurrent;//当前类使用(发送消息、接收处理消息)

    @Override
    public void onCreate() {
        super.onCreate();
        msngerCurrent = new Messenger(new MessengerHandler());
    }

    @Nullable
    @Override
    public IBinder onBind(Intent intent) {
        return msngerCurrent.getBinder();
    }

    public static class MessengerHandler extends Handler{
        @Override
        public void handleMessage(Message msg) {
            switch (msg.what){
                case FROM_CLIENT:

                    ///1.处理接受消息
                    Log.e(TAG,"收到来自客户端【"+msg.getData().getString("name")+"】的消息:"+msg.getData().getString("content"));

                    MyApplication.value = msg.getData().getInt("value");

                    //2.拿到客户端发送消息附带的Messenger,用它回传消息
                    Messenger msngerReply = msg.replyTo;
                    //封装回传消息
                    Message replyMsg = Message.obtain(null,FROM_SERVICE);
                    Bundle bundle = new Bundle();
                    bundle.putString("name","阿里云");
                    bundle.putString("content","你好,我这边已经同步修改,值为:"+MyApplication.value);
                    replyMsg.setData(bundle);
                    try {
                        msngerReply.send(replyMsg);//回传消息
                    }catch (Exception e){}
                    break;

                default:break;
            }
        }
    }
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
这里暂时只说明这个服务的功能,利用MessengerHandler处理发送自客户端来的数据,通过msg.what匹配。
  • 1

所以我们在客户端(MainActivity中去注册绑定这个服务,并在修改appvalue时候发送一个消息给这个服务)

public class MainActivity extends AppCompatActivity {

    private Messenger msngerCurrent;
    private class MessengerHandler extends Handler{
        @Override
        public void handleMessage(Message msg) {
            switch (msg.what){
                case MessengerService.FROM_SERVICE:
                    Log.e("MessengerService","收到来自服务端【"+msg.getData().getString("name")+"】的回应:"+msg.getData().getString("content"));
                    unbindService(serviceConnection);
                    break;
            }
        }
    }

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        MyApplication.value = 8;//此处修改值

        Log.e("appvalue","MainActivity中获取到的value:"+MyApplication.value);
        /*绑定服务*/
        bindRemoteService();
        msngerCurrent = new Messenger(new MessengerHandler());
        findViewById(R.id.btn_requestServer).setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                Intent intent = new Intent(MainActivity.this,ServerActivity.class);
                startActivity(intent);
            }
        });
    }



    ///服务链接状态监听
    private ServiceConnection serviceConnection = new ServiceConnection() {
        @Override
        public void onServiceConnected(ComponentName name, IBinder service) {
            Messenger messengerClient = new Messenger(service);
            /*封装消息体*/
            Message msg = Message.obtain(null,MessengerService.FROM_CLIENT);//对应服务端接受码
            Bundle bundle = new Bundle();
            bundle.putString("name","张山");
            bundle.putString("content","我修改了我们的共享值,请你务必修改!");
            bundle.putInt("value",MyApplication.value);
            msg.setData(bundle);
            msg.replyTo=msngerCurrent;
            //发送
            try{
                messengerClient.send(msg);
            }catch (Exception e){
            }
        }

        @Override
        public void onServiceDisconnected(ComponentName name) {
        }
    };

    public void bindRemoteService(){
        Intent intent = new Intent(this, MessengerService.class);
        bindService(intent,serviceConnection, Context.BIND_AUTO_CREATE);
    }


    @Override
    protected void onDestroy() {
        unbindService(serviceConnection);
        super.onDestr

oy();
    }
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73
  • 74
  • 75

我们详细解释一下工作流程
- 我们首先得创建一个ServiceConnection 用于检测服务绑定后或者断开后的操作如下图,绑定服务链接后,回掉调nServiceConnected方法,在这个方法中,我们构造一个客户端Messenger
这里写图片描述并用message封装数据,然后用这个Messenger发送消息即可

发送消息后,MessengerService便可以接收到消息处理,修改当前进程的appvalue值,并回传附加消息给客户端,注意这里回传的Messenger,直接在获取消息体中用msg.replyTo获取,前提是客户端相应的在传过来的msg中replyTo赋值Mesenger,此messenger在客户端也用来处理服务端响应回来的数据。

这里写图片描述

5.结果 我们重启应用,重新打印两个值
这里写图片描述
发现在主进程修改appvalue后,另一个进程获取到的值也及时得到同步了。

End注意:Messenger通信,可使用它进行进程间的通信,而Messenger对Service的请求采用队列的方式,因此它不支持多线程通信。

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/Gausst松鼠会/article/detail/122672?site
推荐阅读
相关标签
  

闽ICP备14008679号