//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();
}
})
发送消息有多个实现,对应的接收通过setCode
和setUri
来进行过滤,默认code为0,uri为空字符串。
实现很简单,无非就是建立可观察对象单例,接收的地方订阅消息接收。
具体的注释有说明,这里进行简单介绍。
AbsRxBus
是抽象的实现方式,发送和接收的方法在这里实现。RxBus
、RxBusBehavior
和RxBusReplsy
是具体的单例实现,区别在于没有订阅者消息缓存方式。EventBusMsg
消息对象,发送的消息最终会以一个EventBusMsg发送出去。EventFilter
消息过滤机制,过滤接收消息,如果想加入更多判断可修改此处实现。EventNext
消息接收,这里主要是为了防止catch后无法接收消息,没有什么特殊。EventObservable
RxBus的接口定义EventSubscribeBuilder
构建订阅者,为了方便调用封装RxJava调用逻辑。