如何使用RxJava实现事件总线EventBus-创新互联
这篇文章给大家分享的是有关如何使用RxJava实现事件总线Event Bus的内容。小编觉得挺实用的,因此分享给大家做个参考,一起跟随小编过来看看吧。
示例:
public class RxBus { private static volatile RxBus defaultInstance; private final Subject
注:
1、Subject同时充当了Observer和Observable的角色,Subject是非线程安全的,要避免该问题,需要将 Subject转换为一个 SerializedSubject ,上述RxBus类中把线程非安全的PublishSubject包装成线程安全的Subject。
2、PublishSubject只会把在订阅发生的时间点之后来自原始Observable的数据发射给观察者。
3、ofType操作符只发射指定类型的数据,其内部就是filter+cast(这里非常感谢@小鄧子 的提醒)
public finalObservable 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://myzitong.com/article/dsohjj.html