入门
简介
GitHub:EventBus
Android optimized event bus that simplifies communication between Activities, Fragments, Threads, Services, etc. Less code, better quality.
android最佳的事件总线,简化了Activities、Fragments、Threads、Services等之间的通信,代码更少,质量更好。
EventBus是greenrobot团队Markus Junginger开源的发布-订阅事件总线库。主要用于:适合当做组件间的通讯工具使用,主要用来传递消息。请求网络,等网络返回时通过Handler或Broadcast通知UI,两个Fragment之间需要通过Listener通信,这些需求都可以通过EventBus实现。。。。
优点有
简洁性。简化了应用程序内各组件间、组件与后台线程间的通信。
开销小。代码更优雅。
低耦合。将发送者和接受者解耦。
缺点是
事件一般都要写个对应的 Event 类出来,导致会都很多这些类;
可读性降低。两个模块间交互,不如原来定位快。
EventBus3.0较之前版本:用注解的方式代替约定的方法名规范。
其他框架对比
RxBus:使用RxJava实现的库。缺点有:如何实现sticky功能;如何处理RxJava的订阅操作中的异常导致的订阅的中断(因为RxJava中出现异常会直接跳转OnError,事件流就被中断了);使用运行时(Run-time)注解的话,反射的性能问题。
Guava:Google的Guava是一个庞大的库,EventBus只是它附带的一个小功能,因此实际项目中使用并不多。
Otto:square的otto修改自 Guava。但已停止维护,临死前推荐大家使用RxBus。
基础用法
使用
基本使用大致分为5个步骤:
1,创建事件类;(用一个POJO封装传递数据。如果是简单的基本数据类型,不封装也行。)
2,在订阅事件处注册事件;(在发送端)
EventBus.getDefault().register(this);
3,发送事件;(此为发布者,在发送端)
EventBus.getDefault().post(new EventPOJO("Hello EventBus!"));
4,接收,处理事件;(此为订阅者,在接收端)
//接收方法可以随便起名,但需要添加Subscribe注解。
@Subscribe(threadMode= ThreadMode.MAIN)
public voidonEvent(EventPOJO messageEvent) {
tv_message.setText(messageEvent.getMessage());
}
5,注销总线。
EventBus.getDefault().unregister(this);
@Subscribe
ThreadMode提供了四种类型。MainThread 主线程,BackgroundThread 后台线程,Async 后台线程,PostThread 发送线程(默认)。
- POSTING(默认):如果使用事件处理函数指定了线程模型为POSTING,那么该事件在哪个线程发布出来的,事件处理函数就会在这个线程中运行,也就是说发布事件和接收事件在同一个线程。在线程模型为POSTING的事件处理函数中尽量避免执行耗时操作,因为它会阻塞事件的传递,甚至有可能会引起ANR。
- MAIN:事件的处理会在UI线程中执行。事件处理时间不能太长,长了会ANR的。
- BACKGROUND:如果事件是在UI线程中发布出来的,那么该事件处理函数就会在新的线程中运行,如果事件本来就是子线程中发布出来的,那么该事件处理函数直接在发布事件的线程中执行。在此事件处理函数中禁止进行UI更新操作。
- ASYNC:无论事件在哪个线程发布,该事件处理函数都会在新建的子线程中执行,同样,此事件处理函数中禁止进行UI更新操作。
sticky机制
sticky机制俗称粘性事件。即发送事件之后再订阅该事件也能收到该事件。sticky默认值为false,在Subscribe方法中可以更改。
@Subscribe(threadMode = ThreadMode.POSTING,priority = 1, sticky = true)
priority 值表示优先级。值越小优先级越低,默认为0。
1,订阅粘性事件;
bt_subscription.setOnClickListener(newView.OnClickListener() {
@OverridepublicvoidonClick(View v) {//注册事件
EventBus.getDefault().register(MainActivity.this);
}
});
2,处理粘性事件;
@Subscribe(threadMode = ThreadMode.POSTING,priority=0, sticky =true)
publicvoidononMoonStickyEvent(MessageEvent messageEvent){
tv_message.setText(messageEvent.getMessage());
}
3,发送粘性事件。
bt_subscription.setOnClickListener(newView.OnClickListener() {
@OverridepublicvoidonClick(View v) {
EventBus.getDefault().postSticky(newMessageEvent("粘性事件"));
finish();
}
});
进阶用法
添加processor
由于使用了注解,性能会降低。使用processor在编译的时候为注册类构建了一个索引,而不是在运行时,这样的结果是其让EventBus 3.0的性能提升了一倍,相比2.4来说,其会是它的3到6倍。
使用processor有两种方案。<一>添加依赖:provided'de.greenrobot:eventbus-annotation-processor:3.0.0-beta1';
<二>添加依赖:apt 'org.greenrobot:eventbus-annotation-processor:3.0.1'。在Application中添加EventBus.builder().addIndex(newMyEventBusIndex()).installDefaultEventBus();。
源码解析
EventBus是用了反射,并且维护了一个全局map,记录event到method的映射。
通过注解把类中的所有订阅者和订阅信息提取出来,这里有很多过滤条件保证提取的正确性。
EventBus中有两个映射表,subscriptionsByEventType中存放所有event和对应的订阅者,typesBySubscriber中存放每个订阅者对应的事件。提取出来的订阅者和信息就被存进了这两个表里。
private final Map<Class<?>, CopyOnWriteArrayList<Subscription>>
subscriptionsByEventType;
private final Map<Object, List<Class<?>>> typesBySubscriber;
所有的的poster被放在3个队列中,mainThreadPoster、backgroundPoster、asyncPoster。这3个队列是用链表实现的,让poster在各自的线程排队,等候处理。如果是POSTING类型的事件,就直接执行了,不用排队。
错误汇总
post了消息之后,你的订阅者有多个,每一个都接收吗?能否做到指定接收者。
使用经验
EventBus最好都定义在一个包下,分散开后期不好维护。
参考文章
Android事件总线(一)EventBus3.0用法全解析 刘望舒
EventBus使用详解(一)——初步使用EventBus 讲的2.X,算的上比较早的blog了。贴上纪念下。