原文地址
什么是Eventbus
EventBus定義：是一個(gè)發(fā)布 / 訂閱的事件總線挤聘。 這么說(shuō)應(yīng)該包含4個(gè)成分：發(fā)布者舷手，訂閱者着倾，事件拾酝，總線。 那么這四者的關(guān)系是什么呢屈呕？ 很明顯：訂閱者訂閱事件到總線微宝，發(fā)送者發(fā)布事件棺亭。
總結(jié)一下就是：我訂閱你虎眨，你遇到事情了，發(fā)送事件，或者理解為更新動(dòng)態(tài)嗽桩，我就收到消息岳守。
常用的地方
Eventbus和Rxbus常用于組件間信息的交換與通知，避免采用廣播以及使用一大堆接口來(lái)實(shí)現(xiàn)碌冶。
使用的地方以本次項(xiàng)目來(lái)舉例： 一個(gè)商城界面湿痢，包含一個(gè)RecyclerView和LinearLayout，LinearLayout中是一個(gè)購(gòu)物籃信息扑庞，也就是美團(tuán)那種譬重。當(dāng)點(diǎn)擊RecyclerView中的按鈕時(shí)，商品被添加罐氨，LinearLayout中的商品總價(jià)應(yīng)該發(fā)生變化臀规。而這時(shí)候就到了使用Eventbus或者Rxbus的時(shí)候了。 為了增加商品總價(jià)栅隐，常見(jiàn)的方法有這幾種： 1. 在創(chuàng)建adapter的時(shí)候?qū)inearLayout的對(duì)象一并傳入塔嬉，以此可以更改LinearLayout中的TextView 2. 設(shè)置廣播事件。添加商品-》發(fā)送廣播-》處理廣播 3. 設(shè)置接口租悄。添加商品-》觸發(fā)接口 4. 使用觀察者模式谨究。也就是Eventbus以及Rxbus實(shí)現(xiàn)的功能。
以上部分抄自一個(gè)網(wǎng)友泣棋，有的時(shí)候知道怎么回事就是寫不出來(lái)胶哲；好坑,不多說(shuō)了直接上代碼
public class RxBus {
private static volatile RxBus defaultInstance;
// 主題
private final Subject bus;
// PublishSubject只會(huì)把在訂閱發(fā)生的時(shí)間點(diǎn)之后來(lái)自原始Observable的數(shù)據(jù)發(fā)射給觀察者
public RxBus() {
bus = new SerializedSubject<>(PublishSubject.create());
}
// 單例RxBus
public static RxBus getDefault() {
RxBus rxBus = defaultInstance;
if (defaultInstance == null) {
synchronized (RxBus.class) {
rxBus = defaultInstance;
if (defaultInstance == null) {
rxBus = new RxBus();
defaultInstance = rxBus;
}
}
}
return rxBus;
}
// 提供了一個(gè)新的事件
public void post (Object o) {
bus.onNext(o);
}
// 根據(jù)傳遞的 eventType 類型返回特定類型(eventType)的 被觀察者
public <T> Observable<T> toObserverable (Class<T> eventType) {
return bus.ofType(eventType);
}
}
自定義event 實(shí)現(xiàn)數(shù)據(jù)拆分
public class RxEvent {
public int reciveType;
public int eventType;
public String eventAction;
public Object event;
public RxEvent() {
}
/**
* RxBus 事件
* @param reciveType 接收者類型
* @param eventType 事件類型
* @param eventAction 事件Action
* @param event 時(shí)間
*/
public RxEvent(int reciveType, int eventType, String eventAction, Object event) {
this.reciveType = reciveType;
this.eventType = eventType;
this.eventAction = eventAction;
this.event = event;
}
public Object getEvent() {
return event;
}
}
在項(xiàng)目中的使用,注意要在activity或者是fragment的start中注冊(cè)Subscription觀察者事件，并且在onDestroy中將解除注銷事件外傅，在android中使用過(guò)程中可以結(jié)合Rxandroid一起使用纪吮，
Subscription rxMainBus = RxBus.getDefault().toObserverable(RxEvent.class)
.filter(rxEvent -> {
//此處可以通過(guò)Rxjava的filter過(guò)濾函數(shù)對(duì)數(shù)據(jù)進(jìn)行過(guò)濾，從而得到自己想要的數(shù)據(jù)
if ((rxEvent.reciveType == IStatics.DATA_BROADCAST ||
rxEvent.reciveType ==IStatics.DATA_ALL) && (rxEvent.eventType ==
IStatics.EVENT_MAIN || rxEvent.eventType ==IStatics.EVENT_ALL_THREAD)) {
return true;
}
return false;
})
//.observeOn(Schedulers.computation())//可以設(shè)置為子線程中接收數(shù)據(jù)
.observeOn(AndroidSchedulers.mainThread())//設(shè)置為主線程接收數(shù)據(jù)
.subscribe(new Action1<RxEvent>() {
@Override
public void call(RxEvent rxEvent) {
switch (rxEvent.eventAction) {
//此處可以根據(jù)事件類型分析數(shù)據(jù)萎胰，一對(duì)應(yīng)不同的操作
}
}
},
new Action1<Throwable>() {
@Override
public void call(Throwable throwable) {
// TODO: 處理異常
}
});
特別注意的是一定要在onDestroy中解除事件的注銷碾盟，以保證不出現(xiàn)內(nèi)存泄漏
if (rxMainBus != null && !rxMainBus.isUnsubscribed()) { rxMainBus.unsubscribe();}
