EventBus初理解

来源:http://www.cnblogs.com/cr330326/archive/2016/02/01/5176038.html
-Advertisement-
Play Games

緣由: 平時工作,因為懶於動筆的原因,也沒註重技術和經驗的積累,導致之前曾經研究過的問題現在又忘記了,所以要慢慢註重積累,那麼就從寫作開始,談談對工作中碰到的問題進行整理和歸納。 我們都知道,在Android中,想處理事件傳遞,可以用Handler+MessageQueue+Message+Loop


 緣由:     平時工作,因為懶於動筆的原因,也沒註重技術和經驗的積累,導致之前曾經研究過的問題現在又忘記了,所以要慢慢註重積累,那麼就從寫作開始,談談對工作中碰到的問題進行整理和歸納。     我們都知道,在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 img     根據類來分析,從中,我們可以看到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 事件、優先順序。 註冊流程:       

register 函數中會先根據訂閱者類名去subscriberMethodFinder中查找當前訂閱者所有事件響應函數,然後迴圈每一個事件響應函數,依次執行下麵的 subscribe 函數:

第一,通過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源碼解析
您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 一、java JDK & 配置 java 系統變數 java JDK 這個請自行百度安裝 配置 java 系統變數 1.打開我的電腦--屬性--高級--環境變數 2.新建系統變數JAVA_HOME 和CLASSPATH 變數名:JAVA_HOME 變數值(jdk安裝目錄):C:\Program Fi
  • 有時需要app裡面顯示網頁,而不調用其他瀏覽器瀏覽網頁,那麼這時就需要WebView控制項。這個控制項也是很強大的,放大,縮小,前進,後退網頁都可以。 1、部分方法 //支持javascriptweb.getSettings().setJavaScriptEnabled(true); // 設置可以支持
  • 應用在後臺運行時很容易被強殺,這很正常,但是回到前臺時,很容易出現空指針的情況。怎麼解決這樣的問題,且看看Stay的見解。 我們先跳出來看看android的app運行原理。 app在後臺被強殺,是在記憶體不足的情況下被強制釋放了,也有一些噁心的rom會強制殺掉那些後臺進程以釋放緩存以提高所謂的用戶體驗
  • 在文章《Android程式員從小白到大神必讀資料彙總(一)和(三)》裡面介紹了基礎學習資料和一點點的進階資料,今天小編收集了5篇帶有實例乾貨的資料,趕緊來看看吧!另外,喜歡寫博客的博主可以申請加工程師博主交流群:391519124,分享你的博文,和大牛們一起交流技術 ~ 一、Android 記憶體泄漏
  • 現在最火的android開發框架 簡單描述一下 這一篇簡單描述尋找控制項以及事件的使用 1.該方法可以不用寫setconteview @EActivity(R.layout.activity_main)public class MainActivity extends Activity { 2.尋找控
  • 1、eclipse關聯源碼 步驟一:自已百度下載相應版本的源碼,我這裡是4.2也就是API=17的版本。 步驟二:找到你安裝sdk的目錄, G:\Program Files\adt-bundle-windows-x86\sdk\platforms\android-4.2 步驟三:在這個目錄下新建一個
  • 通訊錄導航欄源碼: 1.activity 1 package com.anna.contact.activity; 2 3 import java.util.ArrayList; 4 import java.util.HashMap; 5 import java.util.List; 6 7 imp
  • iPhone中GPS定位如何使用 關鍵詞 1.info.plist配置授權描述 2.引入庫 3.CLLocationManager的使用 info.plist配置 在info.plist中根據情況加入以下兩個string類型配置項,並填寫描述 1.NSLocationAlwaysUsageDescr
一周排行
    -Advertisement-
    Play Games
  • C#TMS系統代碼-基礎頁面BaseCity學習 本人純新手,剛進公司跟領導報道,我說我是java全棧,他問我會不會C#,我說大學學過,他說這個TMS系統就給你來管了。外包已經把代碼給我了,這幾天先把增刪改查的代碼背一下,說不定後面就要趕鴨子上架了 Service頁面 //using => impo ...
  • 委托與事件 委托 委托的定義 委托是C#中的一種類型,用於存儲對方法的引用。它允許將方法作為參數傳遞給其他方法,實現回調、事件處理和動態調用等功能。通俗來講,就是委托包含方法的記憶體地址,方法匹配與委托相同的簽名,因此通過使用正確的參數類型來調用方法。 委托的特性 引用方法:委托允許存儲對方法的引用, ...
  • 前言 這幾天閑來沒事看看ABP vNext的文檔和源碼,關於關於依賴註入(屬性註入)這塊兒產生了興趣。 我們都知道。Volo.ABP 依賴註入容器使用了第三方組件Autofac實現的。有三種註入方式,構造函數註入和方法註入和屬性註入。 ABP的屬性註入原則參考如下: 這時候我就開始疑惑了,因為我知道 ...
  • C#TMS系統代碼-業務頁面ShippingNotice學習 學一個業務頁面,ok,領導開完會就被裁掉了,很突然啊,他收拾東西的時候我還以為他要旅游提前請假了,還在尋思為什麼回家連自己買的幾箱飲料都要叫跑腿帶走,怕被偷嗎?還好我在他開會之前拿了兩瓶芬達 感覺感覺前面的BaseCity差不太多,這邊的 ...
  • 概述:在C#中,通過`Expression`類、`AndAlso`和`OrElse`方法可組合兩個`Expression<Func<T, bool>>`,實現多條件動態查詢。通過創建表達式樹,可輕鬆構建複雜的查詢條件。 在C#中,可以使用AndAlso和OrElse方法組合兩個Expression< ...
  • 閑來無聊在我的Biwen.QuickApi中實現一下極簡的事件匯流排,其實代碼還是蠻簡單的,對於初學者可能有些幫助 就貼出來,有什麼不足的地方也歡迎板磚交流~ 首先定義一個事件約定的空介面 public interface IEvent{} 然後定義事件訂閱者介面 public interface I ...
  • 1. 案例 成某三甲醫預約系統, 該項目在2024年初進行上線測試,在正常運行了兩天後,業務系統報錯:The connection pool has been exhausted, either raise MaxPoolSize (currently 800) or Timeout (curren ...
  • 背景 我們有些工具在 Web 版中已經有了很好的實踐,而在 WPF 中重新開發也是一種費時費力的操作,那麼直接集成則是最省事省力的方法了。 思路解釋 為什麼要使用 WPF?莫問為什麼,老 C# 開發的堅持,另外因為 Windows 上已經裝了 Webview2/edge 整體打包比 electron ...
  • EDP是一套集組織架構,許可權框架【功能許可權,操作許可權,數據訪問許可權,WebApi許可權】,自動化日誌,動態Interface,WebApi管理等基礎功能於一體的,基於.net的企業應用開發框架。通過友好的編碼方式實現數據行、列許可權的管控。 ...
  • .Net8.0 Blazor Hybird 桌面端 (WPF/Winform) 實測可以完整運行在 win7sp1/win10/win11. 如果用其他工具打包,還可以運行在mac/linux下, 傳送門BlazorHybrid 發佈為無依賴包方式 安裝 WebView2Runtime 1.57 M ...