RxBus的使用

前一阶段，组内做技术分享，我给大家分享了RxJava的使用。在分享的时候，这次分享也是我对RxJava一个快速学习和掌握的过程，分享的时候讲到了RxBus，在此之前我还没有用过RxBus，新项目尝试用一下。用法和EventBus类似，优点是少引入一个jar。
步骤如下：
1.先引入RxJava的jar包，这里只涉及RxJava.
compile 'io.reactivex:rxjava:1.1.9'
2.定义一个RxBus类。
public class RxBus { private static volatile RxBus mInstance; private final Subject<Object, Object> bus; private RxBus() { bus = new SerializedSubject<>(PublishSubject.create()); } //单例RxBus public static RxBus getInstance() { RxBus rxBus = mInstance; if (mInstance == null) { synchronized (RxBus.class) { rxBus = mInstance; if (mInstance == null) { rxBus = new RxBus(); mInstance = rxBus; } } } return rxBus; } // 发送一个新事件 public void send(Object o) { bus.onNext(o); } // 返回特定类型的被观察者 public <T> Observable<T> toObservable(Class<T> eventType) { return bus.ofType(eventType); }}
3.定义一个事件对应的Event
public class CalculateEvent { String result; //计算的结果 public CalculateEvent(String result) { this.result = result; } public String getResult() { return result; } public void setResult(String result) { this.result = result; } @Override public String toString() { return "CalculateEvent{" + "result='" + result + '\'' + '}'; }}
4.发送事件：
RxBus.getInstance().send(new CalculateEvent(""+ 3 * 2));
5.在接收事件的地方要做以下几步：
5.1订阅事件
private CompositeSubscription rxSubscriptions = new CompositeSubscription();
@Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); //订阅下载事件 subscribeDownloadEvent(); }
5.2处理事件
/** * RxBus subscribeDownloadEvent() */ private void subscribeDownloadEvent() { rxSubscriptions.add(RxBus.getInstance().toObservable(CalculateEvent.class) .map(new Func1<Object, CalculateEvent>() { @Override public CalculateEvent call(Object o) { return (CalculateEvent) o; } }) .subscribe(new Action1<CalculateEvent>() { @Override public void call(CalculateEvent calculateEvent) { Log.i(TAG, "MainActivity.call." + calculateEvent.toString()); } })); }
5.3取消订阅，防止内存泄漏
/* * 取消订阅，防止内存泄漏 */ private void unSubscribe() { Log.i(TAG,"MainActivity.unSubscribe."); if (!rxSubscriptions.isUnsubscribed()) { rxSubscriptions.unsubscribe(); } }
在OnDestory方法中去取消。
@Override protected void onDestroy() { super.onDestroy(); //取消订阅 unSubscribe(); }
Demo已经上传到Github上了RxBusDemo