EventBus初理解

本文轉載自查看原文 2016-02-01 18:45 3761 Android

　緣由：

平時工作，因為懶於動筆的原因，也沒注重技術和經驗的積累，導致之前曾經研究過的問題現在又忘記了，所以要慢慢注重積累，那么就從寫作開始，談談對工作中碰到的問題進行整理和歸納。

我們都知道，在Android中，想處理事件傳遞，可以用Handler+MessageQueue+Message+Looper循環，固然是有解決方法，但是這個使用起來不方便，代碼寫起來也不簡潔，同時還必須要理解好Handler+MessageQueue+Message+Looper之間的關系，比如這樣的圖：

是不是看到覺得頭大，理解起來也麻煩，但是這個原理是很有必要去了解的，這個也是基本功之一吧。今天我們來講講對於EventBus這個開源庫的分析，看看高手代碼是如何寫的，如何解耦合，對於自身的技術的進步相比也是很有大的幫助吧。

初認識：

因為在工作大量用到Fragment和Activity之間的耦合，需要獲取對方某某的實例，自然而然就去尋找事件之間是否有解耦合的庫，EventBus就涌現出來了，這個是greenrobot大神寫的，多么經典已經無需多說了，github地址： https://github.com/greenrobot/EventBus，雖然我們會使用，但是也需要了解里面的原理，這樣使用的起來也放心，畢竟對於陌生的東西不明白內部情況，就去用，什么時候被坑也會不知道的。

腦補下：

介紹這個庫之前，需要認識以下幾個名詞。

事件(Event)：又可稱為消息，本文中統一用事件表示。其實就是一個對象，可以是網絡請求返回的字符串，也可以是某個開關狀態等等。事件類型(EventType)指事件所屬的 Class。事件分為一般事件和 Sticky 事件，相對於一般事件，Sticky 事件不同之處在於，當事件發布后，再有訂閱者開始訂閱該類型事件，依然能收到該類型事件最近一個 Sticky 事件。

訂閱者(Subscriber)：訂閱某種事件類型的對象。當有發布者發布這類事件后，EventBus 會執行訂閱者的 onEvent 函數，這個函數叫事件響應函數。訂閱者通過 register 接口訂閱某個事件類型，unregister 接口退訂。訂閱者存在優先級，優先級高的訂閱者可以取消事件繼續向優先級低的訂閱者分發，默認所有訂閱者優先級都為 0。

發布者(Publisher)：發布某事件的對象，通過 post 接口發布事件。

結構圖：

從中，我們可以看到這個庫整體結構是基於生產者/消費者模式，也可以稱呼為發布者/訂閱者，顯得更親切。所謂的發布者/訂閱者，比如我們日常生活中，小區的通告欄，生產者類似小區居委會，訂閱者就是小區里的住戶，當你需要小區居委會幫忙的時候，比如你外出了，可以叫居委會里某個大媽幫你拿下快遞，那么你需要在居委會那里登記，也可以叫做注冊，只有登記了，居委會里的大媽才知道你是我們同一個小區的，也可以認識你了。同時，每當有事情發生，需要通知的時候，需要在通告欄里發布一個通告，現在信息發達了，通告欄可以通過微信公眾號來發布，但是也需要每個人去掃一掃，關注下小區的公眾號，一發通知，有關注的業主自然就知道通知事情是什么。那么這個EventBus庫的實現原理，跟我們日常生活中的微信公眾號很類型，首先在使用的時候，我們需要向公眾平台注冊，注冊完之后，當生產者需要發布信息的時候，平台會幫我們把這些消息推送給訂閱者，訂閱者根據消息內容，進行不同處理操作。

使用方法流程：

類圖：

根據類來分析，從中，我們可以看到EventBus依賴有五個類，分別如下。

SubscriberMethod:這是一個訂閱方法類的封裝，包含了方法反射的名稱，線程模型和事件類型，比如當你向主干注冊的時候，這時候就會實例化SubscriberMethod類實例，來存放以onEvent開頭的方法，運行的線程模型和自定義的傳遞事件類型。

SubscriberMethodFinder:在這個類中，我們可以看到為何在定義方法消息接受回調時，會以“onEvent”開頭的方法，因為這里有個

private static final String ON_EVENT_METHOD_NAME = "onEvent";

ON_EVENT_METHOD_NAME的常量。里面關鍵方法是findSubscriberMethods(),具體實現可以去看代碼，通過反射的方法，找出訂閱者上的以onEvent開頭的方法，最終返回的時候SubscriberMethod類的集合，也就是所有事件響應函數。

HandlerPoster:這是繼承Handler的請求類，封裝了請求隊列，整個過程是在隊列不斷發送請求，直到所有的請求都出隊列，也就是全部發送完畢。事件主線程處理，對應ThreadMode.MainThread。enqueue 函數將事件放到隊列中，並利用 handler 發送 message，handleMessage 函數從隊列中取事件，invoke 事件響應函數處理。

AsyncPoster:這個其實一個Runnable實現類，封裝執行的過程，在異步時調用。是一個事件異步線程處理，對應ThreadMode.Async。enqueue 函數將事件放到隊列中，並調用線程池執行當前任務，在 run 函數從隊列中取事件，invoke 事件響應函數處理。

BackgroundPoster:這個其實一個Runnable實現類，事件 Background 處理，對應ThreadMode.BackgroundThread。enqueue 函數將事件放到隊列中，並調用線程池執行當前任務，在 run 函數從隊列中取事件，invoke 事件響應函數處理。與 AsyncPoster.java 不同的是BackgroundPoster 中的任務只在同一個線程中依次執行，而不是並發執行。

ThreadMode模型

線程模型共有四類：

PostThread，默認的ThreadMode，表示在執行Post操作的線程直接調用訂閱者的事件響應方法不論該線程是否為主線程(UI線程)。當該線程為主線程時，響應方法不能有耗時操作，否則有卡主線程風險。適用場景：對於是否在主線程執行無要求，但若 Post 線程為主線程，不能耗時的操作。
MainThread，在主線程中執行響應方法。如果發布線程就是主線程，則直接調用訂閱者的事件響應方法，否則通過主線程的 Handler 發送消息在主線程中處理——調用訂閱者的事件響應函數。顯然，MainThread類的方法也不能有耗時操作，以避免卡主線程。適用場景：必須在主線程執行的操作；

BackgroundThread，在后台線程中執行響應方法。如果發布線程不是主線程，則直接調用訂閱者的事件響應函數，否則啟動唯一的后台線程去處理。由於后台線程是唯一的，當事件超過一個的時候，它們會被放在隊列中依次執行，因此該類響應方法雖然沒有PostThread類和MainThread類方法對性能敏感，但最好不要有重度耗時的操作或太頻繁的輕度耗時操作，以造成其他操作等待。適用場景：操作輕微耗時且不會過於頻繁，即一般的耗時操作都可以放在這里；
Async，不論發布線程是否為主線程，都使用一個空閑線程來處理。和BackgroundThread不同的是，Async類的所有線程是相互獨立的，因此不會出現卡線程的問題。適用場景：長耗時操作，例如網絡訪問。

EventBus類介紹

EventBus類是對外暴露的API，包括register()，post()，unregister()方法，配合自定義的EventTypeji s事件響應，即可完成使用過程。

EventBus類有個默認getDefault單例，當然也可以通過EventBusBuilder 或構造函數新建一個EventBus，每個新建的EventBus發布和訂閱事件都是相互隔離的，即在一個EventBus對象中發布事件，如果有另外一個EventBus對象，則另外一個EventBus對象的訂閱者不會收到該訂閱。

關鍵點：

1，register和unregister，分別表示訂閱事件和取消訂閱，register 最底層函數有三個參數，分別為訂閱者對象、是否是 Sticky 事件、優先級。

注冊流程：

第一，通過subscriptionsByEventType得到該事件類型的所有訂閱者信息隊列，根據優先級把當前訂閱者信息插入到訂閱者隊列subscriptionsByEventType中。

第二，在typesBySubscriber中得到當前訂閱者的所有事件隊列，將此事件保存到隊列typesBySubscriber中，用於后續取消訂閱。

第三，檢查這個事件是否是 Sticky 事件，如果是則從stickyEvents事件保存隊列中取出該事件類型最后一個事件發送給當前訂閱者。

發布流程：

post方法，用於發布事件，cancle方法用戶取消訂閱者訂閱的所有事件類型。

post 方法會首先得到當前線程的 post 信息PostingThreadState，其中包含事件隊列，將當前事件添加到其事件隊列中，然后循環調用 postSingleEvent 函數發布隊列中的每個事件。

postSingleEvent 方法會先去eventTypesCache得到該事件對應類型的的父類及接口類型，沒有緩存則查找並插入緩存。循環得到的每個類型和接口，調用 postSingleEventForEventType 方法發布每個事件到每個訂閱者。

postSingleEventForEventType 方法在subscriptionsByEventType查找該事件訂閱者訂閱者隊列，調用 postToSubscription 函數向每個訂閱者發布事件。

結尾：

重點名稱解釋：

typesBySubscriber訂閱者訂閱的事件的保存隊列，以 subscriber 為 key，元素為 eventType 的 ArrayList 為 Value。
currentPostingThreadState當前線程的 post 信息，包括事件隊列、是否正在分發中、是否在主線程、訂閱者信息、事件實例、是否取消。
mainThreadPoster、backgroundPoster、asyncPoster事件主線程處理者、事件 Background 處理者、事件異步處理者。
subscriberMethodFinder訂閱者響應函數信息存儲和查找類。
executorService異步和 BackGround 處理方式的線程池。

參考地址： http://www.codekk.com/open-source-project-analysis/detail/Android/Trinea/EventBus%20源碼解析