上饶市彦顺网络科技有限公司
首页 | 联系方式 | 加入收藏 | 设为首页 | 手机站

产品目录

联系方式

联系人:业务部
电话: 00137-363357
邮箱:service@yuandamt.com

当前位置:首页 >> 新闻中心 >> 正文

Messenger(轻量级的AIDL)

字号:
摘要:Messenger(轻量级的AIDL)

关于Messenger,我自己的理解,因为底层是AIDL,所以你想着AIDL的步骤就可以解决挺多的疑问的。

我自己总结了下调用的步骤:

关于服务端 1、和AIDL一致,同样是extend Service 并实现onBind方法(返回Messenger的Binder对象)

2、然后就是这个Messenger对象需要一个Handler对象作为参数来创建,我们就做一个处理客户端消息的Handler类(重写handlMessage方法)

3、前两步没什么难点,主要是handlerMessage中的处理,这里面需腰获取到客户端的Messenger对象,然后做出相应的处理,在将恢复的信息发回去

先上服务端的代码哈:

package com.example.chenxiaojiong.messengertext;
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.support.annotation.Nullable;
import android.util.Log;
/**
 * Created by chenxiaojiong on 2016/6/8.
 */
public class MessengerServices extends Service {
 private static final int FROM_SERVICE = 2;
 @Nullable
 @Override
 public IBinder onBind(Intent intent) {
 //获取Messenger的Binder对象
 return mMessenger.getBinder();
 }
 private Messenger mMessenger=new Messenger(new MessengerHandler());
 //设置Handler对象来接受客户端传递的信息并加以处理
 private class MessengerHandler extends Handler{
 @Override
 public void handleMessage(Message msg) {
 switch (msg.what){
 case 1:
 Log.i("kkkk", "msg from Client:" + msg.getData().getString("client"));
 //获取客户端传递的Messenger对象(由于replyTo参数,那到客户端的Messenger对象)
 Messenger messengerFromClient = msg.replyTo;
 //打包你要发送的数据,一般使用bundle,使用message来装载信息
// Message message = new Message();不能使用这个方法,不然回复给客户端不知道是从哪里发来的,除非在下面设置msg.what的值
 Message message=Message.obtain(null,FROM_SERVICE);
 Bundle bundle = new Bundle();
 bundle.putString("service","哥是服务端");
 message.setData(bundle);
 //回复客户端的消息
 try {
 messengerFromClient.send(message);
 } catch (RemoteException e) {
 e.printStackTrace();
 }
 break;
 default:
 super.handleMessage(msg);
 break;
 }
 }
 }
}
关于service你要注意的大概就是,需要到清单文件中注册下,不然好像不报错,也没有你想要的结果,好像是这样的……

关于客户端:1、既然是AIDL,那客户端就是绑定服务咯,还有绑定之后需要解绑(不然会报错的哈)

2、bindService中的参数需要一个ServiceConnection对象,我们就new一个赏给他,并实现它要求的两个方法(如下代码所示)

ServiceConnection mServiceConnection =new ServiceConnection() {
 @Override
 public void onServiceConnected(ComponentName name, IBinder service) {
 //获取服务端传递过来的Messenger对象
 Messenger messenger=new android.os.Messenger(service);
 //new 个message对象,通过他向服务端发送信息(必须带上标记,让服务端可以区分)
 Message obtain = Message.obtain(null, FROM_CLIENT);
 Bundle bundle=new Bundle();
 bundle.putString("client","哥是客户端");
 obtain.setData(bundle);
 //将接受服务端的Messenger对象(就是客户端中的Messenger)通过Message的replyTo参数传递给服务端
 obtain.replyTo=mGetReplyToMessenger;
 //发送信息给服务端
 try {
 messenger.send(obtain);
 } catch (RemoteException e) {
 e.printStackTrace();
 }
 }
 @Override
 public void onServiceDisconnected(ComponentName name) {
 }
 };

3、这一步就是onServiceConnected中的处理啦,上面的代码注释的应该很明确了,我这里就不多说,有一个需要注意的是你想服务端对客户端发的信息做出响应,那你就必须设置message.replyTo的属性为客户端的Messenger(这一点可能有点绕,比较难理解,我自己也不知道理解是不是对的,我就不多说)

4、需要什么我们就给你什么,那个客户端的Messenger,我们new一个给他,同样handler进行对服务端回调的处理,代码如下:

private Messenger mGetReplyToMessenger=new Messenger(new MessengerHandler());
 private class MessengerHandler extends Handler{
 @Override
 public void handleMessage(Message msg) {
 switch (msg.what){
 case 2:
 //获取服务端的响应
 String info = msg.getData().getString("service");
 Log.i("kkkk", "msg from Service:" + info);
 break;
 default:
 super.handleMessage(msg);
 }
 }
 }


客户端的完整代码:
package com.example.chenxiaojiong.messengertext;
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;
public class MessengerTextActivity extends AppCompatActivity {
 private static final int FROM_CLIENT = 1;
 @Override
 protected void onCreate(Bundle savedInstanceState) {
 super.onCreate(savedInstanceState);
 setContentView(R.layout.activity_messenger_text);
 Intent intent = new Intent(this, MessengerServices.class);
 bindService(intent,mServiceConnection,BIND_AUTO_CREATE);
 }
 ServiceConnection mServiceConnection =new ServiceConnection() {
 @Override
 public void onServiceConnected(ComponentName name, IBinder service) {
 //获取服务端传递过来的Messenger对象
 Messenger messenger=new android.os.Messenger(service);
 //new 个message对象,通过他向服务端发送信息(必须带上标记,让服务端可以区分)
 Message obtain = Message.obtain(null, FROM_CLIENT);
 Bundle bundle=new Bundle();
 bundle.putString("client","哥是客户端");
 obtain.setData(bundle);
 //将接受服务端的Messenger对象(就是客户端中的Messenger)通过Message的replyTo参数传递给服务端
 obtain.replyTo=mGetReplyToMessenger;
 //发送信息给服务端
 try {
 messenger.send(obtain);
 } catch (RemoteException e) {
 e.printStackTrace();
 }
 }
 @Override
 public void onServiceDisconnected(ComponentName name) {
 }
 };
 private Messenger mGetReplyToMessenger=new Messenger(new MessengerHandler());
 private class MessengerHandler extends Handler{
 @Override
 public void handleMessage(Message msg) {
 switch (msg.what){
 case 2:
 //获取服务端的响应
 String info = msg.getData().getString("service");
 Log.i("kkkk", "msg from Service:" + info);
 break;
 default:
 super.handleMessage(msg);
 }
 }
 }
 @Override
 protected void onDestroy() {
 unbindService(mServiceConnection);
 super.onDestroy();
 }
}



大致的步骤应该就是这样了,应该没有疏漏

结果如下所示:


下面所几个容易疏忽的错误:

绑定了没有解绑报:


还有就是你没有把message.replyTo的属性赋值为客户端的Messenger的话,回报空:




下一条:暂时没有!