Android之事件总线EventBus详解

顾名思义，AndroidEventBus是一个Android平台的事件总线框架，它简化了Activity、Fragment、Service等组件之间的交互，很大程度上降低了它们之间的耦合，使我们的代码更加简洁，耦合性更低，提升了我们的代码质量。但它能做的却不仅限于这些。经过定制，它能完成很多有意思的功能，那么究竟该怎么做呢？就让我们一起往下看吧。      

不堪回首的痛

首先，让我们先来看看这么一个场景：你是否在开发的过程中遇到过从Activity-A跳转到Activity-B，然后需要在Activity-B处理完某些工作之后回调Activity-A中的某个函数，但Activity又不能手动创建对象来设置一个Listener的情况？或者遇到在某个Service中更新Activity或Fragment中的界面等组件之间的交互问题……      

一经思考，你会发现Android中的Activity、Fragment、Service之间的交互是比较麻烦的，可能我们第一想到的是使用广播接收器来在它们之间进行交互。如上文所说，在Activity-B中发一个广播，在Activity-A中注册一个广播接收器来接收该广播。但使用广播接收器稍显麻烦，如果你要将一个实体类当作数据在组件之间传递，那么该实体类还得实现序列化接口，这个成本实在有点高！如代码1所示。

class ActivityA extends Activity {  @Override  protected void onCreate(Bundle savedInstanceState) {  super.onCreate(savedInstanceState);             // ActivityA中注册广播接收器  registerReceiver(new BroadcastReceiver() {                  @Override  public void onReceive(Context context， Intent intent) {  User person = intent.getParcelableExtra("user") ;  }  }， new IntentFilter("my_action")) ;  }  // ......   }      // ActivityB中发布广播  class ActivityB extends Activity {  @Override  protected void onCreate(Bundle savedInstanceState) {  super.onCreate(savedInstanceState);              // 发布广播  Intent intent  = new Intent("my_    action");  intent.putExtra("user"， new User("mr.simple")) ;  sendBroadcast(intent);  }  // ......   }     // 实体类需要实现序列化  class User implements Parcelable {  String name ;  public User(String aName) {  name = aName ;  }         // 代码省略  @Override  public void writeToParcel(Parcel dest， int flags) {  dest.writeString(name);  }  }
是不是有很麻烦的感觉？我们再来看一个示例，在开发过程中，我们经常要在子线程中做一些耗时操作，然后将结果更新到UI线程，除了AsyncTask之外，Thread加Handler是我们经常用的手段。如代码2所示。 

class MyActivity extends Activity {          Handler mHandler = new Handler () {  public void handleMessage(android.os.Message msg) {  if ( msg.what == 1 ) {  User user = (User)msg.obj ;  // do sth  }  };  } ;         @Override  protected void onCreate(Bundle savedInstanceState) {  super.onCreate(savedInstanceState);  // code ......             new Thread(  new Runnable() {  public void run() {  // do sth  User newUser = new User("simple") ;  Message msg = mHandler.obtainMessage() ;  msg.what = 1 ;  msg.obj = newUser ;  mHandler.sendMessage(msg) ;  }  }).start();  }  }

是不是依然相当麻烦？当然你也可以使用AsyncTask来简化操作，但AsyncTask的几个泛型参数让你的代码看起来并不那么简洁，因此GitHub上出现了TinyTask、SimpleTask这些开源库来简化AsyncTask的使用。而这些，使用AndroidEventBus都可以很好地解决！

下面就让我们来领悟一下AndroidEventBus的强大魅力吧。

初见AndroidEventBus

使用AndroidEventBus简单概括只有三个步骤：

  • 将对象注册到AndroidEventBus中；
  • 使用@Subcriber标注订阅函数（只能有一个参数）；
  • 通过post函数发布事件。

接下来就是注册订阅对象，如代码3所示。

public class MainActivity extends Activity {  @Override  protected void onCreate(Bundle savedInstanceState) {  super.onCreate(savedInstanceState);  setContentView(R.layout.activity_main);  // 将对象注册到事件总线中， ****** 注意要在onDestory中进行注销 ****  EventBus.getDefault().register(this);  }  @Override  protected void onDestroy() {  super.onDestroy();  // ****** 不要忘了进行注销 ****  EventBus.getDefault().unregister(this);  }      // 代码省略  
}

在onCreate中注册之后，MainActivity就可以添加订阅函数来接收消息了。需要注意的是在onDestory中需要将MainActivity从事件总线中注销。通过AndroidEventBus你可以去除Activity、Fragment、Service等组件的回调，减少了耦合，简化了代码。 

事件订阅函数

事件订阅需要使用@Subscriber注解进行标识，且订阅函数的参数必须为一个。事件总线凭借参数类型和@Subscriber注解的tag值来标识订阅函数的唯一性。当用户发布事件时，总线库会根据事件类型和tag来查找符合要求的订阅函数，并且将这些订阅函数执行在对应的线程中。我们先来看看代码4的订阅函数示例。

public class MainActivity extends Activity {  // 代码省略   @Subcriber(tag = "csuicide")  private void csuicideMyself(String msg) {  // do sth  finish();  }  @Subcriber(mode = ThreadMode.MAIN)  private void toastMsgFromEvent(String msg) {  // do sth  }  @Subcriber(tag = "async"， mode = ThreadMode.ASYNC)  private void executeAsync(final String msg) {  // do sth  }  // 代码省略  
}

在代码4中，我们为MainActivity添加了以下三个订阅函数： 

  • csuicideMyself：该订阅函数执行在主线程，接收事件的类型为String，tag为csuicide。当用户发布一个事件类型为String，且tag为csuicide的事件时将会触发该方法。
  • toastMsgFromEvent：该订阅函数也是执行在主线程，事件类型为String，且tag为默认。当用户发布一个事件类型为String，且tag为默认的事件时将会触发该方法。
  • executeAsync：该订阅函数也是执行在一个异步线程，事件类型为String，且tag为async。当用户发布一个事件类型为String，且tag为async的事件时将会触发该方法。

从上述的描述中我们可以知道，事件接收函数主要有两个约束：事件类型和tag（类似于Intent中的Action）。添加tag是因为在事件类型一样时，如果投递一个消息，那么单纯以事件类型（例如String）作为投递依据，那么多个参数为String的订阅函数将会被触发，这极大地降低了灵活性。

发布事件

参数1为事件类型，无tag：EventBus.getDefault().post（这是一个执行在异步线程的事件）；参数2为tag，tag的类型为String，类似Intent的Action：EventBus.getDefault().post（这是一个执行在异步线程的事件：“async”）。

发布事件时可以构造任意类型的事件，如果没有tag则该参数可以省略。发布事件后，AndroidEventBus会根据事件类型和tag到已注册的订阅对象中查找符合要求的订阅函数，例如投递的第二个事件类型为String、tag为async，那么在MainActivity中符合要求的订阅函数就是：

@Subcriber(tag = "async"， mode = ThreadMode.ASYNC)  private void executeAsync(final String msg) {  // do sth  }

AndroidEventBus的ThreadMode

在上述代码中有一段代码是这样的：

@Subcriber(mode = ThreadMode.MAIN)  private void toastMsgFromEvent(String msg) {        }

这个mode可是大有来头，它指定这个事件接收函数执行在哪个线程中。具体有如下三个选项：

  • ThreadMode.MAIN，事件接收函数执行在UI线程；
  • ThreadMode.POST，事件在哪个线程发布，接收函数就执行在哪个线程；
  • ThreadMode.ASYNC，事件执行在一个独立的异步线程中。

图1中，事件接收函数就执行在异步线程。通过这几个线程模型，我们就可以定制接收函数的执行线程。这样我们就可以使用AndroidEventBus做很多事了。比如发布一个事件，在这个事件接收函数中进行耗时操作；或下载图片、进行HTTP请求、I/O操作等，以及替换Thread、AsyncTask等组件。不过，AndroidEventBus的功能远不止于此，下面我们就看看如何进行更高端的操作。


还可以怎么玩？

退出应用的另类实现

在Android应用开发中，有些情况下我们需要可以直接退出程序。但问题是，回退栈中含有其他的Activity存在，直接使用返回键并不能退出应用。此时我们常见的做法是再自定义一个Application子类，在子类中维护一个Activity的列表，然后在进入Activity时，将Activity添加到列表中，在Activity销毁之前将自己从Application子类的列表中移除。在需要退出应用时遍历Application子类的Activity列表，然后调用每个Activity的finish函数。那我们看看AndroidEventBus怎么实现这个功能。如代码5所示。 

public class CsuicideActivity extends Activity {  @Override  protected void onCreate(Bundle savedInstanceState) {  super.onCreate(savedInstanceState);  // 将对象注册到事件总线中， ****** 注意要在onDestory中进行注销 ****  EventBus.getDefault().register(this);  }  @Override  protected void onDestroy() {  super.onDestroy();       // ****** 不要忘了进行注销 ****  EventBus.getDefault().unregister(this);  }  @Subcriber(tag = "csuicide")  private void csuicideMyself(String msg) {  finish();  }  
}

代码5中，我们定义一个CsuicideActivity在onCreate中注册该Activity对象，在onDestroy中注销，还添加了一个csuicideMyself的订阅函数。所有的Activity类可以继承自CsuicideActivity。当需要退出应用时，直接发布一个类型为String、tag为csuicide的事件即可。这样所有的Activity就会触发csuicideMyself，而该函数中又调用了finish方法，因此所有的Activity都将退出，通过这种方式就完成了应用退出。

自定义事件处理器 ( EventHandler )

AndroidEventBus在设计之初就考虑到了可扩展性，主要可扩展的地方就是订阅函数的搜索策略，具体可以调用EventBus.getDefualt().setMatchPolicy(MatchPolicy policy)来实现策略替换。另一个比较重要的扩展就是事件处理器EventHandler，用户可以通过setter函数来设置三个事件处理器。如代码6所示。

 /** * 设置执行在UI线程的事件处理器 * @param handler   UI线程事件处理器 */  public void setUIThreadEventHandler(EventHandler handler) {  mDispatcher.mUIThreadEventHandler = handler;  }  /** * 设置执行在post线程的事件处理器 * @param handler 事件在哪个线程投递，事件就执行在哪个线程的事件处理器 */  public void setPostThreadHandler(EventHandler handler) {  
mDispatcher.mPostThreadHandler = handler;  }  /** * 设置执行在异步线程的事件处理器 * @param handler 异步线程事件处理器 */  public void setAsyncEventHandler(EventHandler handler) {  mDispatcher.mAsyncEventHandler = handler;  }
EventHandler的接口定义如代码7所示，只需实现handleEvent即可，然后将该实现注入到EventBus即可。 

/** * 事件处理接口，处理事件的抽象 */  
public interface EventHandler {  /** * 处理事件 * @param subscription 订阅对象 * @param event 待处理的事件 */  void handleEvent(Subscription subscription， Object event);  
}  
默认有DefaultEventHandler、UIThreadEventHandler、AsyncEventHandler三个实现：DefaultEventHandler：事件在哪个线程发布，就将事件接收函数执行在哪个线程；
UIThreadEventHandler：将事件接收函数执行在UI线程；
AsyncEventHandler：将事件接收函数执行在异步线程。
下面我们以自定义异步事件处理器，也就是AsyncEventHandler，通过实现EventHandler接口，将事件处理函数执行在一个线程池中，从而实现图片下载的功能。如代码8所示。
public class ThreadPoolHandler implements EventHandler {  ExecutorService mExecutorService = Executors.newFixedThreadPool(3);  EventHandler mHandler = new DefaultEventHandler();  @Override  public void handleEvent(final Subscription subscription， final Object event) {  mExecutorService.submit(new Runnable() {  @Override  public void run() {  mHandler.handleEvent(subscription， event);  }  });  }  
}

然后通过如下代码将ThreadPoolEventHandler注入到：

EventBus中：

// 自定义的异步事件处理器，使用线程池  EventBus.getDefault().setAsyncEventHandler(new ThreadPoolHandler());
再在订阅对象中添加代码9所示的订阅方法 ： 

@Subcriber(tag = "download"， mode = ThreadMode.ASYNC)  
private void downloadImage(final String imageUrl) {  HttpURLConnection urlConnection = null;  try {  final URL url = new URL(imageUrl);  urlConnection = (HttpURLConnection) url.openConnection();  final Bitmap bmp = BitmapFactory.decodeStream(urlConnection.getInputStream());           // 将Bitmap投递给ImageView之类的工作  } catch (IOException e) {  } finally {  if (urlConnection != null) {  urlConnection.disconnect();  }  }  
}

最后，当需要下载图片时，通过post发布一个参数为String类型、tag为download的事件即可执行downloadImage函数，这个函数将执行在线程池中，我们的简易ImageLoader就这么实现了。图2、图3分别为图片下载中和图片下载完成的页面。

当然，由于AndroidEventBus的高度定制化，我们还可以通过AndroidEventBus来实现各种各样的功能，它到底还能怎么玩，我就不做过多的演示了，开发者可以充分发挥自己的聪明才智和想象力。















本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/294856.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

湘乡江南计算机学校,湘乡职业中等专业学校2021年招生录取分数线

湘乡江南计算机学校,湘乡职业中等专业学校2021年招生录取分数线

许多学生对自己的职业生涯并没有什么明确的规划,所以没有什么好结果,纯属正常现象。只要不断学习,才能不断收获。由此,本网老师为大家整理了湘乡职业中等专业学校2021年招生录取分数线的相关内容,后期若有变化,一切以官方发布为准。湘乡职业中等专业学校往年参考分数线年份地区…
阅读更多...
实验4

实验4

#include<stdio.h> int main(void) {double r,h,v,n;printf("Enter r,h and n ");scanf("%lf%lf%lf",&r,&h,&n);if(r<0||h<0){printf("输入错误&#xff0c;重新输入");}else{vcylinder(r,h,n);printf("v%.3f\n&qu…
阅读更多...
当女朋友问你会不会出轨的时候，该怎么回答？

当女朋友问你会不会出轨的时候，该怎么回答？

1 大象为什么会害怕体型小的动物&#xff1f;&#xff08;素材来源网络&#xff0c;侵删&#xff09;▼2 学会说话很重要&#xff08;素材来源网络&#xff0c;侵删&#xff09;▼3 原来&#xff0c;他们的老爸是一串香肠&#xff1f;&#xff08;素材来源网络&#xff0c;侵…
阅读更多...
WPF开源项目：WPF-ControlBase

WPF开源项目：WPF-ControlBase

仓库截图仓库README很素&#xff0c;但看作者README贴的几篇博文介绍&#xff0c;你会喜欢上它的&#xff0c;废话不多说&#xff0c;上介绍目录&#xff1a;动画封装https://blog.csdn.net/u010975589/article/details/95974854属性表单https://blog.csdn.net/u010975589/arti…
阅读更多...
Win10系统修改MAC地址

Win10系统修改MAC地址

本地管理地址&#xff0c;输入想修改的MAC地址后&#xff0c;点确定即完成修改。在CMD窗口中&#xff0c;使用ipconfig 命令可以查看新的MAC地址。 再次钩选不存在&#xff0c;则还原为原来的MAC地址。
阅读更多...
ftp上传图片出现550_FtpClient 实现文件上传

ftp上传图片出现550_FtpClient 实现文件上传

FtpUtils 工具类封装 public static boolean uploadFile( String hostname, int port, String username, String password, String pathname, String remote,InputStream local) { boolean flagfalse; try{ //创建 FtpClient 对象 FTPClient clientnew FTPClient…
阅读更多...
Android之安全退出应用程序的几种方式

Android之安全退出应用程序的几种方式

当我们做项目的时候，当用户在几秒的时间之内按回车键的时候，需要退出程序，但是退出我们要确保安全退出，防止还有程序还在后台运行，下面介绍几种安全的退出程的几种方式（综合了其它博客的然后加上自己使用的看到的总结） number1: 首先获取当前进程的id，然后杀死该进程。…
阅读更多...
西电计算机应用基础 一,15秋西电《计算机应用基础(一)》在线作业答案解析.doc...

西电计算机应用基础 一,15秋西电《计算机应用基础(一)》在线作业答案解析.doc...

西电《计算机应用基础(一)》在线作业一、单选题(共 25 道试题&#xff0c;共 100 分。)1. 下拉式菜单命令项右侧的三角形标记说明&#xff1a;. 该命令项当前正在起作用。. 选择该命令将弹出一个对话框。. 该命令项是级联式命令。. 该命令项无快捷键组合。正确答案&#xff1a;…
阅读更多...
SBuild 0.1.4 发布，基于 Scala 的构建系统

SBuild 0.1.4 发布，基于 Scala 的构建系统

SBuild 0.1.4 改进了 Eclipse 插件的稳定性&#xff1b;ZipSchemeHandler的 TargetFile 参数相对于项目目录&#xff1b;一些 Ant 的封装提供更多支持的参数。 SBuild 是基于 Scala 的构建系统&#xff0c;主要特点&#xff1a; 平台无关支持多项目自动检测所需的动作以及新版本…
阅读更多...
ZOJ 3228（AC自动机+修改的匹配）

ZOJ 3228（AC自动机+修改的匹配）

题目大意&#xff1a;给出一个字符串和若干个单词&#xff0c;问这些单词在字符串里面出现了多少次。单词前面为0表示这个单词可重叠出现&#xff0c;1为不可重叠出现。 分析&#xff1a;可重叠出现的单词可以直接用ac自动机就解决。至于不可重叠的单词&#xff0c;可以用一个数…
阅读更多...
一篇论文未发博士毕业，中科院最年轻院士入职浙大

一篇论文未发博士毕业，中科院最年轻院士入职浙大

全世界只有3.14 % 的人关注了爆炸吧知识本文由科研大匠&#xff08;Id:keyandajiang&#xff09;综合整理自科技日报、网络、科研大匠等11月30日&#xff0c;浙江大学官微转载《浙江日报》头版文章消息提到&#xff0c;“目前中国最年轻的中科院院士孙斌勇已入职数学高等研究院…
阅读更多...
C# WPF MVVM开发框架Caliburn.Micro常用功能指南②

C# WPF MVVM开发框架Caliburn.Micro常用功能指南②

这是Caliburn.Micro项目中最常用的约定和功能的快速指南。01—事件连接这会自动将控件上的事件关联到ViewModel上的方法。常规约定&#xff1a;<Button x:Name"Save">这将导致按钮的单击事件调用ViewModel上的“Save”方法。简短语法&#xff1a;<Button ca…
阅读更多...
4.7、Bootstrap V4自学之路------组件---广告屏

4.7、Bootstrap V4自学之路------组件---广告屏

为什么80%的码农都做不了架构师&#xff1f;>>> 示例 单独的一个空的标签 <div class"jumbotron"><!-- 背景色是灰色的--> <div> PS&#xff1a;可以看出来&#xff0c;其中上下边距还是挺高的。 <div class"jumbotron"&…
阅读更多...
计算机和hdmi无法正常显示,HDMI都不灵 为什么电脑连电视效果差?

计算机和hdmi无法正常显示,HDMI都不灵 为什么电脑连电视效果差?

1电脑连接电视用法人群庞大【中关村在线显示器频道原创】目前的桌面级显示器尺寸最大的范围就是30英寸&#xff0c;但是30英寸的显示器产品价格过于昂贵&#xff0c;因此很少有消费者能够选择购买。因此&#xff0c;目前大部分消费者都会购买27英寸的显示器&#xff0c;但是问题…
阅读更多...
easyui 修改单元格内容_初学Excel办公软件快速修改文字的方法

easyui 修改单元格内容_初学Excel办公软件快速修改文字的方法

今天我们学习Excel办公软件快速修改文字的方法&#xff0c;首先我们看这个表格里面的文字很多都是相差一个字&#xff0c;甚至很多内容相差不大&#xff0c;因此我们在输入文字时就需要改进快速方法了。首先我们根据图片来操作&#xff0c;我们修改红色字体里的数据&#xff0c…
阅读更多...
Android display架构分析

Android display架构分析

这篇文章非常好&#xff0c;必须转载。目录(?)[-] Kernel Space Display架构介绍函数和数据结构介绍函数和数据结构介绍函数和数据结构介绍数据流分析初始化过程分析User Space display接口Kernel display接口典型应用flow分析介绍 Surface manager&#xff08;surface flinge…
阅读更多...
栈和队列之用一个栈实现另一个栈的排序

栈和队列之用一个栈实现另一个栈的排序

用一个栈实现另一个栈的排序 题目： 一个栈元素的类型为整数，现在要想将该栈从顶到底按从大到小的顺序排列，只允许申请一个栈，除此之外， 可以申请一个变量，可以申请额外的变量，但是不能申请额外的数据结构，如何完成排序 思路： 我们需要排序的栈为stack,然后我们申请…
阅读更多...
从状态转移看：载波侦听多路访问/冲突避免（CSMA/CA）

从状态转移看：载波侦听多路访问/冲突避免（CSMA/CA）

CSMA/CA是写入IEEE802.11的无线网络MAC层标准协议&#xff0c;相信看到这篇文章的读者都知道它是用来做什么的。但许多短文对这个协议的解释都有所缺乏&#xff0c;因此本文用状态转换图的形式详细说明协议的工作流程。&#xff08;好吧其实是作者看到一个状态图有感而发&#…
阅读更多...
年度迷惑新闻：美女其实是个男生？

年度迷惑新闻：美女其实是个男生？

1 南方人为什么不喜欢冬天&#xff08;素材来源网络&#xff0c;侵删&#xff09;▼2 老板果然是有两把刷子&#xff08;素材来源网络&#xff0c;侵删&#xff09;▼3 干大事者必是单身狗&#xff1f;&#xff08;素材来源网络&#xff0c;侵删&#xff09;▼4 把狗子的铁饭…
阅读更多...
The import com.sun.tools cannot be resolved

The import com.sun.tools cannot be resolved

2019独角兽企业重金招聘Python工程师标准>>> 这是因为在myeclipse中&#xff0c;有自带的jar包&#xff1b;儿导入eclipse中&#xff0c;用的是自己安装的jre&#xff0c;tool.jar包是在JDK中&#xff0c;不是在jre中,所以window-》preferrence-》java-》installed …
阅读更多...
最新文章

Copyright @ 2022~2023