美文网首页
EventBus 3.0

EventBus 3.0

作者: javaBoy_hw | 来源:发表于2018-07-05 15:12 被阅读0次

入门

简介

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

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 发送线程(默认)。

  1. POSTING(默认):如果使用事件处理函数指定了线程模型为POSTING,那么该事件在哪个线程发布出来的,事件处理函数就会在这个线程中运行,也就是说发布事件和接收事件在同一个线程。在线程模型为POSTING的事件处理函数中尽量避免执行耗时操作,因为它会阻塞事件的传递,甚至有可能会引起ANR。
  2. MAIN:事件的处理会在UI线程中执行。事件处理时间不能太长,长了会ANR的。
  3. BACKGROUND:如果事件是在UI线程中发布出来的,那么该事件处理函数就会在新的线程中运行,如果事件本来就是子线程中发布出来的,那么该事件处理函数直接在发布事件的线程中执行。在此事件处理函数中禁止进行UI更新操作。
  4. 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倍。

EventBus性能对比

使用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 3.0的用法详解(一)

EventBus3.0源码解析

老司机教你“飙”EventBus3

快速Android开发系列通信篇之EventBus

EventBus使用详解(一)——初步使用EventBus 讲的2.X,算的上比较早的blog了。贴上纪念下。

相关文章

网友评论

      本文标题:EventBus 3.0

      本文链接:https://www.haomeiwen.com/subject/nvspuftx.html