EventBus原理

EventBus实现了观察者模式，使用方法很是简单，可参考:有用的Guava(二)

这篇文章主要讲解EventBus的实现原理。
一言以蔽之:EventBus内部有一个map，当register时往map中增长一个元素(key为事件的类型，value为观察者)，post时根据事件类型找到观察者以后，对其反射调用。
下面咱们从register方法开始：

public void register(Object object) {
    Multimap<Class<?>, EventHandler> methodsInListener =
        finder.findAllHandlers(object);
    handlersByTypeLock.writeLock().lock();
    try {
      handlersByType.putAll(methodsInListener);
    } finally {
      handlersByTypeLock.writeLock().unlock();
    }
  }

调用eventBus.register(new Event())时，会将事件类型及观察者(封装为EventHandler)放置在SetMultimap<Class<?>, EventHandler> handlersByType中，这是一个线程安全的对象容器，卸载事件也是在这个容器中作移除操做。根据事件类型查找观察者时使用了策略模式，HandlerFindingStrategy finder作为策略接口，目前只有一个策略实现AnnotatedHandlerFinder(查找带有Subscribe注解的方法)。
有了这样一个map，调用post时只须要根据类型找到观察者就好了：

public void post(Object event) {
    Set<Class<?>> dispatchTypes = flattenHierarchy(event.getClass());

    boolean dispatched = false;
    for (Class<?> eventType : dispatchTypes) {
      handlersByTypeLock.readLock().lock();
      try {
        Set<EventHandler> wrappers = handlersByType.get(eventType);

        if (!wrappers.isEmpty()) {
          dispatched = true;
          for (EventHandler wrapper : wrappers) {
            enqueueEvent(event, wrapper);
          }
        }
      } finally {
        handlersByTypeLock.readLock().unlock();
      }
    }

    if (!dispatched && !(event instanceof DeadEvent)) {
      post(new DeadEvent(this, event));
    }

    dispatchQueuedEvents();
  }

这里查找到参数匹配的EventHandler后并无马上执行反射调用，而是分发到了事件队列（ThreadLocal<Queue<EventWithHandler>> eventsToDispatch）中，当全部事件分发完毕以后，事件队列作统一的事件消费。