事件總線的好處在于方便組件之間的交互，RxBus不是一個庫，而是使用RxJava實現(xiàn)事件總線的一種思想。首先介紹一下RxJava與事件總線的不同之處。

• RxJava使用的是Observable-Observer模式
• 事件總線使用的是Publisher-Subscriber模式

兩者都是使用觀察者模式，但存在一點區(qū)別，Publisher-Subscriber模式的發(fā)布者(Publisher,Observable)關(guān)心的是事件的發(fā)出，并不想知道事件的訂閱者(Subscriber,Observer)是誰。觀察者模式通常會借助于一個中間人，這個中間者即事件總線(EventBus,Otto),在此用RxJava創(chuàng)建中間人RxBus來實現(xiàn)事件總線。

事件總線

package com.android.buttondemo;import rx.Observable; import rx.subjects.PublishSubject; import rx.subjects.SerializedSubject; import rx.subjects.Subject;/*** 事件總線*/ public class RxBus {public static RxBus rxBus = null;public static RxBus getInstance(){if(rxBus == null){rxBus = new RxBus();}return rxBus;}private final Subject<Object,Object> bus = new SerializedSubject<>(PublishSubject.create());/**** 發(fā)送消息*/public void send(Object o){bus.onNext(o);}/**** 接受消息*/public Observable<Object> toObservable(){return bus;}/**** 查看是否有訂閱者*/public boolean hasObserver(){return bus.hasObservers();} }

• Subject充當(dāng)中間人，因為它既做Observable,也做Observer，但是它不是線程安全的，需要用SerializedSubject包裝，讓其線程安全
• PublishSubject只會在事件訂閱發(fā)生之后把來自原始Observable中的數(shù)據(jù)發(fā)送給訂閱者

發(fā)布者

package com.android.buttondemo;import android.content.Intent; import android.support.v7.app.AppCompatActivity; import android.os.Bundle; import android.view.View; import android.widget.Button;public class PublisherActivity extends AppCompatActivity {private Button send;@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.publisher_activiy);RxBus bus = RxBus.getInstance();//Log.d("TAG",String.valueOf(bus.hasObserver()));bus.send("Message");send = (Button) findViewById(R.id.send_button);send.setOnClickListener(new View.OnClickListener() {@Overridepublic void onClick(View v) {Intent intent = new Intent(PublisherActivity.this,SubscriberActivity.class);startActivity(intent);finish();}});} }

訂閱者

package com.android.buttondemo;import android.app.Activity; import android.os.Bundle; import android.util.Log; import android.widget.TextView;import rx.Subscription; import rx.android.schedulers.AndroidSchedulers; import rx.functions.Action1;public class SubscriberActivity extends Activity {private TextView content;private Subscription subscription;@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.subscriber_activity);content = (TextView) findViewById(R.id.content_textView);RxBus bus = RxBus.getInstance();subscription = bus.toObservable().subscribeOn(AndroidSchedulers.mainThread()).observeOn(AndroidSchedulers.mainThread()).subscribe(new Action1<Object>() {@Overridepublic void call(Object o) {Log.d("Thread",Thread.currentThread().getName());}});}/*** 取消訂閱*/@Overrideprotected void onDestroy() {super.onDestroy();if(subscription.isUnsubscribed()){subscription.unsubscribe();}} }

一定記得要取消事件訂閱，防止RxJava引起的內(nèi)存泄漏

總結(jié)

以上是生活随笔為你收集整理的RxJava实现事件总线——RxBus的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。