摘要：第二種是通過(guò)方法來(lái)檢查，源碼如下通過(guò)以及來(lái)生成一個(gè)，來(lái)存儲(chǔ)方法所在的類。先看下的方法繼承了，調(diào)用方法后會(huì)向事件隊(duì)列中插入一個(gè)事件，然后將標(biāo)記位設(shè)置為表示正在處理事件，然后調(diào)用發(fā)送消息通知處理事件。

首先從訂閱開(kāi)始

EventBus.getDefault().register(this);

register方法會(huì)獲取傳入的object對(duì)象的class，通過(guò)findSubscriberMethods方法來(lái)查找這個(gè)class中訂閱的方法，如下

    public void register(Object subscriber) {
        Class<");synchronized (this) {
            for (SubscriberMethod subscriberMethod : subscriberMethods) {
                subscribe(subscriber, subscriberMethod);
            }
        }
    }

findSubscriberMethods方法實(shí)現(xiàn)如下，其中有一個(gè)ConcurrentHashMap類型的靜態(tài)對(duì)象METHOD_CACHE，是用來(lái)緩存對(duì)應(yīng)類的訂閱方法的，以便后續(xù)再次訂閱時(shí)不用重新去findMethods，可以直接從緩存中讀取。

    List findSubscriberMethods(Class<"); {
        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("Subscriber " + subscriberClass
                    + " and its super classes have no public methods with the @Subscribe annotation");
        } else {
            METHOD_CACHE.put(subscriberClass, subscriberMethods);
            return subscriberMethods;
        }
    }

查找訂閱方法通過(guò)ignoreGeneratedIndex字段分為兩種方式

第一種findUsingReflection是通過(guò)反射來(lái)查找，找到被@Subscribe注解修飾的方法，并且根據(jù)具體的注解以及方法參數(shù)生成一個(gè)SubscriberMethod對(duì)象：

findState.subscriberMethods.add(new SubscriberMethod(method, eventType, threadMode,
                                    subscribeAnnotation.priority(), subscribeAnnotation.sticky()));

第二種findUsingInfo是通過(guò)apt的方式，提前找到訂閱的方法，可以避免通過(guò)反射查找方法帶來(lái)的耗時(shí)。

具體使用方法：在gradle配置apt，rebuild項(xiàng)目，會(huì)生成一個(gè)注解方法索引類，在EventBusBuilder中通過(guò)addIndex方法新建一個(gè)該類的對(duì)象傳入即可。

這邊還有一個(gè)問(wèn)題，對(duì)于子類重寫(xiě)父類的訂閱方法如何處理。在上面的兩種方式中在查找完子類的訂閱方法后都會(huì)繼續(xù)去查找父類的訂閱方法，都通過(guò)一個(gè)叫做checkAdd的方法進(jìn)行支撐，該方法返回true表示可以添加到訂閱方法的集合中去。

boolean checkAdd(Method method, Class<"); {
    // 2 level check: 1st level with event type only (fast), 2ndlevelwith complete signature when required.
    // Usually a subscriber doesn"t have methods listening to thesameevent type.
    Object existing = anyMethodByEventType.put(eventType, method);
    if (existing == null) {
        return true;
    } else {
        if (existing instanceof Method) {
            if (!checkAddWithMethodSignature((Method)existing,eventType)) {
                // Paranoia check
                throw new IllegalStateException();
            }
            // Put any non-Method object to "consume" theexistingMethod
            anyMethodByEventType.put(eventType, this);
        }
        return checkAddWithMethodSignature(method, eventType);
    }
}

checkAdd中設(shè)置了兩種檢查方式，第一種是通過(guò)eventType也就是訂閱方法的入?yún)?lái)檢查，這種方式比較快，只需要看下之前有沒(méi)有這種入?yún)⒌姆椒ň涂梢粤?。注釋中也指出了通常一個(gè)類不會(huì)有多個(gè)入?yún)⑾嗤挠嗛喎椒ā?/p>

第二種是通過(guò)checkAddWithMethodSignature方法來(lái)檢查，源碼如下：

private boolean checkAddWithMethodSignature(Method method,Class<"); {
    methodKeyBuilder.setLength(0);
    methodKeyBuilder.append(method.getName());
    methodKeyBuilder.append(">").append(eventType.getName());
    String methodKey = methodKeyBuilder.toString();
    Class<");if (methodClassOld == null||methodClassOld.isAssignableFrom(methodClass)) {
        // Only add if not already found in a sub class
        return true;
    } else {
        // Revert the put, old class is further down theclasshierarchy
        subscriberClassByMethodKey.put(methodKey, methodClassOld);
        return false;
    }
}

通過(guò)method以及eventType來(lái)生成一個(gè)key，來(lái)存儲(chǔ)方法所在的類。其中methodClassOld == null ||methodClassOld.isAssignableFrom(methodClass)這個(gè)判斷條件對(duì)應(yīng)著兩種情況，methodClassOld == null說(shuō)明是入?yún)⑾嗤欠椒煌姆椒ㄕ诒惶砑?，直接返?b>true就可以了methodClassOld.isAssignableFrom(methodClass)這個(gè)條件是為了過(guò)濾掉父類被子類重寫(xiě)的方法，前面說(shuō)過(guò)了查找訂閱方法是從子類開(kāi)始遍歷的，此時(shí)如果子類重寫(xiě)了父類的訂閱方法，那么methodClassOld對(duì)應(yīng)的是子類，methodClass對(duì)應(yīng)的是父類，顯然這個(gè)判斷就會(huì)為false，之后進(jìn)入下面的else分支return false，也就是忽略掉父類被子類重寫(xiě)的方法。

查找訂閱方法基本就這么點(diǎn)，查找完畢之后需要執(zhí)行訂閱操作，也就是register方法中的subscribe(subscriber, subscriberMethod);操作，直接看下該方法的實(shí)現(xiàn)：

private void subscribe(Object subscriber, SubscriberMethodsubscriberMethod) {
    Class<");new Subscription(subscriber,subscriberMethod);
    CopyOnWriteArrayList subscriptions =subscriptionsByEventType.get(eventType);
    if (subscriptions == null) {
        subscriptions = new CopyOnWriteArrayList<>();
        subscriptionsByEventType.put(eventType, subscriptions);
    } else {
        if (subscriptions.contains(newSubscription)) {
            throw new EventBusException("Subscriber " +subscriber.getClass() + " already registered to event "
                    + eventType);
        }
    }
    int size = subscriptions.size();
    for (int i = 0; i <= size; i++) {
        if (i == size || subscriberMethod.priority >subscriptions.get(i).subscriberMethod.priority) {
            subscriptions.add(i, newSubscription);
            break;
        }
    }
    Listif (subscribedEvents == null) {
        subscribedEvents = new ArrayList<>();
        typesBySubscriber.put(subscriber, subscribedEvents);
    }
    subscribedEvents.add(eventType);
    if (subscriberMethod.sticky) {
        if (eventInheritance) {
            // Existing sticky events of all subclasses of eventTypehave to be considered.
            // Note: Iterating over all events may be inefficientwith lots of sticky events,
            // thus data structure should be changed to allow a moreefficient lookup
            // (e.g. an additional map storing sub classes of superclasses: Class -> List).
            Setfor (Map.Entryif (eventType.isAssignableFrom(candidateEventType)) {
                    Object stickyEvent = entry.getValue();
                checkPostStickyEventToSubscription(newSubscriptin, stickyEvent);
                }
            }
        } else {
            Object stickyEvent = stickyEvents.get(eventType);
            checkPostStickyEventToSubscription(newSubscription,stickyEvent);
        }
    }
}

subscriptionsByEventType這個(gè)Map是將eventType作為key保存其所對(duì)應(yīng)的訂閱方法的集合。該方法將剛查找到的方法添加到對(duì)應(yīng)的集合中去，添加時(shí)有這樣一層判斷i == size || subscriberMethod.priority >subscriptions.get(i).subscriberMethod.priority這表示這個(gè)集合里的方法會(huì)按照所設(shè)定的優(yōu)先級(jí)進(jìn)行排序。緊接著又出現(xiàn)了個(gè)MaptypesBySubscriber將訂閱者作為key保存一個(gè)Class的集合，暫時(shí)看不出有啥用，就先不管，最后再檢查下是不是粘性事件，如果是粘性事件就根據(jù)所保存的粘性事件來(lái)執(zhí)行該方法。eventInheritance也是在bulider中設(shè)置的，如果為true則會(huì)考慮事件的繼承性，如果現(xiàn)在有eventType為正在訂閱的方法的eventType的子類的粘性事件存在，那么這個(gè)粘性事件也會(huì)被正在訂閱的方法接收到，直接說(shuō)可能比較繞，舉個(gè)栗子，現(xiàn)在我有兩個(gè)事件，其中一個(gè)是另一個(gè)的子類，并且有兩個(gè)粘性訂閱方法，如下：

    class EventMessage {
  
    }

    class SubEventMessage extends EventMessage {

    }
    
    @Subscribe(sticky =  true)
    public void onEvent(EventMessage message) {
        // do something
    }

    @Subscribe(sticky =  true)
    public void onSubEvent(SubEventMessage message) {
        // do something
    }

當(dāng)執(zhí)行register時(shí)，如果內(nèi)存中存在著一個(gè)類型為SubEventMessage的事件，那么訂閱的時(shí)候onEvent方法會(huì)被執(zhí)行，入?yún)⑹莾?nèi)存中類型為SubEventMessage的事件。

現(xiàn)在register大致就分析完了，再來(lái)看下unregister方法：

    public synchronized void unregister(Object subscriber) {
        Listif (subscribedTypes != null) {
            for (Class<");else {
            logger.log(Level.WARNING, "Subscriber to unregister was not registered before: " + subscriber.getClass());
        }
    }

unregister方法十分簡(jiǎn)單，typesBySubscriber是剛才在進(jìn)行訂閱的時(shí)候不知道用來(lái)干什么的Map，現(xiàn)在知道是在取消訂閱時(shí)用到的，這個(gè)Map將訂閱者作為key，將其所有的訂閱方法的eventType存入到對(duì)應(yīng)的List中去，取消訂閱時(shí)將這個(gè)List取出來(lái)，遍歷去移除對(duì)應(yīng)的訂閱方法，具體實(shí)現(xiàn)在unsubscribeByEventType中，也十分簡(jiǎn)單，就不贅述了。

訂閱和取消訂閱都看過(guò)了，還差個(gè)發(fā)送事件，發(fā)送事件分為post和postSticky兩種，先看post：

    public void post(Object event) {
        PostingThreadState postingState = currentPostingThreadState.get();
        List