好久沒寫博客了，在RxJava火熱的環(huán)境下，能用RxJava解決的問題都會被RxJava替代。
開始正文，EventBus作為Android消息傳遞的事件總線，可以很方便的在Activity和Fragment和View間傳遞消息，很多項目都使用過。用來替代系統(tǒng)廣播，替代接口回調(diào)簡化調(diào)用邏輯。而RxBus并不是一個庫，是一種RxJava實現(xiàn)EventBus的方案。RxBus的文章有很多，但并沒有給出一個成熟可行的實現(xiàn)方案，本文的實現(xiàn)在項目使用中不斷改進的成果，有基本穩(wěn)定保障，通過RxLifecycle綁定生命周期不用手動解除訂閱。
先上栗子：https://github.com/wittyneko/rxbus
gif.gif
上圖一個Activity頁內(nèi)有兩個Fragment，Activity和Fragment，F(xiàn)ragment和Fragment間消息事件傳遞。
依懶庫
//RxJava
compile 'io.reactivex:rxjava:1.1.6'
compile 'io.reactivex:rxandroid:1.2.1'
//RxLifecycle管理Rx的生命周期
compile 'com.trello:rxlifecycle:0.6.1'
compile 'com.trello:rxlifecycle-components:0.6.1'
//compile 'com.trello:rxlifecycle-kotlin:0.6.1'
調(diào)用
JitPack導(dǎo)包方式：
compile 'com.github.wittyneko:rxbus:0.1.0'
發(fā)送消息
RxBus.getInstance().send("main", "來自Activity數(shù)據(jù)");
接收消息
RxBus.getInstance().with(this)
.setCode(EventBusMsg.EMPTY) //過濾接收code
.setUri("main") //過濾接收uri
.observeOn(AndroidSchedulers.mainThread())
.onNext(new Action1<EventBusMsg<String>>() {
@Override
public void call(EventBusMsg<String> msg) {
mBinding.mainTv.setText(msg.getContent());
Toast.makeText(getApplication(), "收到：" + msg.getUri() + "，消息：" + msg.getContent(), Toast.LENGTH_SHORT).show();
}
})
采用RxLifecycle綁定生命周期，所以Activity和Fragment必須繼承RxAppCompatActivity或RxFragment。
發(fā)送消息有多個實現(xiàn)，對應(yīng)的接收通過setCode和setUri來進行過濾，默認(rèn)code為0，uri為空字符串。
send
實現(xiàn)
實現(xiàn)很簡單，無非就是建立可觀察對象單例，接收的地方訂閱消息接收。
info
具體的注釋有說明，這里進行簡單介紹。
-
AbsRxBus是抽象的實現(xiàn)方式，發(fā)送和接收的方法在這里實現(xiàn)。 -
RxBus、RxBusBehavior和RxBusReplsy是具體的單例實現(xiàn)，區(qū)別在于沒有訂閱者消息緩存方式。 -
EventBusMsg消息對象，發(fā)送的消息最終會以一個EventBusMsg發(fā)送出去。 -
EventFilter消息過濾機制，過濾接收消息，如果想加入更多判斷可修改此處實現(xiàn)。 -
EventNext消息接收，這里主要是為了防止catch后無法接收消息，沒有什么特殊。 -
EventObservableRxBus的接口定義 -
EventSubscribeBuilder構(gòu)建訂閱者，為了方便調(diào)用封裝RxJava調(diào)用邏輯。
本作品采用知識共享署名-非商業(yè)性使用-相同方式共享 4.0 國際許可協(xié)議進行許可。轉(zhuǎn)載請保留作者及原文鏈接
