Android IPC机制绑定Service实现本地通信
作者:lqh 发布时间:2023-10-08 15:25:40
**写作原因:跨进程通信的实现和理解是Android进阶中重要的一环。下面博主分享IPC一些相关知识、操作及自己在学习IPC过程中的一些理解。
这一章是为下面的Messenger和AIDL的使用做准备,主要讲解Android Service的绑定和Activity与本地Service之间通信相关知识。**
简介
我们都知道启动Service有两种方式:startService()和bindService()。相比第一种方式,bindService()能够更加灵活地实现与启动端Activity的数据通信,第一种启动方式启动Activity与Service之间并没有直接关联,难以直接实现通信(当然了,使用BroadCast或者事件总线也是可以实现的)。而使用绑定的方式启动Service则可以实现Service之间的通信。
下面就讲述一下绑定Service实现本地通信的流程。
实例
结合图片我们来模拟开启一个后台执行更新功能为例来讲解本地Service的绑定。
先分析一下该需求的场景:首先我们需要点击Start按钮开启后台更新数据,后台将数据返回给Activity并在ProgressBar展示进度;当我们点击Pause时后台暂停更新;点击Stop按钮时关闭后台。本例中也用到Service通过BroadCast向Activity传递数据。由于只是实例,对于线程操作一块有一些bug,希望大家能够帮忙指正。
Activity的布局如下:
Service 实现:
先看看Service的实现:
思路是这样的:先继承Binder类创建MyBinder类,把MyBinder看做Service与Activity通信的代理人,所以在MyBinder内部中写好方法间接调用Service中的方法以供Activity去调用(如本例中callPauseUpgrade())。关于IBinder对象的获取除了直接重写后面还有两种方式,这里先不阐述了。在Service中我们开启一个Thread,在这个Thread中模拟持续更新进度条直到isStop为False或者progress大于等于100时,然后将进度广播出去,让Activity接收到广播进行进度条更新。Service中供Activity调用的方法实现暂停和停止Thread的功能,具体过程参照代码。
public class UpgradeService extends Service {
private Thread thread;
private Intent intent;
private int progress;
private Boolean isStop;
public class MyBinder extends Binder{
public void callPauseUpgrade(){
pauseUpgrade();
}
public void callStopUpgrade() {
stopUpgrade();
}
}
private void stopUpgrade() {
progress = 0;
isStop = false;
intent.putExtra("progress",progress);
sendBroadcast(intent);
}
@Override
public void onCreate() {
super.onCreate();
progress = 0;
isStop = true;
intent = new Intent();
thread = new Thread(new Runnable() {
@Override
public void run() {
while(isStop){
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
progress = progress +5;
intent.putExtra("progress",progress);
intent.setAction("UPGRADE_ACTION");
sendBroadcast(intent);
if(progress>=100) break;
}
}
});
thread.start();
}
private void pauseUpgrade() {
//TODO:Pause the upgrade
Toast.makeText(getApplicationContext(),"暂停",Toast.LENGTH_SHORT).show();
isStop = false;
}
@Override
public IBinder onBind(Intent intent) {
return new MyBinder();
}
}
Activity实现
下面是在客户端实现与Service的通信代码。主要思路是:先注册广播实现Service数据的返回;单击Start按钮时实现与Service的绑定,创建ServiceConnection对象实现ServiceConnection接口,分别回调绑定成功和失败两种情况下的逻辑。当成功时获取MyBinder对象,并将设置的isBound值设为true;当失败时将isBound设置为false。单击Pause调用MyBinder对象的callPauseUpgrade()方法间接调用Service中的pauseUpgrade()方法。单击Stop调用callStopUpgrade()方法并且解除绑定。注意解除绑定事件只能执行一次,否则程序会崩溃。
具体实现并不难,主要是认真理解上面的流程图即可。
public class MainActivity extends AppCompatActivity implements View.OnClickListener{
private Button mBtStart;
private Button mBtStop;
private Button mBtPause;
private ProgressBar mPbProgress;
private UpgradeService.MyBinder myBinder;
private boolean isBound;
private UpgradeReceiver upgradeReceiver;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
IntentFilter intentFilter = new IntentFilter();
intentFilter.addAction("UPGRADE_ACTION");
upgradeReceiver = new UpgradeReceiver();
registerReceiver(upgradeReceiver,intentFilter);
initView();
initEvent();
}
public class UpgradeReceiver extends BroadcastReceiver{
@Override
public void onReceive(Context context, Intent intent) {
mPbProgress.setProgress(intent.getIntExtra("progress",0));
}
}
@Override
protected void onDestroy() {
super.onDestroy();
unregisterReceiver(upgradeReceiver);
}
private void initEvent() {
mBtPause.setOnClickListener(this);
mBtStart.setOnClickListener(this);
mBtStop.setOnClickListener(this);
}
private void initView() {
mBtPause = (Button) findViewById(R.id.bt_pause);
mBtStart = (Button) findViewById(R.id.bt_start);
mBtStop = (Button) findViewById(R.id.bt_stop);
mPbProgress = (ProgressBar) findViewById(R.id.pb_progress);
}
@Override
public void onClick(View v) {
switch(v.getId()){
case R.id.bt_pause:
if(isBound&&myBinder!=null){
myBinder.callPauseUpgrade();
}
break;
case R.id.bt_start:
bindService(new Intent(MainActivity.this,UpgradeService.class),conn,BIND_AUTO_CREATE);
break;
case R.id.bt_stop:
if(isBound) {
myBinder.callStopUpgrade();
unbindService(conn);
isBound = false;
}
break;
}
}
private ServiceConnection conn = new ServiceConnection() {
@Override
public void onServiceConnected(ComponentName name, IBinder service) {
if(service != null){
myBinder = (UpgradeService.MyBinder) service;
isBound = true;
}
}
@Override
public void onServiceDisconnected(ComponentName name) {
isBound = false;
}
};
}
总结:
这篇文章是为下面的Messenger和AIDL跨进程通信做准备的,实际上个人感觉真正开发时可以使用EventBus或者RxJava取代这种同进程各个组件通信的问题,有兴趣的读者可以自行尝试。
猜你喜欢
- 本文介绍了Android ItemDecoration 实现分组索引列表的示例代码,分享给大家。具体如下:先来看看效果:我们要实现的效果主要
- springboot 高版本后不支持log4j了,很多人还是喜欢log4j风格的日志,我们自己来加载log4j,其实
- 基于 springboot+vue 的测试平台(练手项目)开发继续更新。接下来准备开发请求断言功能。关于这个功能要实现哪些需求,长什么样子,
- 设置流程百度查阅了几个资料感觉没啥用,经过自己一番试验,总结了简单的方法,具体做法是1.从工具栏拖出一个按钮2.在vs外部使用编辑进入到画图
- 本文实例为大家分享了C语言实现顺序表的顺序查找和折半查找的具体代码,供大家参考,具体内容如下顺序查找:#include <iostre
- springMVC项目中实现图形验证码功能,可以使用kaptcha来实现,下面是步骤一、引入架包,pom.xml<dependency
- 需求前台有日期字符串的数据,提交到后台。后台实体类使用Date属性接收。日期字符串有多种格式,需要用一个转换器将合法的日期字符串格式转换为D
- Hutool Java工具类库_ExcelUtil依赖<!--Hutool Java工具包--> &l
- 双向循环链表定义相比于单链表,有两个指针,next指针指向下一个结点,prior指针指向上一个结点,最后一个结点的next指针指向头结点,头
- println()直接打印我们都知道println()如果打印的是基本数据类型的话直接打印出来的就是值,你如果是引用数据类型呢?🍑除掉这四类
- BitmapFactory.Options的使用是在加载图片时,就从图片的加载和使用说起 怎样获取图片的大小?首先我们把这个图片转
- kafka 架构原理大数据时代来临,如果你还不知道Kafka那就真的out了!据统计,有三分之一的世界财富500强企业正在使用K
- 微信支付最近公司要在微信公众号上做一个活动预报名,活动的门票等需要在微信中支付。微信支付前的准备微信支付需要一个微信支付商务号(https:
- Groovy 简介Groovy 是构建在 JVM 上的一个轻量级却强大的动态语言,它结合了 Python、Ruby 和 Smalltalk
- 对Jpa Entity关系映射中mappedBy的理解mappedBy 单向关系不需要设置该属性,双向关系必须设置,避免双方都建立外键字段数
- 前言序列化想必大家都很熟悉了,对象在进行网络传输过程中,需要序列化之后才能传输到客户端,或者客户端的数据序列化之后送达到服务端序列化的标准解
- 问题(1)重入锁是什么?(2)ReentrantLock如何实现重入锁?(3)ReentrantLock为什么默认是非公平模式?(4)Ree
- 需求winForm 程序输出类型为 windows 程序(不是命令行程序)在运行时想输入一些信息编译开发调试,如何实现这一功能解答:Allo
- 本文设计一个简单的班级管理系统,满足如下要求:1、设计学生类Student,包含学号(String型)、姓名(String型)、
- 背景最近公司的客户要求,分配给员工的任务除了有微信通知外,还希望PC端的网页也能实时收到通知。管理员分配任务是在我们的系统A,而员工接受任务