詳解用RxJava實(shí)現(xiàn)事件總線(Event Bus)
目前大多數(shù)開發(fā)者使用EventBus或者Otto作為事件總線通信庫，對于RxJava使用者來說，RxJava也可以輕松實(shí)現(xiàn)事件總線，因?yàn)樗鼈兌家罁?jù)于觀察者模式。
不多說，上代碼
/**
* RxBus
* Created by YoKeyword on 2015/6/17.
*/
public class RxBus {
private static volatile RxBus defaultInstance;
private final Subject<Object, Object> bus;
// PublishSubject只會(huì)把在訂閱發(fā)生的時(shí)間點(diǎn)之后來自原始Observable的數(shù)據(jù)發(fā)射給觀察者
public RxBus() {
bus = new SerializedSubject<>(PublishSubject.create());
}
// 單例RxBus
public static RxBus getDefault() {
if (defaultInstance == null) {
synchronized (RxBus.class) {
if (defaultInstance == null) {
defaultInstance = new RxBus();
}
}
}
return defaultInstance ;
}
// 發(fā)送一個(gè)新的事件
public void post (Object o) {
bus.onNext(o);
}
// 根據(jù)傳遞的 eventType 類型返回特定類型(eventType)的 被觀察者
public <T> Observable<T> toObservable (Class<T> eventType) {
return bus.ofType(eventType);
// 這里感謝小鄧子的提醒: ofType = filter + cast
// return bus.filter(new Func1<Object, Boolean>() {
// @Override
// public Boolean call(Object o) {
// return eventType.isInstance(o);
// }
// }) .cast(eventType);
}
}
注：
1、Subject同時(shí)充當(dāng)了Observer和Observable的角色，Subject是非線程安全的，要避免該問題，需要將 Subject轉(zhuǎn)換為一個(gè) SerializedSubject ，上述RxBus類中把線程非安全的PublishSubject包裝成線程安全的Subject。
2、PublishSubject只會(huì)把在訂閱發(fā)生的時(shí)間點(diǎn)之后來自原始Observable的數(shù)據(jù)發(fā)射給觀察者。
3、ofType操作符只發(fā)射指定類型的數(shù)據(jù)，其內(nèi)部就是filter+cast（這里非常感謝@小鄧子 的提醒）
public final <R> Observable<R> ofType(final Class<R> klass) {
return filter(new Func1<T, Boolean>() {
@Override
public final Boolean call(T t) {
return klass.isInstance(t);
}
}).cast(klass);
}
filter操作符可以使你提供一個(gè)指定的測試數(shù)據(jù)項(xiàng)，只有通過測試的數(shù)據(jù)才會(huì)被“發(fā)射”。
cast操作符可以將一個(gè)Observable轉(zhuǎn)換成指定類型的Observable。
分析：
RxBus工作流程圖
1、首先創(chuàng)建一個(gè)可同時(shí)充當(dāng)Observer和Observable的Subject；
2、在需要接收事件的地方，訂閱該Subject（此時(shí)Subject是作為Observable），在這之后，一旦Subject接收到事件，立即發(fā)射給該訂閱者；
3、在我們需要發(fā)送事件的地方，將事件post至Subject，此時(shí)Subject作為Observer接收到事件（onNext），然后會(huì)發(fā)射給所有訂閱該Subject的訂閱者。
對于RxBus的使用，就和普通的RxJava訂閱事件很相似了。
先看發(fā)送事件的代碼：
RxBus.getDefault().post(new UserEvent (1, "yoyo"));
userEvent是要發(fā)送的事件，如果你用過EventBus, 很容易理解，UserEvent的代碼：
public class UserEvent {
long id;
String name;
public UserEvent(long id,String name) {
this.id= id;
this.name= name;
}
public long getId() {
return id;
}
public String getName() {
return name;
}
}
再看接收事件的代碼：
// rxSubscription是一個(gè)Subscription的全局變量，這段代碼可以在onCreate/onStart等生命周期內(nèi)
rxSubscription = RxBus.getDefault().toObserverable(UserEvent.class)
.subscribe(new Action1<UserEvent>() {
@Override
public void call(UserEvent userEvent) {
long id = userEvent.getId();
String name = userEvent.getName();
...
}
},
new Action1<Throwable>() {
@Override
public void call(Throwable throwable) {
// TODO: 處理異常
}
});
最后，一定要記得在生命周期結(jié)束的地方取消訂閱事件，防止RxJava可能會(huì)引起的內(nèi)存泄漏問題。
@Override
protected void onDestroy() {
super.onDestroy();
if(!rxSubscription.isUnsubscribed()) {
rxSubscription.unsubscribe();
}
}
這樣，一個(gè)簡單的Event Bus就實(shí)現(xiàn)了！如果你的項(xiàng)目已經(jīng)開始使用RxJava，也許可以考慮替換掉EventBus或Otto，減小項(xiàng)目體積。
RxBus、EventBus因?yàn)榻怦钐珡氐?，濫用的話，項(xiàng)目可維護(hù)性會(huì)越來越低；一些簡單場景更推薦用回調(diào)、Subject來代替事件總線。
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
Android結(jié)合kotlin使用coroutine的方法實(shí)例
這篇文章主要給大家介紹了關(guān)于Android結(jié)合kotlin使用coroutine的相關(guān)資料，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-12-12
這篇文章主要介紹了Android中線程的異步處理方式,講解了Looper、Handler和Handler post三種方式,其中Handler自然是重點(diǎn),需要的朋友可以參考下2016-04-04
本文給大家介石介紹下如何利用RecyclerView實(shí)現(xiàn)多Item布局的加載，多Item布局的加載的意思就是在開發(fā)過程中List的每一項(xiàng)可能根據(jù)需求的不同會(huì)加載不同的Layout2016-03-03
這篇文章主要介紹了Android 掃碼槍不使用輸入框獲取掃描值的操作方法,本文給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2021-09-09
Android懸浮窗的實(shí)現(xiàn)(易錯(cuò)點(diǎn))
現(xiàn)在很多應(yīng)用都使用到懸浮窗，例如微信在視頻的時(shí)候，點(diǎn)擊Home鍵，視頻小窗口仍然會(huì)在屏幕上顯示。下面小編來實(shí)現(xiàn)一下android 懸浮窗，感興趣的朋友跟隨小編一起看看吧2019-10-10
Android用注解與反射實(shí)現(xiàn)Butterknife功能
Butterknife是一個(gè)在android上實(shí)現(xiàn)ioc（控制反轉(zhuǎn)）的一個(gè)庫。ioc的核心是解耦。解耦的目的是修改耦合對象時(shí)不影響另外一個(gè)對象，降低模塊之間的關(guān)聯(lián)。在Spring中ioc更多的是依靠xml的配置。而android上的IOC框架可以不使用xml配置2022-11-11
Android基于ImageSwitcher實(shí)現(xiàn)圖片切換功能
這篇文章主要介紹了Android基于ImageSwitcher實(shí)現(xiàn)圖片切換功能的相關(guān)資料,需要的朋友可以參考下2016-02-02
Android 自定義密碼輸入框?qū)崿F(xiàn)代碼
最近做個(gè)項(xiàng)目自定義密碼輸入框功能，下面小編把實(shí)現(xiàn)思路分享到腳本之家平臺(tái)，需要的朋友參考下吧2018-03-03
Android編程調(diào)用Camera和相冊功能詳解
這篇文章主要介紹了Android編程調(diào)用Camera和相冊功能,結(jié)合實(shí)例形式分析了Android的拍照及相冊調(diào)用功能相關(guān)實(shí)現(xiàn)技巧與操作注意事項(xiàng),需要的朋友可以參考下2017-02-02
在Android中，線程內(nèi)部或者線程之間進(jìn)行信息交互時(shí)經(jīng)常會(huì)使用消息，這些基礎(chǔ)的東西如果我們熟悉其內(nèi)部的原理，將會(huì)使我們?nèi)菀?、更好地架?gòu)系統(tǒng)，避免一些低級的錯(cuò)誤,通過本文給大家介紹android消息機(jī)制，感興趣的朋友一起學(xué)習(xí)吧2016-04-04