個人博客:haichenyi.com。感謝關注
簡介
我們先來看一下他的類注釋
/**
* EventBus is a central publish/subscribe event system for Android. Events are posted ({@link #post(Object)}) to the
* bus, which delivers it to subscribers that have a matching handler method for the event type. To receive events,
* subscribers must register themselves to the bus using {@link #register(Object)}. Once registered, subscribers
* receive events until {@link #unregister(Object)} is called. Event handling methods must be annotated by
* {@link Subscribe}, must be public, return nothing (void), and have exactly one parameter
* (the event).
*
* @author Markus Junginger, greenrobot
*/
??英語不是很好茶没,大致講一下這段話是什么意思:EventBus是重要的發(fā)布/訂閱的Android事件系統(tǒng)登下。事件被發(fā)布給總線匠童,這個總線將這個事件傳遞給跟他匹配類型的訂閱者巩趁。接收事件必須在總線使用的時候注冊他們栈幸。一旦注冊撰茎,訂閱者就會一直接收事件嵌牺,直到他們被取消注冊。這個接收方法必須增加注解Subscribe標識龄糊,必須是public逆粹,返回類型是void,并且只有一個參數(shù)炫惩。 簡單的來說僻弹,就是用之前必須先注冊,然后接收方法必須有Subscribe注解他嚷,必須是public蹋绽,返回類型是void并且只有一個參數(shù)
簡單用法
第一步:依賴
implementation 'org.greenrobot:eventbus:3.1.1'
第二步:注冊與反注冊
//注冊,在onCrate里面
EventBus.getDefault().register(this)
//反注冊筋蓖,在onDestory里面
EventBus.getDefault().unregister(this)
第三步:接收方法
@Subscribe
public void handle(MyClothes myClothes){
//你的具體邏輯
}
第四步:發(fā)送
EventBus.getDefault().post(new MyClothes())
??經過上面三步卸耘,你就可以正常使用EventBus了,前面兩步要在一個類里面粘咖,因為接收之前蚣抗,必須要注冊,可以在任意的地方post
源碼解析—getDefault()
public static EventBus getDefault() {
if (defaultInstance == null) {
synchronized (EventBus.class) {
if (defaultInstance == null) {
defaultInstance = new EventBus();
}
}
}
return defaultInstance;
}
??可以看到這里使用的是雙重校驗鎖的單例模式瓮下,保證不同的線程調用該方法得到的都是同一個EventBus實例翰铡。
EventBus()
看到上面的單例模式之后,我們再來瞅瞅單例模式里面調用的構造方法
public EventBus() {
this(DEFAULT_BUILDER);
}
這里他的空參數(shù)的構造方法里面調用的是一個參數(shù)的構造方法讽坏,我們來看看這個參數(shù)是什么锭魔?
private static final EventBusBuilder DEFAULT_BUILDER = new EventBusBuilder();
EventBusBuilder()
EventBusBuilder() {
}
這個builder的構造方法里面什么都沒有,也就是說沒有初始化任何變量震缭,那我們看一看他的變量赂毯,這里我就說一個:
private final static ExecutorService DEFAULT_EXECUTOR_SERVICE = Executors.newCachedThreadPool();
ExecutorService executorService = DEFAULT_EXECUTOR_SERVICE;
Executors.newCachedThreadPool() 創(chuàng)建的是一個可緩存的線程池战虏,如果線程池長度超過處理需要拣宰,可靈活回收空線程池党涕,若無回收,可新建線程巡社。
接下來膛堤,我們再來看看只有EventBusBuilder參數(shù)的構造方法
EventBus(EventBusBuilder builder)
EventBus(EventBusBuilder builder) {
subscriptionsByEventType = new HashMap<>();
typesBySubscriber = new HashMap<>();
stickyEvents = new ConcurrentHashMap<>();
mainThreadPoster = mainThreadSupport != null ? mainThreadSupport.createPoster(this) : null;
backgroundPoster = new BackgroundPoster(this);
asyncPoster = new AsyncPoster(this);
...
}
??講到這里,很明顯晌该,他這里用的是建造者模式肥荔,跟我們之前講的Luban的模式是一樣的,這個建造者模式朝群,我就不講了燕耿。講Luban的時候講過的
??這里我列出來的6個變量,其他變量并沒有列出來姜胖,因為誉帅,其他變量都是builder里面的賦值,沒有啥好講的右莱。我們來看看這6個成員變量的類型
private final Map<Class<?>, CopyOnWriteArrayList<Subscription>> subscriptionsByEventType;
private final Map<Object, List<Class<?>>> typesBySubscriber;
private final Map<Class<?>, Object> stickyEvents;
private final Poster mainThreadPoster;
private final BackgroundPoster backgroundPoster;
private final AsyncPoster asyncPoster;
意義:
- subscriptionsByEventType:可以看到這是一個是以event的class為key蚜锨,以subscribe的list為value的map,有的人可能不知道CopyOnWriteArrayList慢蜓,這是ArrayList的一個線程安全變種亚再。(這里,有人會點到Subscription里面去看一下晨抡,可以看到就是一個類氛悬,封裝了訂閱者和訂閱方法,重寫了hashcode和equal方法)
- typesBySubscriber:這是以訂閱者類為key耘柱,以event的list為value的map圆雁,在注冊和反注冊的時候用的到
- stickyEvents:粘性事件,以event的class為key帆谍,訂閱者為value的map
- 后面這三個Poster都是用來處理粘性事件的
??我們說了這么多成員變量伪朽。我們知道這里的EventBusBuilder就是給EventBus初始化成員變量的,辣么汛蝙,我們可不可以不用getDefault烈涮,獲取eventBus對象呢?
EventBus build1 = EventBus.getDefault();
EventBus build2 = EventBus.builder().build();
這兩個build的區(qū)別是什么呢窖剑?我們可以點到build()方法里面去看一下:
public EventBus build() {
return new EventBus(this);
}
他這里是直接new出來的坚洽,并沒有單例,所以每次使用的都是new一個新的對象西土,而通過getDefault讶舰,獲得是同一個對象