創(chuàng)新互聯(lián)建站專注于旌德網(wǎng)站建設(shè)服務(wù)及定制，我們擁有豐富的企業(yè)做網(wǎng)站經(jīng)驗。 熱誠為您提供旌德營銷型網(wǎng)站建設(shè)，旌德網(wǎng)站制作、旌德網(wǎng)頁設(shè)計、旌德網(wǎng)站官網(wǎng)定制、小程序設(shè)計服務(wù)，打造旌德網(wǎng)絡(luò)公司原創(chuàng)品牌,更為您提供旌德網(wǎng)站排名全網(wǎng)營銷落地服務(wù)。

這篇文章給大家分享的是有關(guān)如何使用RxJava實現(xiàn)事件總線Event Bus的內(nèi)容。小編覺得挺實用的，因此分享給大家做個參考，一起跟隨小編過來看看吧。

示例：

public class RxBus {
  private static volatile RxBus defaultInstance;

  private final Subject bus;
  // PublishSubject只會把在訂閱發(fā)生的時間點之后來自原始Observable的數(shù)據(jù)發(fā)射給觀察者
  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 ;
  }
  // 發(fā)送一個新的事件
  public void post (Object o) {
    bus.onNext(o);
  }
  // 根據(jù)傳遞的 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同時充當(dāng)了Observer和Observable的角色，Subject是非線程安全的，要避免該問題，需要將 Subject轉(zhuǎn)換為一個 SerializedSubject ，上述RxBus類中把線程非安全的PublishSubject包裝成線程安全的Subject。

2、PublishSubject只會把在訂閱發(fā)生的時間點之后來自原始Observable的數(shù)據(jù)發(fā)射給觀察者。

3、ofType操作符只發(fā)射指定類型的數(shù)據(jù)，其內(nèi)部就是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操作符可以使你提供一個指定的測試數(shù)據(jù)項，只有通過測試的數(shù)據(jù)才會被“發(fā)射”。

cast操作符可以將一個Observable轉(zhuǎn)換成指定類型的Observable。

分析：

RxBus工作流程圖

1、首先創(chuàng)建一個可同時充當(dāng)Observer和Observable的Subject；

2、在需要接收事件的地方，訂閱該Subject（此時Subject是作為Observable），在這之后，一旦Subject接收到事件，立即發(fā)射給該訂閱者；

3、在我們需要發(fā)送事件的地方，將事件post至Subject，此時Subject作為Observer接收到事件（onNext），然后會發(fā)射給所有訂閱該Subject的訂閱者。

對于RxBus的使用，就和普通的RxJava訂閱事件很相似了。

先看發(fā)送事件的代碼：

RxBus.getDefault().post(new UserEvent (1, "yoyo"));

userEvent是要發(fā)送的事件，如果你用過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等生命周期內(nèi)
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: 處理異常
      }    
    });

最后，一定要記得在生命周期結(jié)束的地方取消訂閱事件，防止RxJava可能會引起的內(nèi)存泄漏問題。

@Override
protected void onDestroy() {
  super.onDestroy();
  if(!rxSubscription.isUnsubscribed()) {
    rxSubscription.unsubscribe();
  }
}

這樣，一個簡單的Event Bus就實現(xiàn)了！如果你的項目已經(jīng)開始使用RxJava，也許可以考慮替換掉EventBus或Otto，減小項目體積。

RxBus、EventBus因為解耦太徹底，濫用的話，項目可維護性會越來越低；一些簡單場景更推薦用回調(diào)、Subject來代替事件總線。

感謝各位的閱讀！關(guān)于“如何使用RxJava實現(xiàn)事件總線Event Bus”這篇文章就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，讓大家可以學(xué)到更多知識，如果覺得文章不錯，可以把它分享出去讓更多的人看到吧！

標(biāo)題名稱：如何使用RxJava實現(xiàn)事件總線EventBus-創(chuàng)新互聯(lián)
分享路徑：http://weahome.cn/article/dsohjj.html