好久没写博客了，在RxJava火热的环境下，能用RxJava解决的问题都会被RxJava替代。
开始正文，EventBus作为Android消息传递的事件总线，可以很方便的在Activity和Fragment和View间传递消息，很多项目都使用过。用来替代系统广播，替代接口回调简化调用逻辑。而RxBus并不是一个库，是一种RxJava实现EventBus的方案。RxBus的文章有很多，但并没有给出一个成熟可行的实现方案，本文的实现在项目使用中不断改进的成果，有基本稳定保障，通过RxLifecycle绑定生命周期不用手动解除订阅。
先上栗子：https://github.com/wittyneko/rxbus
gif.gif
上图一个Activity页内有两个Fragment，Activity和Fragment，Fragment和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'
调用
JitPack导包方式：
compile 'com.github.wittyneko:rxbus:0.1.0'
发送消息
RxBus.getInstance().send("main", "来自Activity数据");
接收消息
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。
发送消息有多个实现，对应的接收通过setCode和setUri来进行过滤，默认code为0，uri为空字符串。
send
实现
实现很简单，无非就是建立可观察对象单例，接收的地方订阅消息接收。
info
具体的注释有说明，这里进行简单介绍。
-
AbsRxBus是抽象的实现方式，发送和接收的方法在这里实现。 -
RxBus、RxBusBehavior和RxBusReplsy是具体的单例实现，区别在于没有订阅者消息缓存方式。 -
EventBusMsg消息对象，发送的消息最终会以一个EventBusMsg发送出去。 -
EventFilter消息过滤机制，过滤接收消息，如果想加入更多判断可修改此处实现。 -
EventNext消息接收，这里主要是为了防止catch后无法接收消息，没有什么特殊。 -
EventObservableRxBus的接口定义 -
EventSubscribeBuilder构建订阅者，为了方便调用封装RxJava调用逻辑。
本作品采用知识共享署名-非商业性使用-相同方式共享 4.0 国际许可协议进行许可。转载请保留作者及原文链接
