文章图片
2559b11d580f306a600bf00a25ef9b0b0522a2e4.jpg 在这篇文章中，我会注重分析Android中的EventBus的实现原理，如果你之前还没有使用过该框架，那么可以参考我的另一篇文章来了解如何使用EventBus：Android EventBus 的使用。
此外，我还分析过Google的Guava中的EventBus的实现原理，如果想了解这方面的内容可以参考：Guava源码分析—EventBus。
1、源码分析 在分析EventBus源码的时候，我们先从获取一个EventBus实例的方法入手，然后再分别看一下它的注册、取消注册、发布事件以及触发观察方法的代码是如何实现的。在下面的文章中我们将会回答以下几个问题：

1. 在EventBus中，使用@Subscribe注解的时候指定的ThreadMode是如何实现在不同线程间传递数据的？
2. 使用注解和反射的时候的效率问题，是否会像Guava的EventBus一样有缓存优化？
3. 黏性事件是否是通过内部维护了之前发布的数据来实现的，是否使用了缓存？

1.1 获取实例
在创建EventBus实例的时候，一种方式是按照我们上面的形式，通过EventBus的静态方法getDefault来获取一个实例。getDefault本身会调用其内部的构造方法，通过传入一个默认的EventBusBuilder来创建EventBus。此外，我们还可以直接通过EventBus的builder()方法获取一个EventBusBuilder的实例，然后通过该构建者模式来个性化地定制自己的EventBus。即：

// 静态的单例实例 static volatile EventBus defaultInstance; // 默认的构建者 private static final EventBusBuilder DEFAULT_BUILDER = new EventBusBuilder(); // 实际上使用了DCL双检锁机制，这里简化了一下 public static EventBus getDefault() { if (defaultInstance == null) defaultInstance = new EventBus(); return defaultInstance; }public EventBus() { this(DEFAULT_BUILDER); }// 调用getDefault的时候，最终会调用该方法，使用DEFAULT_BUILDER创建一个实例 EventBus(EventBusBuilder builder) { // ... }// 也可以使用下面的方法获取一个构建者，然后使用它来个性化定制EventBus public static EventBusBuilder builder() { return new EventBusBuilder(); }

1.2 注册
【Android|Android EventBus 的源码解析】当调用EventBus实例的register方法的时候，会执行下面的逻辑：

public void register(Object subscriber) { // 首席会获取注册的对象的类型 Class subscriberClass = subscriber.getClass(); // 然后获取注册的对象的订阅方法 List subscriberMethods = subscriberMethodFinder.findSubscriberMethods(subscriberClass); // 对当前实例加锁，并不断执行监听的逻辑 synchronized (this) { for (SubscriberMethod subscriberMethod : subscriberMethods) { // 对订阅方法进行注册 subscribe(subscriber, subscriberMethod); } } }

这里的SubscriberMethod封装了订阅方法（使用@Subscribe注解的方法）类型的信息，它的定义如下所示。从下面可以的代码中我们可以看出，实际上该类就是通过几个字段来存储@Subscribe注解中指定的类型信息，以及一个方法的类型变量。

public class SubscriberMethod { final Method method; final ThreadMode threadMode; final Class eventType; final int priority; final boolean sticky; // ... }

register方法通过subscriberMethodFinder实例的findSubscriberMethods方法来获取该观察者类型中的所有订阅方法，然后将所有的订阅方法分别进行订阅。下面我们先看下查找订阅者的方法。
查找订阅者的订阅方法 下面是SubscriberMethodFinder中的findSubscriberMethods方法：

List findSubscriberMethods(Class subscriberClass) { // 这里首先从缓存当中尝试去取该订阅者的订阅方法 List subscriberMethods = METHOD_CACHE.get(subscriberClass); if (subscriberMethods != null) { return subscriberMethods; }// 当缓存中没有找到该观察者的订阅方法的时候使用下面的两种方法获取方法信息 if (ignoreGeneratedIndex) { subscriberMethods = findUsingReflection(subscriberClass); } else { subscriberMethods = findUsingInfo(subscriberClass); } if (subscriberMethods.isEmpty()) { throw new EventBusException(...); } else { // 将获取到的订阅方法放置到缓存当中 METHOD_CACHE.put(subscriberClass, subscriberMethods); return subscriberMethods; } }

这里我们先从缓存当中尝试获取某个观察者中的所有订阅方法，如果没有可用缓存的话就从该类中查找订阅方法，并在返回结果之前将这些方法信息放置到缓存当中。这里的ignoreGeneratedIndex参数表示是否忽略注解器生成的MyEventBusIndex，该值默认为false。然后，我们会进入到下面的方法中获取订阅方法信息：

private List findUsingInfo(Class subscriberClass) { // 这里通过FindState对象来存储找到的方法信息 FindState findState = prepareFindState(); findState.initForSubscriber(subscriberClass); // 这里是一个循环操作，会从当前类开始遍历该类的所有父类 while (findState.clazz != null) { // 获取订阅者信息 findState.subscriberInfo = getSubscriberInfo(findState); // 1 if (findState.subscriberInfo != null) { // 如果使用了MyEventBusIndex，将会进入到这里并获取订阅方法信息 SubscriberMethod[] array = findState.subscriberInfo.getSubscriberMethods(); for (SubscriberMethod subscriberMethod : array) { if (findState.checkAdd(subscriberMethod.method, subscriberMethod.eventType)) { findState.subscriberMethods.add(subscriberMethod); } } } else { // 未使用MyEventBusIndex将会进入这里使用反射获取方法信息 findUsingReflectionInSingleClass(findState); // 2 } // 将findState.clazz设置为当前的findState.clazz的父类 findState.moveToSuperclass(); } return getMethodsAndRelease(findState); }

在上面的代码中，会从当前订阅者类开始直到它最顶层的父类进行遍历来获取订阅方法信息。这里在循环的内部会根据我们是否使用了MyEventBusIndex走两条路线，对于我们没有使用它的，会直接使用反射来获取订阅方法信息，即进入2处。
下面是使用反射从订阅者中得到订阅方法的代码：

private void findUsingReflectionInSingleClass(FindState findState) { Method[] methods; try { // 获取该类中声明的所有方法 methods = findState.clazz.getDeclaredMethods(); } catch (Throwable th) { methods = findState.clazz.getMethods(); findState.skipSuperClasses = true; } // 对方法进行遍历判断 for (Method method : methods) { int modifiers = method.getModifiers(); // 这里会对方法的修饰符进行校验 if ((modifiers & Modifier.PUBLIC) != 0 && (modifiers & MODIFIERS_IGNORE) == 0) { // 这里对方法的输入参数进行校验 Class[] parameterTypes = method.getParameterTypes(); if (parameterTypes.length == 1) { // 获取方法的注解，用来从注解中获取注解的声明信息 Subscribe subscribeAnnotation = method.getAnnotation(Subscribe.class); if (subscribeAnnotation != null) { // 获取该方法的第一个参数 Class eventType = parameterTypes[0]; if (findState.checkAdd(method, eventType)) { ThreadMode threadMode = subscribeAnnotation.threadMode(); // 最终将封装之后的方法塞入到列表中 findState.subscriberMethods.add(new SubscriberMethod(method, eventType, threadMode, subscribeAnnotation.priority(), subscribeAnnotation.sticky())); } } } else if (strictMethodVerification && method.isAnnotationPresent(Subscribe.class)) { String methodName = method.getDeclaringClass().getName() + "." + method.getName(); throw new EventBusException(...); } } else if (strictMethodVerification && method.isAnnotationPresent(Subscribe.class)) { String methodName = method.getDeclaringClass().getName() + "." + method.getName(); throw new EventBusException(...); } } }

这里会对当前类中声明的所有方法进行校验，并将符合要求的方法的信息封装成一个SubscriberMethod对象塞到列表中。
注册订阅方法 直到了如何拿到所有的订阅方法之后，我们回到之前的代码，看下订阅过程中的逻辑：

private void subscribe(Object subscriber, SubscriberMethod subscriberMethod) { Class eventType = subscriberMethod.eventType; // 将所有的观察者和订阅方法封装成一个Subscription对象 Subscription newSubscription = new Subscription(subscriber, subscriberMethod); // 1 // 尝试从缓存中根据事件类型来获取所有的Subscription对象 CopyOnWriteArrayList subscriptions = subscriptionsByEventType.get(eventType); // 2 if (subscriptions == null) { // 指定的事件类型没有对应的观察对象的时候 subscriptions = new CopyOnWriteArrayList<>(); subscriptionsByEventType.put(eventType, subscriptions); } else { if (subscriptions.contains(newSubscription)) { throw new EventBusException(...); } }// 这里会根据新加入的方法的优先级决定插入到队列中的位置 int size = subscriptions.size(); // 2 for (int i = 0; i <= size; i++) { if (i == size || subscriberMethod.priority > subscriptions.get(i).subscriberMethod.priority) { subscriptions.add(i, newSubscription); break; } }// 这里又会从“订阅者-事件类型”列表中尝试获取该订阅者对应的所有事件类型 List> subscribedEvents = typesBySubscriber.get(subscriber); // 3 if (subscribedEvents == null) { subscribedEvents = new ArrayList<>(); typesBySubscriber.put(subscriber, subscribedEvents); } subscribedEvents.add(eventType); // 如果是黏性事件还要进行如下的处理 if (subscriberMethod.sticky) { // 4 if (eventInheritance) { Set, Object>> entries = stickyEvents.entrySet(); for (Map.Entry, Object> entry : entries) { Class candidateEventType = entry.getKey(); if (eventType.isAssignableFrom(candidateEventType)) { Object stickyEvent = entry.getValue(); // 这里会向该观察者通知所有的黏性事件 checkPostStickyEventToSubscription(newSubscription, stickyEvent); } } } else { Object stickyEvent = stickyEvents.get(eventType); checkPostStickyEventToSubscription(newSubscription, stickyEvent); } } }

这里涉及到了几个集合，它们是用来做缓存的，还有就是来维护观察者、事件类型和订阅方法之间的关系的。注册观察的方法比较长，我们可以一点一点来看。首先，会在代码1处将观察者和订阅方法封装成一个Subscription对象。然后，在2处用到了CopyOnWriteArrayList这个集合，它是一种适用于多读写少场景的数据结构，是一种线程安全的数组型的数据结构，主要用来存储一个事件类型所对应的全部的Subscription对象。EventBus在这里通过一个Map, CopyOnWriteArrayList>类型的哈希表来维护这个映射关系。然后，我们的程序执行到2处，在这里会对Subscription对象的列表进行遍历，并根据订阅方法的优先级，为当前的Subscription对象寻找一个合适的位置。3的地方主要的逻辑是获取指定的观察者对应的全部的观察事件类型，这里也是通过一个哈希表来维护这种映射关系的。然后，在代码4处，程序会根据当前的订阅方法是否是黏性的，来决定是否将当前缓存中的信息发送给新订阅的方法。这里会通过checkPostStickyEventToSubscription方法来发送信息，它内部的实现的逻辑和post方法类似，我们不再进行说明。
取消注册的逻辑比较比较简单，基本上就是注册操作反过来——将当前订阅方法的信息从缓存中踢出来，我们不再进行分分析。下面我们分析另一个比较重要的地方，即发送事件相关的逻辑。
1.3 通知
通知的逻辑相对来说会比较复杂一些，因为这里面涉及一些线程之间的操作。我们看下下面的代码吧：

public void post(Object event) { // 这里从线程局部变量中取出当前线程的状态信息 PostingThreadState postingState = currentPostingThreadState.get(); // 这里是以上线程局部变量内部维护的一个事件队列 List