好久沒寫博客了，在RxJava火熱的環(huán)境下萍启，能用RxJava解決的問題都會被RxJava替代总珠。
開始正文，EventBus作為Android消息傳遞的事件總線勘纯，可以很方便的在Activity和Fragment和View間傳遞消息局服，很多項(xiàng)目都使用過。用來替代系統(tǒng)廣播驳遵，替代接口回調(diào)簡化調(diào)用邏輯淫奔。而RxBus并不是一個庫，是一種RxJava實(shí)現(xiàn)EventBus的方案堤结。RxBus的文章有很多唆迁，但并沒有給出一個成熟可行的實(shí)現(xiàn)方案，本文的實(shí)現(xiàn)在項(xiàng)目使用中不斷改進(jìn)的成果竞穷，有基本穩(wěn)定保障唐责，通過RxLifecycle綁定生命周期不用手動解除訂閱。
先上栗子：https://github.com/wittyneko/rxbus
上圖一個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ā)送消息有多個實(shí)現(xiàn)帽衙，對應(yīng)的接收通過setCode和setUri來進(jìn)行過濾，默認(rèn)code為0贞绵，uri為空字符串厉萝。
實(shí)現(xiàn)
實(shí)現(xiàn)很簡單，無非就是建立可觀察對象單例榨崩，接收的地方訂閱消息接收谴垫。
具體的注釋有說明，這里進(jìn)行簡單介紹母蛛。
-
AbsRxBus是抽象的實(shí)現(xiàn)方式翩剪，發(fā)送和接收的方法在這里實(shí)現(xiàn)。 -
RxBus彩郊、RxBusBehavior和RxBusReplsy是具體的單例實(shí)現(xiàn)前弯，區(qū)別在于沒有訂閱者消息緩存方式蚪缀。 -
EventBusMsg消息對象，發(fā)送的消息最終會以一個EventBusMsg發(fā)送出去恕出。 -
EventFilter消息過濾機(jī)制询枚，過濾接收消息，如果想加入更多判斷可修改此處實(shí)現(xiàn)浙巫。 -
EventNext消息接收金蜀，這里主要是為了防止catch后無法接收消息，沒有什么特殊的畴。 -
EventObservableRxBus的接口定義 -
EventSubscribeBuilder構(gòu)建訂閱者渊抄，為了方便調(diào)用封裝RxJava調(diào)用邏輯。
本作品采用知識共享署名-非商業(yè)性使用-相同方式共享 4.0 國際許可協(xié)議進(jìn)行許可苗傅。轉(zhuǎn)載請保留作者及原文鏈接
