创新互联建站专注于旌德网站建设服务及定制，我们拥有丰富的企业做网站经验。 热诚为您提供旌德营销型网站建设，旌德网站制作、旌德网页设计、旌德网站官网定制、小程序设计服务，打造旌德网络公司原创品牌,更为您提供
旌德网站排名全网营销落地服务。
这篇文章给大家分享的是有关如何使用RxJava实现事件总线Event Bus的内容。小编觉得挺实用的，因此分享给大家做个参考，一起跟随小编过来看看吧。
示例：
public class RxBus {
private static volatile RxBus defaultInstance;
private final Subject bus;
// PublishSubject只会把在订阅发生的时间点之后来自原始Observable的数据发射给观察者
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 ;
}
// 发送一个新的事件
public void post (Object o) {
bus.onNext(o);
}
// 根据传递的 eventType 类型返回特定类型(eventType)的 被观察者
public Observable toObservable (Class eventType) {
return bus.ofType(eventType);
// 这里感谢小鄧子的提醒: ofType = filter + cast
// return bus.filter(new Func1() {
// @Override
// public Boolean call(Object o) {
// return eventType.isInstance(o);
// }
// }) .cast(eventType);
}
}注：
1、Subject同时充当了Observer和Observable的角色，Subject是非线程安全的，要避免该问题，需要将 Subject转换为一个 SerializedSubject ，上述RxBus类中把线程非安全的PublishSubject包装成线程安全的Subject。
2、PublishSubject只会把在订阅发生的时间点之后来自原始Observable的数据发射给观察者。
3、ofType操作符只发射指定类型的数据，其内部就是filter+cast（这里非常感谢@小鄧子 的提醒）
public final Observable ofType(final Class klass) {
return filter(new Func1() {
@Override
public final Boolean call(T t) {
return klass.isInstance(t);
}
}).cast(klass);
}
filter操作符可以使你提供一个指定的测试数据项，只有通过测试的数据才会被“发射”。
cast操作符可以将一个Observable转换成指定类型的Observable。
分析：
RxBus工作流程图
1、首先创建一个可同时充当Observer和Observable的Subject；
2、在需要接收事件的地方，订阅该Subject（此时Subject是作为Observable），在这之后，一旦Subject接收到事件，立即发射给该订阅者；
3、在我们需要发送事件的地方，将事件post至Subject，此时Subject作为Observer接收到事件（onNext），然后会发射给所有订阅该Subject的订阅者。
对于RxBus的使用，就和普通的RxJava订阅事件很相似了。
先看发送事件的代码：
RxBus.getDefault().post(new UserEvent (1, "yoyo"));
userEvent是要发送的事件，如果你用过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是一个Subscription的全局变量，这段代码可以在onCreate/onStart等生命周期内
rxSubscription = RxBus.getDefault().toObserverable(UserEvent.class)
.subscribe(new Action1() {
@Override
public void call(UserEvent userEvent) {
long id = userEvent.getId();
String name = userEvent.getName();
...
}
},
new Action1() {
@Override
public void call(Throwable throwable) {
// TODO: 处理异常
}
});
最后，一定要记得在生命周期结束的地方取消订阅事件，防止RxJava可能会引起的内存泄漏问题。
@Override
protected void onDestroy() {
super.onDestroy();
if(!rxSubscription.isUnsubscribed()) {
rxSubscription.unsubscribe();
}
}这样，一个简单的Event Bus就实现了！如果你的项目已经开始使用RxJava，也许可以考虑替换掉EventBus或Otto，减小项目体积。
RxBus、EventBus因为解耦太彻底，滥用的话，项目可维护性会越来越低；一些简单场景更推荐用回调、Subject来代替事件总线。
感谢各位的阅读！关于“如何使用RxJava实现事件总线Event Bus”这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，让大家可以学到更多知识，如果觉得文章不错，可以把它分享出去让更多的人看到吧！
网页题目：如何使用RxJava实现事件总线EventBus-创新互联
网站网址：
http://cdkjz.cn/article/dsohjj.html
