1 定义

Rxjava是基于事件流实现异步操作的库

2 解决了什么问题

通过基于事件流的链式调用可以简洁&优雅地实现异步操作
注：在逻辑复杂性越高的情况下，简洁&优雅的特点更突出

3 原理

RxJava 的异步实现，是通过一种扩展的观察者模式来实现的

3.1 4个成员

成员	作用
被观察者（observable）	产生事件
观察者（observer）	接受&响应事件
订阅（subscribe）	连接被观察者&观察者
事件（event）	被观察者 & 观察者沟通的载体

三种事件

Rxjava不仅把每个事件单独处理，还会把他们看做一个队列

事件类型	描述	使用	事件的回调方法
Next	普通事件，将要处理的事件添加到事件队列中	Observable: 可发送无限个Next事件 Observer: 可接受无限个Next事件	onNext()
Complete	事件队列完结，意味着不再发出Next事件	该事件唯一当上游发送了一个onComplete后, 上游onComplete之后的事件将会继续发送, 而下游收到onComplete事件之后将不再继续接收事件	onCompleted()
Error	事件队列异常，意味着处理事件的过程中发生异常、队列终止，不允许再有事件发出	该事件唯一当上游发送了一个onError后, 上游onError之后的事件将继续发送, 而下游收到onError事件之后将不再继续接收事件	onError()

注：onComplete和onError唯一并且互斥

3.2 基本流程

3.3 基本使用

3.3.1 添加依赖

implementation 'io.reactivex.rxjava2:rxandroid:2.0.1'
implementation 'io.reactivex.rxjava2:rxjava:2.0.7'

3.3.2 创建被观察者&产生事件

    //通过create创建被观察者和创建事件序列
    Observable<String> observable = Observable.create(new ObservableOnSubscribe<String>() {
        //定义需要发送的事件序列
        @Override
        public void subscribe(ObservableEmitter<String> e) throws Exception {
            //ObservableEmitter是事件发射器，做了两件事：定义发射事件 & 向观察者发送事件
            e.onNext("菜品1");
            e.onNext("菜品2");
            e.onNext("菜品3");
        }
    });

3.3.3 创建观察者&定义响应事件的行为

    //创建观察者对象
    Observer<String> observer = new Observer<String>() {
        //在接受事件前调用
        @Override
        public void onSubscribe(Disposable d) {
            Log.d(TAG, "开始订阅subscribe");
        }
        //接受被观察者发送的Next事件并响应，
        @Override
        public void onNext(String s) {
            Log.d(TAG, "接收到Next事件:" + s);
        }

        @Override
        public void onError(Throwable e) {
            Log.d(TAG, "接收到onError事件:");
        }

        @Override
        public void onComplete() {
            Log.d(TAG, "接收到onError事件:");

        }
    };

注：除了使用Observer 接口创建观察者，还可以使用Subscriber 抽象类，用法一致，本质上，在订阅subscribe的过程中，Observer总是会先被转换成Subscriber再使用

Subscriber 抽象类对Observer接口进行了扩展，增加了两个方法：
(1) onStart()：在还未响应事件前调用，用于做一些初始化工作
(2) unsubscribe()：用于取消订阅。在该方法被调用后，观察者将不再接收 & 响应事件调用该方法前，先使用 isUnsubscribed() 判断状态，确定被观察者Observable是否还持有观察者Subscriber的引用，如果引用不能及时释放，就会出现内存泄露

3.3.4 通过订阅连接观察者和被观察者

observable.subscribe(observer);

3.3.5 链式调用

将前面的三个步骤串起来

//通过create创建被观察者和创建事件序列
    Observable<String> observable = Observable.create(new ObservableOnSubscribe<String>() {
        //定义需要发送的事件序列
        @Override
        public void subscribe(ObservableEmitter<String> e) throws Exception {
            //ObservableEmitter是事件发射器，做了两件事：定义发射事件 & 向观察者发送事件
            e.onNext("菜品1");
            e.onNext("菜品2");
            e.onNext("菜品3");
        }
    }).subscribe(new Observer<String>() {
       //在接受事件前调用
        @Override
        public void onSubscribe(Disposable d) {
            Log.d(TAG, "开始订阅subscribe");
        }
        //接受被观察者发送的Next事件并响应，
        @Override
        public void onNext(String s) {
            Log.d(TAG, "接收到Next事件:" + s);
        }

        @Override
        public void onError(Throwable e) {
            Log.d(TAG, "接收到onError事件:");
        }

        @Override
        public void onComplete() {
            Log.d(TAG, "接收到onError事件:");

        }
    });

事件接受序列

Rxjava入门