前一階段，組內(nèi)做技術(shù)分享，我給大家分享了RxJava的使用。在分享的時候，這次分享也是我對RxJava一個快速學(xué)習(xí)和掌握的過程，分享的時候講到了RxBus，在此之前我還沒有用過RxBus，新項目嘗試用一下。用法和EventBus類似，優(yōu)點是少引入一個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; } // 發(fā)送一個新事件 public void send(Object o) { bus.onNext(o); } // 返回特定類型的被觀察者 public <T> Observable<T> toObservable(Class<T> eventType) { return bus.ofType(eventType); }}
3.定義一個事件對應(yīng)的Event
public class CalculateEvent { String result; //計算的結(jié)果 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.發(fā)送事件：
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取消訂閱，防止內(nèi)存泄漏
/* * 取消訂閱，防止內(nèi)存泄漏 */ private void unSubscribe() { Log.i(TAG,"MainActivity.unSubscribe."); if (!rxSubscriptions.isUnsubscribed()) { rxSubscriptions.unsubscribe(); } }
在OnDestory方法中去取消。
@Override protected void onDestroy() { super.onDestroy(); //取消訂閱 unSubscribe(); }
Demo已經(jīng)上傳到Github上了RxBusDemo