笔记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 条评论
登录 后参与评论

相关文章

来自专栏魂祭心

原 canvas绘制clock

4174
来自专栏一个会写诗的程序员的博客

Spring Reactor 项目核心库Reactor Core

Non-Blocking Reactive Streams Foundation for the JVM both implementing a Reactiv...

2202
来自专栏张善友的专栏

Mix 10 上的asp.net mvc 2的相关Session

Beyond File | New Company: From Cheesy Sample to Social Platform Scott Hansel...

2607
来自专栏闻道于事

js登录滑动验证,不滑动无法登陆

js的判断这里是根据滑块的位置进行判断,应该是用一个flag判断 <%@ page language="java" contentType="text/html...

6998
来自专栏芋道源码1024

熔断器 Hystrix 源码解析 —— 断路器 HystrixCircuitBreaker

本文主要基于 Hystrix 1.5.X 版本 1. 概述 2. HystrixCircuitBreaker 3. HystrixCircuitBreaker....

5367
来自专栏张善友的专栏

Silverlight + Model-View-ViewModel (MVVM)

     早在2005年,John Gossman写了一篇关于Model-View-ViewModel模式的博文,这种模式被他所在的微软的项目组用来创建Expr...

2988
来自专栏跟着阿笨一起玩NET

c#实现打印功能

2822
来自专栏pangguoming

Spring Boot集成JasperReports生成PDF文档

由于工作需要,要实现后端根据模板动态填充数据生成PDF文档,通过技术选型,使用Ireport5.6来设计模板,结合JasperReports5.6工具库来调用渲...

1.2K7
来自专栏张善友的专栏

LINQ via C# 系列文章

LINQ via C# Recently I am giving a series of talk on LINQ. the name “LINQ via C...

2665
来自专栏ASP.NETCore

ASP.NET Core 整合Autofac和Castle实现自动AOP拦截

除了ASP.NETCore自带的IOC容器外,我们还可以使用其他成熟的DI框架,如Autofac,StructureMap等(笔者只用过Unity,Ninjec...

674

扫码关注云+社区