版权所有，转载请注明出处：linzhiyong https://www.jianshu.com/p/559c5e7376a2 https://blog.csdn.net/u012527802/article/details/81117684

本文主要介绍RxJava2是什么、RxJava2的基本使用。
Github：https://github.com/ReactiveX/RxJava
RxDoc：http://reactivex.io/RxJava/2.x/javadoc/
RxJava2Demo：https://github.com/linzhiyong/RxJava2Demo

目录

1. RxJava2介绍
   1.1 什么是RxJava
   1.2 RxJava2与RxJava区别
2. RxJava2操作符介绍
   2.1 创建操作符
   2.2 线程相关操作符
   2.3 事件监听操作符
   2.4 过滤操作符
   2.5 其他操作符
3. 总结

1. RxJava2介绍

1.1 什么是RxJava

Github的介绍

RxJava is a Java VM implementation of Reactive Extensions: a library for composing asynchronous and event-based programs by using observable sequences.
It extends the observer pattern to support sequences of data/events and adds operators that allow you to compose sequences together declaratively while abstracting away concerns about things like low-level threading, synchronization, thread-safety and concurrent data structures.

Google翻译一下

RxJava是一个在Java虚拟机上的响应式扩展：一个用于通过使用可观察序列来编写异步和基于事件的程序的库。
它扩展了观察者模式以支持数据/事件序列，并添加了允许您以声明方式组合序列的运算符，同时抽象出对低级线程，同步，线程安全和并发数据结构等问题的关注。

总结一下，RxJava是基于响应式编程思想，实现并扩展了观察者模式，可以进行异步操作的库。

注：这里简单介绍一下，响应式编程、观察者模式的概念
1、响应式编程，简称RP（Reactive Programming），是一个专注于数据流和变化传递的异步编程范式。一个简单的例子：在Excel中，在A1单元格输入数字，在B1输入数字，设置C1的内容为SUM(A1, B1)，一旦A1或B1数值变化，那么C1将会立即更新；
2、观察者模式，属于行为型模式，又叫发布-订阅(Publish/Subscribe)模式、模型-视图 (Model/View)模式、源-监听器(Source/Listener)模式或从属者(Dependents)模式，作用是定义对象间的一种一对多的依赖关系，当一个对象的状态发生改变时，所有依赖于它的对象都得到通知并被自动更新。例如：拍卖的时候，拍卖师观察最高标价，然后通知给其他竞价者竞价。

1.2 RxJava2与RxJava区别

1、在Rxjava 2中，有一个新的Reactive类型：Flowable，它与Observable很相似，但是有一个关键的不同是，Flowable支持背压 backpressure。支持backpressure，如果事件的消费者不能及时消费生产的事件时可以定义一个处理事件的策略，开发者要自己实现这个事件处理策略。[关于背压]；
2、Rxjava2中onNext设计成限制不能传null；

    /**
     * Signal a normal value.
     * @param value the value to signal, not null
     */
    void onNext(@NonNull T value);

3、增加Single角色，和Observable，Flowable一样会发送数据，不同的是订阅后只能接受到一次；
4、Actions和Functions方法名的修改和次要类的删除；
5、。。。

1.3 RxJava2的角色和事件介绍

RxJava2事件消费者包括Observer、Subscriber、Consumer。其中使用Consumer的话，RxJava内部默认实现Observer/Subscriber，然后在onNext()方法中回调Consumer的accept()。

下面主要介绍一下Emitter、Observer/Subscriber，Emitter接口作为被观察者的事件发射器，有3中事件：onNext、onError、onComplete；Observer/Subscriber作为观察者的事件接收器，两个接口除了名字完全相同，只是为了区分Observable/Flowable的使用，包含4种事件：onSubscribe、onNext、onError、onComplete；

注：onError和onComplete是互斥的事件，一个正确运行的事件序列中, onCompleted和onError只能有一个，并且是事件序列中的最后一个。

看一个订阅的示例

Observable<String> observable = Observable.create(new ObservableOnSubscribe<String>() {
        @Override
        public void subscribe(ObservableEmitter<String> emitter) throws Exception {
            // 使用Emitter事件发射器发射事件
            emitter.onNext("这是事件1");
            emitter.onNext("这是事件2");
//                emitter.onError(new Exception("这里事件发生了异常。"));
            emitter.onNext("这是事件3");
            emitter.onNext("这是事件4");
            emitter.onComplete();
        }
    });

    // 定义观察者，接收事件
    Observer<String> observer = new Observer<String>() {
        @Override
        public void onSubscribe(Disposable d) {
            // 订阅成功回调该方法，返回控制对象
            // d.dispose();
            Log.i(TAG, "--onSubscribe--");
        }
        @Override
        public void onNext(String s) {
            // 这里接收被观察者发出的事件
            Log.i(TAG, "--onNext--" + s);
        }
        @Override
        public void onError(Throwable e) {
            // 错误事件
            Log.i(TAG, "--onError--" + e.getMessage());
        }
        @Override
        public void onComplete() {
            // 完成事件
            Log.i(TAG, "--onComplete--");
        }
    };

    // 观察者订阅被观察者
    observable.subscribe(observer);
}

看一下控制台日志：

I/com.lzy.org.rxjava2.RxJava2Test2: --onSubscribe--
I/com.lzy.org.rxjava2.RxJava2Test2: --onNext--这是事件1
I/com.lzy.org.rxjava2.RxJava2Test2: --onNext--这是事件2
I/com.lzy.org.rxjava2.RxJava2Test2: --onNext--这是事件3
I/com.lzy.org.rxjava2.RxJava2Test2: --onNext--这是事件4
I/com.lzy.org.rxjava2.RxJava2Test2: --onComplete--

2 RxJava2常用操作符介绍

2.1 创建操作符

2.2 线程相关操作符

注：Scheduler类型

2.3 事件监听操作符

2.4 过滤操作符

2.5 其他操作符

还有其他操作符，像onErrorResumeNext、retry、repeat、all、skipWhile等等等，这里就不一一列举了，如果需要，可以去自行查询RxjavaDoc 。

3 总结

本章主要是介绍了RxJava2，比较了与RxJava的差异，还列举了一堆让人看着头疼的操作符，都是些概念性的东西，最关键的是学会如何把RxJava应用到自己的项目中。流行的框架固然好，但是盲目的追风只会导致项目更加难以开发和维护，更不要谈什么效率了。适合你的才是最好的。

下一章节，会具体介绍RxJava2的基本使用方法。