ReactiveX
是一个专注于异步编程与控制可观察数据（或者事件）流的API。它组合了观察者模式，迭代器模式和函数式编程的优秀思想。
实时数据处理是一件普通的现象，有一个高效、干净和可扩展的方式来处理这些情景是重要的。使用 Observables 和 Operators 来熟练操作它们。ReactiveX 提供一个可组合又灵活的 API 来创建和处理数据流，同时简化了异步编程带来的一些担忧，如：线程创建和并发问题。
RxJava 简介
是 ReactiveX 在 Java 上的开源的实现。Observable（观察者） 和 Subscriber（订阅者）是两个主要的类。在 RxJava 上，一个 Observable 是一个发出数据流或者事件的类，Subscriber 是一个对这些发出的 items （数据流或者事件）进行处理（采取行动）的类。一个 Observable 的标准流发出一个或多个 item，然后成功完成或者出错。一个 Observable 可以有多个 Subscribers，并且通过 Observable 发出的每一个 item，该 item 将会被发送到 Subscriber.onNext() 方法来进行处理。一旦 Observable 不再发出 items，它将会调用 Subscriber.onCompleted() 方法，或如果有一个出错的话 Observable 会调用 Subscriber.onError() 方法。
以前我们要想在activity或fragment之间传递信息，我们会通过onActvityResult接收信息。但是这样有一个缺点，一个是代码量太大，重复率太高。二是有时候传递的数据需要经过几个界面的跳转。加入从A->B->C，C界面修改了某些信息，同时，想在A界面进行界面的刷新。那么通过onActvityResult的话很难操作。还有就是，加入从A->B，B传递信息给A界面。以往通过onActvityResult，我们需要在B界面关闭的时候，A界面才能拿到数据，再进行局部刷新，这样的话，A界面很可能会闪烁（数据刷新）。这样的话用户体验感就很差了。
使用方法
首先，附上RxJava/RxAndroid的导包连接，也可以去gitHub上添加最新的版本链接
implementation 'io.reactivex:rxandroid:1.2.1'
implementation 'io.reactivex:rxjava:1.2.4'
首要要创建一个RxBus类，来实现基本的方法封装，下面贴出来一个简单示例：
public class RxBus {
private static volatile RxBus instance;
private Subject<Object , Object> bus;
/**
* PublishSubject只会把在订阅发生的时间点之后来自原始Observable的数据发射给观察者
*/
public RxBus () {
bus = new SerializedSubject<>(PublishSubject.create());
}
public static RxBus getDefault(){
if (instance ==null){
synchronized (RxBus .class){
if (instance == null){
instance = new RxBus ();
}
}
}
return instance;
}
/**
* 发送一个新的事件
* @param object
*/
public void post(Object object){
bus.onNext(object);
}
/**
* 根据传递的 eventType 类型返回特定类型(eventType)的 被观察者
*/
public <T> Observable<T> toObservable(Class<T> eventType){
return bus.ofType(eventType);
}
}
完成上面一个小示例的封装，那么怎么来使用呢？
要在我们使用的位置要进行订阅，添加订阅之后，这样就可以接受其他位置发来的数据data了。
RxBus.getDefault().toObservable(RxBusXunHeBean.class)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread()).subscribe(new Action1<RxBusXunHeBean>() {
@Override
public void call(Bean mBean) {
//此处的bean就是携带数据的实体，可以是你想要的任何数据类型，都是没有问题的。
}
});
携带数据的实体Bean，我就不在此处贴代码了，要是有不懂的话初学者，可以留言或者微信联系我。
最后一步，有了携带数据的实体，又有了接受数据的位置，接下来，就是数据的发送了，因为RxBus中封装了post方法，在此处，我们直接调用就可以了。
public class Test1Activity extends AppCompatActivity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_test1);
initView();
}
private void initView() {
Bean bean= new Bean("android-RxBus","不一样的烟火");
RxBus.getDefault().post(bean);
}
}
以上，就是一个很简单的RxBus的使用方法了，欢迎大家批评指正。
网友评论