通过RxBus来实现事件的通知和订阅，简化应用组件间的通信,解耦事件的发送者和接收者,避免复杂和容易出错的依赖和生命周期的问题.

1. 依赖方式Dependency

1.1 Maven

com.hanzhifengyun

rxbus

1.0.0

pom

1.2 Gradle

compile 'com.hanzhifengyun:rxbus:1.0.0'

2 如何使用Use

2.1 在合适的时机注册

@Override

protected void onCreate(Bundle savedInstanceState) {

super.onCreate(savedInstanceState);

//在页面创建时订阅

RxBus.getInstance().register(this);

}

2.2 在合适的时机解除注册

@Override

protected void onDestroy() {

super.onDestroy();

//在页面销毁时解除订阅，防止页面销毁后导致内存溢出

RxBus.getInstance().unRegister(this);

}

2.3 如何发送事件

只发送事件code，不包含数据，一般用于通知某一事件的发生

RxBus.getInstance().send(int code);

只发送事件数据，不包含code，一般用于所有关心相同类型数据变化的接收者

RxBus.getInstance().send(Object data);

根据不同code发送事件数据，只有相同的code和数据类型的接收者才能接收到数据

RxBus.getInstance().send(int code, Object data);

2.4 如何接收事件

在已经注册过的类中自定义一个public方法，方法名随意，参数填写需要接收数据的类型.

在方法上添加注解OnSubscribe，表示接收订阅的信息:

code: 用于区分发送的不同事件的标识，int类型

threadType: 标识事件接收时回调在什么线程

2.5 例子：

只关心事件类型，不包含数据

定义事件类型

public static final int CODE_PAY_SUCCESS = 3;//支付成功事件

发送事件

RxBus.getInstance().send(CODE_PAY_SUCCESS);

接收事件，并在UI主线程中消费

@OnSubscribe(code = CODE_PAY_SUCCESS, threadType = ThreadType.UI)

public void onPaySuccess() {

//do something after pay success…

}

只关心事件数据

发送事件，只包含数据

List dataList = new ArrayList<>();

dataList.add("a");

dataList.add("b");

dataList.add("c");

RxBus.getInstance().send(dataList);

接收数据，并在IO子线程中消费

@OnSubscribe(threadType = ThreadType. IO)

public void onDataChanged(List dataList) {

// do something for data…

}

只关心特定的事件类型和特定的数据

定义事件类型

public static final int CODE_LOAD_DATA = 9;//加载数据事件

发送事件

List dataList = new ArrayList<>();

dataList.add("a");

dataList.add("b");

dataList.add("c");

RxBus.getInstance().send(CODE_LOAD_DATA, dataList);

接收数据，并在CURRENT_THREAD当前线程中消费

@OnSubscribe(code = CODE_LOAD_DATA, threadType =

ThreadType. CURRENT_THREAD)

public void onDataChanged(List dataList) {

// do something for data…

}