笔记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学习之sqlite与listview

在android系统中使用的是sqlite数据库,前面的简易登录系统已经讲述了数据库的应用。本例的重点是实现数据库与listview的绑定。demo的数据是将个...

3116
来自专栏Android Note

Android-实用的MVP

1073
来自专栏项勇

笔记56 | 管理网络的使用

1436
来自专栏何俊林

一款聚合电影、电视剧、综艺节目、动漫、游戏影音软件开源啦!

1165
来自专栏知识分享

Android之TCP服务器编程android 之TCP客户端编程

推荐一个学java或C++的网站http://www.weixueyuan.net/,本来想自己学了总结出来再写博客,现在没时间,打字太慢!!!!,又想让这好东...

4616
来自专栏Android知识点总结

3-AIII--Service绑定服务基于接口调用方法

1115
来自专栏Android源码框架分析

从Toast显示原理初窥Android窗口管理

Android窗口管理系统是非常大的一块,涉及AMS、InputManagerService、输入法管理等,这么复杂的一个系统,如果直接扎进入分析看源码可能会比...

1224
来自专栏Android源码框架分析

ViewPager刷新问题原理分析及解决方案(FragmentPagerAdapter+FragementStatePagerAdapter)ViewPager+FragmentPagerAdapte

2352
来自专栏Android干货

Android项目实战(十六):QQ空间实现(一)—— 展示说说中的评论内容并有相应点击事件

1437
来自专栏Android干货

Android项目实战(十六):QQ空间实现(一)—— 展示说说中的评论内容并有相应点击事件

3746

扫码关注云+社区