EventBus源码分析

       前面一篇文章讲解了EventBus的使用，但是作为开发人员，不能只停留在仅仅会用的层面上，我们还需要弄清楚它的内部实现原理。所以本篇博文将分析EventBus的源码，看看究竟它是如何实现“发布/订阅”功能的。

事件注册

根据前一讲EventBus使用详解我们已经知道EventBus使用首先是需要注册的，注册事件的代码如下：

EventBus.getDefault().register(this);

EventBus对外提供了一个register方法来进行事件注册，该方法接收一个Object类型的参数，下面看下register方法的源码:

public void register(Object subscriber) {
Class<?> subscriberClass = subscriber.getClass();
List<SubscriberMethod> subscriberMethods =subscriberMethodFinder.findSubscriberMethods(subscriberClass);
for (SubscriberMethod subscriberMethod : subscriberMethods) {
subscribe(subscriber, subscriberMethod);
}
}

通过传入的类（Activity中，一般写的是this，也就是Activity本身）

得到对应的 Class<?> 对象， 再通过 SubscriberMethodFinder对象去得到 一个 SubscriberMethod的List

把对应的List放入到一个容器中（应该用于之后通知的过程中，判断是否响应）

注：下面会对SubscriberMethodFinder进行分析。

事件解注册unregister

/** Unregisters the given subscriber from all event classes. */
public synchronized void unregister(Object subscriber) {
List<Class<?>> subscribedTypes = typesBySubscriber.get(subscriber);
if (subscribedTypes != null) {
for (Class<?> eventType : subscribedTypes) {
unsubscribeByEventType(subscriber, eventType);
}
typesBySubscriber.remove(subscriber);
} else {
logger.log(Level.WARNING, "Subscriber to unregister was not registered before: " + subscriber.getClass());
}
}

这里也比较好理解，通过容器，拿到对应的Class<?> 的List，也就是某个Activity或者Fragment中，对应的注解类型

循环去遍历，最后在容器Map<Object, List<Class<?>>> typesBySubscriber 中

remove掉对应的key，也就是Activity或者Fragment中所有注解的方法
事件发送post方法

/** Posts the given event to the event bus. */
public void post(Object event) {
PostingThreadState postingState = currentPostingThreadState.get();
List<Object> eventQueue = postingState.eventQueue;
eventQueue.add(event);

if (!postingState.isPosting) {
postingState.isMainThread = isMainThread();
postingState.isPosting = true;
if (postingState.canceled) {
throw new EventBusException("Internal error. Abort state was not reset");
}

4000
try {
while (!eventQueue.isEmpty()) {
postSingleEvent(eventQueue.remove(0), postingState);
}
} finally {
postingState.isPosting = false;
postingState.isMainThread = false;
}
}
}

我们知道，对应的值，是通过post去完成的

这里 用 ThreadLocal的线程包装类，去完成对应的线程记录和操作

对应的泛型PostingThreadState对象，记录对应的信息，将对应的线程放入一个List中

通过对应的状态，判断Looper.getMainLooper() == Looper.myLooper() 是否是主线程等操作， 将状态存入PostingThreadState的属性中

最后，遍历容器中的Event，

最后通过存储的Subscription中的subscriberMethod的method，反射去invoke调用方法。

---------------------------------------------------------------

SubscriberMethodFinder类

其中findSubscriberMethods方法源码如下

List<SubscriberMethod> findSubscriberMethods(Class<?> subscriberClass) {
List<SubscriberMethod> subscriberMethods = METHOD_CACHE.get(subscriberClass);
//如果有Map缓存中有值，就直接获取
if (subscriberMethods != null) {
return subscriberMethods;
}

if (ignoreGeneratedIndex) {
//通过反射获取
subscriberMethods = findUsingReflection(subscriberClass);
} else {
subscriberMethods = findUsingInfo(subscriberClass);
}
if (subscriberMethods.isEmpty()) {
//内部报异常（对外是不会提示的）
throw new EventBusException("Subscriber " + subscriberClass
+ " and its super classes have no public methods with the @Subscribe annotation");
} else {
//把对应的key为 subscriberClass， value为subscriberMethods 加入到 Map缓存中
METHOD_CACHE.put(subscriberClass, subscriberMethods);
return subscriberMethods;
}
}