摘要：實現(xiàn)了觀察者模式，使用方法非常簡單，可參考有用的二這篇文章主要講解的實現(xiàn)原理。一言以蔽之內(nèi)部有一個，當時往中增加一個元素為事件的類型，為觀察者，時根據(jù)事件類型找到觀察者之后，對其反射調(diào)用。

EventBus實現(xiàn)了觀察者模式，使用方法非常簡單，可參考:有用的Guava(二)

這篇文章主要講解EventBus的實現(xiàn)原理。
一言以蔽之:EventBus內(nèi)部有一個map，當register時往map中增加一個元素(key為事件的類型，value為觀察者)，post時根據(jù)事件類型找到觀察者之后，對其反射調(diào)用。
下面我們從register方法開始：

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

調(diào)用eventBus.register(new Event())時，會將事件類型及觀察者(封裝為EventHandler)放置在SetMultimap, EventHandler> handlersByType中，這是一個線程安全的對象容器，卸載事件也是在這個容器中做移除操作。根據(jù)事件類型查找觀察者時使用了策略模式，HandlerFindingStrategy finder做為策略接口，目前只有一個策略實現(xiàn)AnnotatedHandlerFinder(查找?guī)в蠸ubscribe注解的方法)。
有了這樣一個map，調(diào)用post時只需要根據(jù)類型找到觀察者就行了：

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

    boolean dispatched = false;
    for (Class eventType : dispatchTypes) {
      handlersByTypeLock.readLock().lock();
      try {
        Set 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();
  }

這里查找到參數(shù)匹配的EventHandler后并沒有立刻執(zhí)行反射調(diào)用，而是分發(fā)到了事件隊列（ThreadLocal> eventsToDispatch）中，當所有事件分發(fā)完畢之后，事件隊列做統(tǒng)一的事件消費。