Android 基于Aidl的跨进程间双向通信管理中心(类似于聊天室)
得益于最近有点时间和精力,我想起来了一件事。那就是在上家公司,公司要求做一个APP进程间的通信的功能,并不是APP对APP的直接跨进程通信,而是通过一个服务中心,做接收,然后,再转发,避免应用之间耦合性高,不然的话,新增一个APP,其他APP也要进行升级更新(类似于有服务中心的聊天室)。
我就花几个小时写点东西吧,顺便记录一下
大家都知道在Android设备上,有很多方式,比如,广播,socket,共享内存,aidl等,其中广播和aidl都是基于android中iBinder机制
广播:
广播有缺陷,就是效率不高,有时候会遇到广播丢失,或者说广播的队列过长,导致消息发送慢;
共享内存:
共享内存没有安全性可言,而且多线程读写数据的话,会无法控制
socket:
socket耦合度较高,内存需要拷贝两次,适用于跨网络
AIDL:
基于binder,效率高;基于C/S架构,分层清晰,功能明确;有Linux的进程ID概念,更加安全等优点
流程图
很简单的架构,所有的APP消息传递都通过Server来做,工程结构如下,center(消息中心),app1,app2都依赖于lib(aidl接口库)
利用aidl中的RemoteCallbackList类(原理和源码我就不多说了,其实Client调用Server是大同小异的,只不过是反者来了一次),来实现client中的接口回调,这样才能从server主动给client发消息,一般我们都是client主动调用Server,现在轮到Server主动调用client
服务端的代码如下,你可以按照你项目的要求来做
package com.helang.messagecenterdemo; import android.app.Service; import android.content.Intent; import android.os.IBinder; import android.os.RemoteCallbackList; import android.os.RemoteException; import android.support.annotation.Nullable; import android.util.Log; import com.helang.lib.IMyAidlCallBackInterface; import com.helang.lib.IMyAidlInterface; /** * 消息服务中心(记得在 manifest.xml 加上 android:exported="true") */ public class MyService extends Service { private final static String TAG = MyService.class.getSimpleName(); private RemoteCallbackList<IMyAidlCallBackInterface> callbackList = new RemoteCallbackList<>();//回调的关键(API>=17,才能使用) @Override public void onCreate() { super.onCreate(); } @Nullable @Override public IBinder onBind(Intent intent) { return iBinder; } /** * 实现iBinder */ private IMyAidlInterface.Stub iBinder = new IMyAidlInterface.Stub() { @Override public void sendMessage(String tag, String message) throws RemoteException { callbackList.beginBroadcast(); sendMessageToAllClient(tag,message); Log.d(TAG,"tag="+tag+" message="+message); callbackList.finishBroadcast(); } @Override public void registerListener(IMyAidlCallBackInterface listener) throws RemoteException { callbackList.register(listener);//注册回调listener Log.d(TAG,"registerListener"); } @Override public void unregisterListener(IMyAidlCallBackInterface listener) throws RemoteException { callbackList.unregister(listener);//取消回调listener Log.d(TAG,"unregisterListener"); } }; /** * 发送消息给全部的client(你也可以指定发送给某个client,也可 * 以根据自己的业务来封装一下Bean,记得要实现Parcelable接口来序列化 * @param tag * @param message */ private void sendMessageToAllClient(String tag,String message){ for (int i = 0 ; i < callbackList.getRegisteredCallbackCount();i++){ try { callbackList.getBroadcastItem(i).callback(tag,message); } catch (RemoteException e) { e.printStackTrace(); } } } }
Client1和Client2代码是一样的,就是相互发消息:
package com.helang.app2; import android.content.ComponentName; import android.content.Intent; import android.content.ServiceConnection; import android.os.Handler; import android.os.IBinder; import android.os.RemoteException; import android.support.v7.app.AppCompatActivity; import android.os.Bundle; import android.view.View; import android.widget.Button; import android.widget.EditText; import android.widget.TextView; import com.helang.lib.IMyAidlCallBackInterface; import com.helang.lib.IMyAidlInterface; public class MainActivity extends AppCompatActivity { private EditText editText; private Button bt_send; private TextView text; private IMyAidlInterface iMyAidlInterface; private ServiceCallBack serviceCallBack; private MyServiceConnection myServiceConnection; private Handler handler = new Handler(); @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); bt_send = findViewById(R.id.bt_send); editText = findViewById(R.id.editText); text = findViewById(R.id.text); bt_send.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View view) { if (iMyAidlInterface != null){ try { iMyAidlInterface.sendMessage("app2",editText.getText().toString().trim()); } catch (RemoteException e) { e.printStackTrace(); } } } }); bindService(); } @Override protected void onDestroy() { super.onDestroy(); unbindService(); } private void bindService(){ myServiceConnection = new MyServiceConnection(); serviceCallBack = new ServiceCallBack(); Intent intent = new Intent(); intent.setComponent(new ComponentName("com.helang.messagecenterdemo", "com.helang.messagecenterdemo.MyService")); startService(intent);//开启远程服务 bindService(intent,myServiceConnection,BIND_AUTO_CREATE);//绑定服务 } private void unbindService(){ if (myServiceConnection != null){ try { iMyAidlInterface.unregisterListener(serviceCallBack); } catch (RemoteException e) { e.printStackTrace(); } unbindService(myServiceConnection); } } /** * 连接Service */ class MyServiceConnection implements ServiceConnection { @Override public void onServiceConnected(ComponentName componentName, IBinder iBinder) { iMyAidlInterface = IMyAidlInterface.Stub.asInterface(iBinder); handler.post(new Runnable() { @Override public void run() { //注册回调 if (iMyAidlInterface != null){ try { iMyAidlInterface.registerListener(serviceCallBack); } catch (RemoteException e) { e.printStackTrace(); } } } }); } @Override public void onServiceDisconnected(ComponentName componentName) { } } /** * service回到client的类 */ class ServiceCallBack extends IMyAidlCallBackInterface.Stub{ @Override public void callback(final String tag, final String message) throws RemoteException { runOnUiThread(new Runnable() { @Override public void run() { text.append("tag="+tag+" message="+message); } }); } } }
看看效果吧,Client2(app2)发消息给Client1(app1)
顺便说一句,提前打开Center服务,因为android 8.0之后的版本直接远程开启其他App后台进程服务,是行不通了,可以绑定一个前台进程,网上方法有很多,我这里就简单处理了
源码我都放在github:https://github.com/helang1991/MessageCenter
喜欢的就给个star吧
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
code push 相关命令
code-push login 登陆 code-push logout 注销 code-push access-key ls 列出登陆的token code-push access-key rm <accessKye> 删除某个 access-key 输入code-push app add <appName>即可完成注册。 code-push app add 在账号里面添加一个新的app code-push app remove 或者 rm 在账号里移除一个app code-push app rename 重命名一个存在app code-push app list 或则 ls 列出账号下面的所有app code-push app transfer 把app的所有权转移到另外一个账号 code-push deployment -k ls <appName>获取 部署秘钥 code-push deployment ls ckhsAndroid -k code-push release-react <appName> <platform&...
- 下一篇
Android--录音
版权声明:本文为博主原创文章,转载请标明出处。 https://blog.csdn.net/chaoyu168/article/details/81327067 录音分为环境录音和通话录音。 环境录音: public class audio { private static MediaRecorder mMediaRecorder; private static String fileName= ""; @SuppressLint("LongLogTag") public static void startRecord() { // 开始录音 /* ①Initial:实例化MediaRecorder对象 */ if (mMediaRecorder == null) mMediaRecorder = new MediaRecorder(); try { /* ②setAudioSource/setVedioSource */ mMediaRecorder.setAudioSource(MediaRecorder.AudioSource.MIC);// 设置麦克风 /* * ②设置输出文件...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
-
Docker使用Oracle官方镜像安装(12C,18C,19C)
- Springboot2将连接池hikari替换为druid,体验最强大的数据库连接池
- CentOS8编译安装MySQL8.0.19
- Docker快速安装Oracle11G,搭建oracle11g学习环境
- SpringBoot2配置默认Tomcat设置,开启更多高级功能
- MySQL8.0.19开启GTID主从同步CentOS8
- CentOS7,8上快速安装Gitea,搭建Git服务器
- Jdk安装(Linux,MacOS,Windows),包含三大操作系统的最全安装
- SpringBoot2编写第一个Controller,响应你的http请求并返回结果
推荐阅读
最新文章
- SpringBoot2编写第一个Controller,响应你的http请求并返回结果
- Docker使用Oracle官方镜像安装(12C,18C,19C)
- CentOS8编译安装MySQL8.0.19
- Springboot2将连接池hikari替换为druid,体验最强大的数据库连接池
- SpringBoot2整合Redis,开启缓存,提高访问速度
- CentOS关闭SELinux安全模块
- Hadoop3单机部署,实现最简伪集群
- CentOS6,7,8上安装Nginx,支持https2.0的开启
- SpringBoot2全家桶,快速入门学习开发网站教程
- SpringBoot2更换Tomcat为Jetty,小型站点的福音