笔记36 | android通讯之实现一个Messenger通讯例子

地址

http://blog.csdn.net/xiangyong_1521/article/details/78559022


前言

Android进程间的通信方式常见有Intent,Broadcast,aidl,SharedPreferences,ContentProvider,Messenger,Socket。 本节要学习的就是Messenger!


目录

  • Messenger介绍
  • 实现

Messenger介绍

/**
 * Reference to a Handler, which others can use to send messages to it(引用一个Handler,其他人可以用来向它发送消息).
 * This allows for the implementation of message-based communication across
 * processes(这允许实现基于消息的通信的实现), by creating a Messenger pointing to a Handler in one process(通过在一个进程中创建一个指向处理程序的Messenger),
 * and handing that Messenger to another process(将Messenger交给另一个进程).
 */
public final class Messenger implements Parcelable {

服务端提供一个Service来处理客户端连接,维护一个Handler来创建Messenger,在onBind时返回Messenger的binder。 双方用Messenger来发送数据,用Handler来处理数据。Messenger处理数据依靠Handler,所以是串行的,也就是说,Handler接到多个message时,就要排队依次处理。


实现

A.Service端:

服务端就一个Service,先去声明一个Messenger对象,然后onBind方法返回mMessenger.getBinder();

等客户端将消息发送到handleMessage方法,根据message.what去判断进行什么操作,然后做对应的操作,最终将结果通过 msgfromClient.replyTo.send(msgToClient);返回。

这里主要是取出客户端传来的两个数字,然后求和返回,这里我有意添加了sleep(1500)模拟耗时,注意在实际使用过程中,可以换成在独立开辟的线程中完成耗时操作,比如和HandlerThread结合使用。

/*
 * Service端,负责接收并处理Messenger数据并返回结果给Client端
 * evan by 20171117
 */
public class mService extends Service{

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

    private static final int MSG_SUM = 0x110;
    private Messenger messenger = new Messenger(new Handler(){//声明一个messenger对象

        public void handleMessage(Message frommsg) {

            Message tomessage = Message.obtain(frommsg);
            switch (frommsg.what) {//判断做什么操作
            case MSG_SUM:
                tomessage.what=MSG_SUM;
                try {
                    Thread.sleep(1500);
                    tomessage.arg1 = frommsg.arg1+frommsg.arg2;
                    frommsg.replyTo.send(tomessage);//返回数据
                    Log.i("md", "收到aig1:"+frommsg.arg1+", aig2:"+frommsg.arg2+", what:"+frommsg.what+", 并返回了:"+tomessage.arg1);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                    Toast.makeText(getApplication(), "e.InterruptedException()", 1).show();
                    } catch (RemoteException e) {
                    e.printStackTrace();
                    Toast.makeText(getApplication(), "e.RemoteException()", 1).show();
                }
                break;
            }
            super.handleMessage(frommsg);
        };
    });
}

B.AndroidManifest中注册service

<service 
            android:name=".mService"
            android:enabled="true"
            android:exported="true">
            <intent-filter>
                <action android:name="com.evan.messer"></action>
                <category android:name="android.intent.category.DEFAULT"/>
                </intent-filter>
            </service>

C.Client端:

首先建立连接:写一个bindService的方法bindServiceInvoike(),在onServiceConnected中拿到回调的service(IBinder)对象,通过service对象去构造一个mService =new Messenger(service);

建立连接后,就可以使用mService.send(msg)给服务端了。

发送后,在写一个接受service返回的方法messenger,service收到消息后,处理完成会将结果返回,就可以传到Client端的messenger中的Handler的handleMessage方法中了。

/*
 * Client端,负责通过Messenger发送与接受数据
 * evan by 20171117
 */
public class MainActivity extends ActionBarActivity implements OnClickListener{
    private static final String TAG = "MainActivity";
    private static final int MSG_SUM = 0x110;

    private Button mBtnAdd;
    private LinearLayout mLyContainer;
    //显示连接状态
    private TextView mTvState,mTvInfo;

    private Messenger mService;
    private boolean isConn;

    private int mA;

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

    private void initView() {
        mTvState=(TextView)findViewById(R.id.textView1);
        mLyContainer=(LinearLayout)findViewById(R.id.mLyContainer);
        mBtnAdd=(Button)findViewById(R.id.button1);
        mBtnAdd.setOnClickListener(this);
    }

    /*
     * 建立连接
     */
    private void bindServiceInvoike() {
        Intent intent = new Intent();
        intent.setAction("com.evan.messer");
        bindService(intent, mConn, Context.BIND_AUTO_CREATE);
    }

        /*
     * 拿到ServiceConnection连接数据
     */
    private ServiceConnection mConn = new ServiceConnection() {

        @Override
        public void onServiceDisconnected(ComponentName name) {
            mService = null;
            isConn = false;
            mTvState.setText("disconnected!");
        }

        @Override
        public void onServiceConnected(ComponentName name, IBinder service) {
            mService = new Messenger(service);
            isConn = true;
            mTvState.setText("connected!");
        }
    };

    /*
     * 发送消息
     */
    @Override
    public void onClick(View v) {
        try {
            int a = mA++;
            int b = (int)(Math.random()*100);

            TextView tv = new TextView(MainActivity.this);
            tv.setText(a+"+"+b+" = 服务器返回的结果: ");
            tv.setId(b);
            mLyContainer.addView(tv);

            Message msgFromClient = Message.obtain(null,MSG_SUM,a,b);
            msgFromClient.replyTo = messenger;

            if (isConn) {
                mService.send(msgFromClient);//往服务里发信息
                Log.i("md", "发送aig1:"+a+", aig2:"+b+",what:"+MSG_SUM+",给services!");
            }

        } catch (RemoteException e) {
            e.printStackTrace();
        }
    }

        /*
     * 接收service处理的数据
     */
    private Messenger messenger = new Messenger(new Handler(){//服务端会收到消息,处理完成会将结果返回,

        public void handleMessage(Message msgfrom) {
            switch (msgfrom.what) {
            case MSG_SUM:
                  TextView tv = (TextView) mLyContainer.findViewById(msgfrom.arg2);
                  tv.setText(tv.getText() + " = " + msgfrom.arg1);
                    Log.i("md", "收到service的Messenger数据:"+msgfrom.arg1);
                  break;
            }
            super.handleMessage(msgfrom);
        };
    });

        /*
         *断开与服务器的连接
         */
    protected void onDestroy() {
        super.onDestroy();
        unbindService(mConn);
    };
}

D.XML:

<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
    xmlns:tools="http://schemas.android.com/tools"
    android:id="@+id/mLyContainer"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    tools:context="com.example.messenger_client.MainActivity"
    tools:ignore="MergeRootFrame"
    android:orientation="vertical"
     >

    <TextView
        android:id="@+id/textView1"
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        android:text="状态信息:"
        />

    <Button
        android:id="@+id/button1"
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        android:text="发送" 
        />

</LinearLayout>

E.运行:

打印:

11-17 11:17:44.842: I/md(10549): 发送aig1:8, aig2:6,what:272,给services!
11-17 11:17:46.342: I/md(10258): 收到aig1:8, aig2:6, what:272, 并返回了:14
11-17 11:17:46.344: I/md(10549): 收到service的Messenger数据:14

原文发布于微信公众号 - 项勇(xiangy_life)

原文发表时间:2017-11-17

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏双十二技术哥

Android AsyncLayoutInflater 限制及改进

上一篇文章中我们介绍了 AsyncLayoutInflater 的用法及源码实现,那么本文来分析下 AsyncLayoutInflater 使用的注意事项及改进...

2112
来自专栏james大数据架构

Android中Services简析

      Services是Android中四大基础组件(Activities、 Services、 Content Providers、 BroadCast...

2148
来自专栏androidBlog

ARouter 使用教程

版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/gdutxiaoxu/article/de...

1791
来自专栏开发之途

Android IPC机制(3)-Messenger

1624
来自专栏编程之路

羊皮书APP(Android版)开发系列(三)APP引导页启动控制类

1023
来自专栏后端之路

junit测试之第三方组件mock

今天某个一直稳定运行的测试挂了,没有开发同学出来认领。 ? 对应模块的小伙伴询问此处依赖的环境是哪个,可以去调查失败的原因。 好吧,回顾一下关于第三方组件mo...

2155
来自专栏Android小菜鸡

自定义Androidk全量更新组件

  自动更新功能对于一个APP来说是必备的功能,特别是对于未投放市场下载的APP,每次都让用户删掉原来的,再下载新的版本,肯定是不合适的。

772
来自专栏Android学习之路

Activity

1436
来自专栏Android知识点总结

[番外]理一理Android多文件上传那点事

1061
来自专栏张善友的专栏

使用ASP.NET实现Model View Presenter(MVP)

作者:Billy McCafferty 翻译:张善友 原文地址:http://www.codeproject.com/useritems/ModelViewPr...

2148

扫码关注云+社区