EventBus源码解析

  • 时间:
  • 浏览:0
  • 来源:大发五分时时彩—大发分分时时彩

通过findUsingInfo来获取订阅者及其父类的所有订阅方法:

PostingThreadState定义了当前正在发布的事件清况 。

2、typesBySubscriber

postSingleEvent调用了lookupAllEventTypes()获取要发布的事件及其父类的Class对象,也假使 说由于发布MyEvent事件,订阅了MyEvent事件由于其父相似于件的订阅者都能收到MyEvent事件(后要 原来理解,订阅了MyEvent的父相似于件,MyEvent是其父类的一种类型,也应该发布)。postSingleEventForEventType完成单个事件的发布:

1、subscriber.getClass获取订阅者的Class对象

post

5、backgroundPoster(threadMode=BACKGROUND)

至此,EventBus的注册、订阅消息、发布消息、注销的流程都由于分析完毕。

1、获取当前的发布清况 PostingThreadState

1、subscriptionsByEventType

4、重置PostingThreadState清况

通过Looper对象判断当前不是主守护进程,创建HandlerPoster赋值给mainThreadPoster,HandlerPoster继承自Handler,handleMessage完成事件的采集,保证订阅方法运行在主守护进程。

在循环结束后,findState.subscriberMethods保存了订阅者及其父类的所有SubscriberMethod。

3、循环调用postSingleEvent发布事件

threadMode:指定订阅方法运行的守护进程,根据其值在对应的守护进程调用订阅Method。

mainThreadSupport的实现

EventBus.getDefault()以单例的方法获取EventBus实例,这里重点介绍下EventBus的成员变量:

findSubscriberMethods

发布事件有以下过程:

unsubscribeByEventType

4、发布事件:EventBus.getDefault().post(MyEvent)后要 发布有有一三个白事件,EventBus会根据发布的消息的类型,找到该类型消息的订阅者,完成消息的传递。

3、stickyEvents

使用EventBus主要分为以下四步:

4、mainThreadSupport&mainThreadPoster(threadMode=MAIN 由于MAIN_ORDERED)

6、asyncPoster(threadMode=ASYNC)

sticky:指定不是粘性事件,由于为true,在调用register的随后,会接受到注册监听随后EventBus postSticky发送过的同一类型的消息。

3、订阅事件:通过@Subscribe注解对方法进行注解,注解的方法时需有且仅有有一三个白参数,这里大伙定义了MyEvent作为订阅的事件。

postToSubscription

findUsingInfo首先初始化了FindState,FindState是个哪几个东东?

第2步获取到所有订阅方法后,就循环调用subscribe(subscriber, subscriberMethod)。

subscribe

是有有一三个白Map对象,Key为EventBus.getDefault().register(this)的this对象,Value为this对象中所有的@Subcribe注解方法的参数类型,也假使 订阅的事件类型。

2、subscriberMethodFinder.findSubscriberMethods(subscriberClass)获取订阅者及其父类的所有@Subscribe注解的Method。

BackgroundPoster

至此,register方法运行结束,subscriptionsByEventType中保存了某个类型消息对应的Subscription列表,Subscription中中有 了订阅者和订阅方法;typesBySubscriber保存了某个订阅者的所有订阅事件类型;最后也完成了sticky事件的发布。

EventBus是有有一三个白开源的事件总线项目,项目地址:EventBus

EventBus通过注册监听器和发布消息的方法来完成事件的传递,如下所示:

首先在subscriptionsByEventType获取eventClass对应的订阅列表,而且调用postToSubscription进行发布。

register主要分为以下三步:

EventBus构造

其中Publisher为事件的发布者,Subscriber为事件的订阅者。下图为EventBus的DEMO使用方法:

2、注销:通过EventBus.getDefault().unregister(this)进行注销;

@Subscribe注解的定义如上图所示,通过@Rentention将注解定义为TUNTIME,表示该注解由于保留到JVM运行时,也假使 后要 通过反射进行调用;通过@Target将注解定义为METHOD,表示该注解只能应用于method;在使用@Subscribe注解时,后要 设置threadMode、sticky、priority属性。

AsyncPoster

上图描述了FindState的作用和信息,FindState用来查找和保存订阅者及其父类的订阅信息,订阅的方法保占据 subscriberMethods中;subscriberInfo默认为空,一点在初始化完FindState后要循环调用findUsingReflectionInSingleClass方法,该方法通过反射来获取FindState.clazz的@Subscribe注解方法,findUsingInfo会老要循环,直到clazz由于那末符合要求的父类了。

实现类是AsyncPoster,也是通随后台守护进程调用订阅者方法,完成事件发布。但与BackgroundPoster有如下区别:

发送粘性事件

register

Key为发送的粘性事件的Class对象,Value为粘性事件。

是有有一三个白Map对象,postSticky发送的粘性事件会保存到该Map中。

BackgroundPoster:由于当前守护进程是主守护进程,就调用backgroundPoster发布事件;由于当前发布时由于是异步守护进程,那末就直接反射运行订阅者方法,不时需开启守护进程了。

AsyncPoster:无论在哪个守护进程post事件都开启新的守护进程执行。

3、对每个subscriberMethod调用subscribe(subscriber, subscriberMethod)方法。

7、subscriberMethodFinder

Subscription的subscriber对象指的是EventBus.getDefault().register(this)的this对象,subscriberMethod指的是@Subcribe注解的方法的Method对象。

unregister

FindState

通过EventBus.getDefault().post(postEvent);后要 发布有有一三个白事件。

EventBus.getDefault().register(this);将当前类注册为事件订阅者。

findUsingInfo

1、注册成为事件接受者:EventBus.getDefault().register(this)将当前类注册为事件接受者

postSingleEvent

postSingleEventForEventType

2、将事件保存到等待时间队列

invokeSubscriber通过反射调用了subscriber的method,并传入了Event参数。

EventBus事件传递机制

通过EventBus.getDefault().unregister(this);后要 完成注销,即订阅者没得关注任何事件了。

到这里,介绍完EventBus主要的成员后,下面分析下EventBus.getDefault().register的流程。

类型为mainThreadSupport类型为MainThreadSupport,mainThreadPoster类型为HandlerPoster。

findUsingReflectionInSingleClass

@Subscribe注解

invokeSubscriber

语句:subscriptionsByEventType保存了订阅MyEvent事件的订阅者列表。

和mainThreadPoster相似于,实现类是BackgroundPoster,该类继承实现了Runnable接口,在异步守护进程调用订阅者的方法。

Subscription

postToSubscription会根据SubscriberMethod的ThreadMode选着调用哪个Poster就进行事件发布。无论在主守护进程还是异步守护进程,最终都是调用了invokeSubscriber:

是有有一三个白Map对象,Key为@Subcribe注解的方法的参数类型,对应到本文一结束的DEMO的MyEvent的Class对象,Value为Subscription列表。

DEMO使用方法

priority:优先级,EventBus根据订阅者的优先级来顺序发布事件。

PostingThreadState

实现类是SubscriberMethodFinder,在EventBus.getDefault().register(this)的随后查询this对象及其父类对象的所有@Subcribe注解的方法。