Eventbus 源码解析

1.eventbus 是基于观察者模式的,在eventbus中 观察者是subscriber,被观察者是publisher,给个图理解下:


eventbus 框架

eventbus 在android 中可以做什么呢 ,基本就是代替Handler和broadcast的功能,再给一张图理解下:


what eventbus can do

2. 再看下eventbus源码的目录吧 稍微了解下具体包含哪些类


eventbus 源码目录

下面通过分析目录和eventbus项目流程逻辑相结合的方式,解析eventbus项目源码

其中eventbus项目中的eventbus这个类是承担的是中介者模式中中介的角色,它联系订阅者和事件产生者。

EventbusBuilder这个类不难理解,是eventbus这个类可以通过构建者模式来配置产生,项目中也提供了eventbus的单例获取函数,单例保证在各个线程中都是相同的eventbus类实例。


获取eventbus 实例

接下来有必要梳理一下eventbus类里面几个重要的数据类型的含义:


成员变量

subscriptionsByEventType:以event为key,以订阅列表(Subscription)为value,事件发送之后,在这里寻找订阅者,而Subscription又是一个CopyOnWriteArrayList,这是一个线程安全的容器。Subscription是一个封装类,封装了订阅者、订阅方法这两个类。

typesBySubscriber:以订阅者类为key,以event事件类为value,在进行register或unregister操作的时候,会操作这个map。


Subscription

订阅者类型是 Object,event类型也是Object,SubscriberMethod是当事件发出者发出事件,订阅者要执行的方法,执行是通过反射调用方法。看下SubscriberMethod的成员


SubscriberMethod

稍微理解下各个类之间的引用关系。

接下来按照eventbus在使用时的流程来梳理一下 代码执行逻辑:

流程1:register (注册)

思路是这样的,一个类(比如Activity)要想成为订阅者,必须注册,注册其实就是让这个订阅者订阅一个方法,什么方法呢?就是当事件发出者发出事件后,这个方法会被订阅者执行。因为我们在代码逻辑中不知道订阅者类的具体类型,注册第一步应该获取订阅者的类型。

Class subscriberClass = subscriber.getClass();

注册

subscriberMethodFinder这个类的findSubscriberMethods方法通过传入订阅者的类型查找该订阅者订阅的方法(subscriberMethodFinder的具体实现先略过),当遍历订阅的方法时,我们看看方法  subscribe(subscriber, subscriberMethod, sticky, priority);做了什么?


method subscribe

在该方法内,主要是实现订阅方法与事件直接的关联,即注册,即放进我们上面提到关键的几个Map中:subscriptionsByEventType、typesBySubscriber。这样注册过程就基本结束了,这段分析省略了一些具体的细节代码逻辑,只是把注册过程大体梳理了一遍。这样可以快速理解整个框架,而不拘泥于具体细节中。

流程2:unregister (注销)

稍微思考一下也就知道注销要做哪几件事。让订阅者不再成为订阅者,


注销

注销方法传入的是订阅者,通过传入的订阅者类型,查看这个订阅者订阅了哪些事件,然后在相应的数据结构中移除事件和订阅者。

说了这么多 该聊聊如何事件产生者如何发送一个事件了,

流程3:事件的发送

事件的发送还是要通过eventbus类的post方法来完成,如下

Eventbus.getDefalutInstance().post(new aEvent(paramters));

post方法传入的参数是一个event类型的对象,parameters是这个event类型对象构造函数的参数,post的具体功能还是看下post的源码吧。


method post

看下PostingThreadState 的成员


PostingThreadState


currentPostingThreadState

可见首先获得创建eventbus类的线程的线程信息,线程信息中维护了一个PostingThreadState类,该类中又维护了一个event事件的队列,所有先把post()方法中传进来的事件添加到队列中。接着判断一下当前线程是不是主线程,把判断的结果存入PostingThreadState。只要event队列不为空,不断取出事件分发,分发交给postSingleEvent()方法。

分发单个事件

因为事件的超类也要考虑,所有遍历事件和事件的所有超类,然后分别找到这些事件类的订阅者,再执行 postToSubscription()方法,这个方法确确实实把事件发送到订阅者手中了。看源码

method

取出订阅方法注解中设置的该方法要在什么线程中运行,来分别对待。如果是PostThread,那么直接调用invokeSubscriber()方法,如果该方法指定在MainThread中运行,提交事件的线程是主线程的话则通过反射,直接运行订阅的方法,如果不是主线程,我们需要mainThreadPoster将我们的订阅事件入队列,mainThreadPoster是HandlerPoster类型的继承自Handler,通过Handler将订阅方法切换到主线程执行。

其中mainThreadPoster是一个HandlerPoster类,它的enqueue方法如下:


enqueue

if(!sendMessage(obtainMessage()))是两个语句,先执行sendMessage,在判断,这样就跳转到handleMessage()方法中,执行订阅的方法。


handleMessage

本文只是大致把Eventbus的流程思想过了一遍,做个记录,完。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 博文出处:EventBus源码解析,欢迎大家关注我的博客,谢谢! 0001B 时近年末,但是也没闲着。最近正好在看...
    俞其荣阅读 1,322评论 1 16
  • 文章基于EventBus 3.0讲解。首先对于EventBus的使用上,大多数人还是比较熟悉的。如果你还每次烦于使...
    Hohohong阅读 2,335评论 0 6
  • 简单的使用 EventBus是greenrobot在Android平台发布的一款以订阅——发布模式为核心的开源库。...
    最最最最醉人阅读 778评论 0 13
  • 在《Android EventBus使用》博文中,我们已经对EventBus的使用进行了分析,在这篇博文中,我们就...
    24K男阅读 476评论 0 5
  • 前面一篇文章讲解了EventBus的使用,但是作为开发人员,不能只停留在仅仅会用的层面上,我们还需要弄清楚它的内部...
    Lauren_Liuling阅读 5,958评论 7 28