RxJava目前已经很火了，如果你尚未了解请看这里。对于RxJava这里不多做介绍。

RxBus并不是一个库，而是一种模式。相信大多数开发者都使用过EventBus，作为事件总线通信库，如果你的项目已经加入RxJava和EventBus，不妨用RxBus代替EventBus，以减少库的依赖。

一、添加RxJava和RxAndroid依赖

//RxJava and RxAndroid

compile 'io.reactivex:rxandroid:1.1.0'

compile 'io.reactivex:rxjava:1.1.0'

二、新建RxBus类

不多说直接上代码：

import rx.Observable;

import rx.subjects.PublishSubject;

import rx.subjects.SerializedSubject;

import rx.subjects.Subject;

/**

* Created by xialo on 2016/6/28.

*/

public class RxBus {

private static volatile RxBus mInstance;

private final Subject bus;

public RxBus()

{

bus = new SerializedSubject<>(PublishSubject.create());

}

/**

* 单例模式RxBus

*

* @return

*/

public static RxBus getInstance()

{

RxBus rxBus2 = mInstance;

if (mInstance == null)

{

synchronized (RxBus.class)

{

rxBus2 = mInstance;

if (mInstance == null)

{

rxBus2 = new RxBus();

mInstance = rxBus2;

}

}

}

return rxBus2;

}

/**

* 发送消息

*

* @param object

*/

public void post(Object object)

{

bus.onNext(object);

}

/**

* 接收消息

*

* @param eventType

* @param

* @return

*/

public Observable toObserverable(Class eventType)

{

return bus.ofType(eventType);

}

}

1、Subject同时充当了Observer和Observable的角色，Subject是非线程安全的，要避免该问题，需要将 Subject转换为一个 SerializedSubject，上述RxBus类中把线程非安全的PublishSubject包装成线程安全的Subject。

2、PublishSubject只会把在订阅发生的时间点之后来自原始Observable的数据发射给观察者。

3、ofType操作符只发射指定类型的数据，其内部就是filter+cast

三、创建你需要发送的事件类

我们这里用StudentEvent举例

/**

* Created by xialo on 2016/6/28.

*/

public class StudentEvent {

private String id;

private String name;

public StudentEvent(String id, String name) {

this.id = id;

this.name = name;

}

public String getId() {

return id;

}

public void setId(String id) {

this.id = id;

}

public String getName() {

return name;

}

public void setName(String name) {

this.name = name;

}

}

四、发送事件

RxBus.getInstance().post(new StudentEvent("007","小明"));

五、接收事件

rxSbscription=RxBus.getInstance().toObserverable(StudentEvent.class)

.subscribe(new Action1() {

@Override

public void call(StudentEvent studentEvent) {

textView.setText("id:"+ studentEvent.getId()+" name:"+ studentEvent.getName());

}

});

注：rxSbscription是Sbscription的对象，我们这里把RxBus.getInstance().toObserverable(StudentEvent.class)赋值给rxSbscription以方便生命周期结束时取消订阅事件

六、取消订阅

@Override

protected void onDestroy() {

if (!rxSbscription.isUnsubscribed()){

rxSbscription.unsubscribe();

}

super.onDestroy();

}