緣由: 平時工作,因為懶於動筆的原因,也沒註重技術和經驗的積累,導致之前曾經研究過的問題現在又忘記了,所以要慢慢註重積累,那麼就從寫作開始,談談對工作中碰到的問題進行整理和歸納。 我們都知道,在Android中,想處理事件傳遞,可以用Handler+MessageQueue+Message+Loop
緣由: 平時工作,因為懶於動筆的原因,也沒註重技術和經驗的積累,導致之前曾經研究過的問題現在又忘記了,所以要慢慢註重積累,那麼就從寫作開始,談談對工作中碰到的問題進行整理和歸納。 我們都知道,在Android中,想處理事件傳遞,可以用Handler+MessageQueue+Message+Looper迴圈,固然是有解決方法,但是這個使用起來不方便,代碼寫起來也不簡潔,同時還必須要理解好Handler+MessageQueue+Message+Looper之間的關係,比如這樣的圖:


事件(Event):又可稱為消息,本文中統一用事件表示。其實就是一個對象,可以是網路請求返回的字元串,也可以是某個開關狀態等等。事件類型(EventType)指事件所屬的 Class。事件分為一般事件和 Sticky 事件,相對於一般事件,Sticky 事件不同之處在於,當事件發佈後,再有訂閱者開始訂閱該類型事件,依然能收到該類型事件最近一個 Sticky 事件。
訂閱者(Subscriber):訂閱某種事件類型的對象。當有發佈者發佈這類事件後,EventBus 會執行訂閱者的 onEvent 函數,這個函數叫事件響應函數。訂閱者通過 register 介面訂閱某個事件類型,unregister 介面退訂。訂閱者存在優先順序,優先順序高的訂閱者可以取消事件繼續向優先順序低的訂閱者分發,預設所有訂閱者優先順序都為 0。
發佈者(Publisher):發佈某事件的對象,通過 post 介面發佈事件。
結構圖:





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類的所有線程是相互獨立的,因此不會出現卡線程的問題。適用場景:長耗時操作,例如網路訪問。




register 函數中會先根據訂閱者類名去subscriberMethodFinder中查找當前訂閱者所有事件響應函數,然後迴圈每一個事件響應函數,依次執行下麵的 subscribe 函數:
第一,通過subscriptionsByEventType得到該事件類型的所有訂閱者信息隊列,根據優先順序把當前訂閱者信息插入到訂閱者隊列subscriptionsByEventType中。第二,在typesBySubscriber中得到當前訂閱者的所有事件隊列,將此事件保存到隊列typesBySubscriber中,用於後續取消訂閱。
第三,檢查這個事件是否是 Sticky 事件,如果是則從stickyEvents事件保存隊列中取出該事件類型最後一個事件發送給當前訂閱者。 發佈流程:

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 處理方式的線程池。