前言:之前一直有聽過RxJava，但是從來沒去用過也沒了解過，所以打算全面了解學(xué)習(xí)下這個(gè)比較流行前言的框架，本篇主要是講解RxJava的基礎(chǔ)知識(shí)，記錄一下api使用，以后查看方便。

解釋：RxJava 是一個(gè) 基于事件流、實(shí)現(xiàn)異步操作的庫.

特點(diǎn)：由于 RxJava的使用方式是：基于事件流的鏈?zhǔn)秸{(diào)用，所以使得 RxJava： 邏輯簡潔、實(shí)現(xiàn)優(yōu)雅、使用簡單。更重要的是，隨著程序邏輯的復(fù)雜性提高，它依然能夠保持簡潔 & 優(yōu)雅

原理介紹：

即RxJava原理可總結(jié)為：被觀察者 （Observable） 通過 訂閱（Subscribe） 按順序發(fā)送事件 給觀察者 （Observer）， 觀察者（Observer） 按順序接收事件 & 作出對(duì)應(yīng)的響應(yīng)動(dòng)

1.首先怎么創(chuàng)建一個(gè)被觀察者 & 生產(chǎn)事件，最簡單的實(shí)現(xiàn)：

//創(chuàng)建了一個(gè)Observable被觀察者通過e.onNext(1);e.onNext(2);e.onNext(3);來發(fā)送事件1，2，3

Observable.create(new ObservableOnSubscribe<Integer>() {
            @Override
            public void subscribe(ObservableEmitter<Integer> e) throws Exception {
                e.onNext(1);
                e.onNext(2);
                e.onNext(3);
            }
        })
        
 //也可以通過其他方式來創(chuàng)建，下篇文章我會(huì)詳細(xì)講解下具體的api來創(chuàng)建被觀察者       
 //組合方式
 Observable.mergeArray(
                Observable.intervalRange(0,3,1,1,TimeUnit.SECONDS),
                Observable.intervalRange(3,3,1,1,TimeUnit.SECONDS),
                Observable.intervalRange(6,3,1,1,TimeUnit.SECONDS),
                Observable.intervalRange(6,3,1,1,TimeUnit.SECONDS)).subscribe(new Consumer<Long>() {
            @Override
            public void accept(Long aLong) throws Exception {
                Log.d(TAG, "接收到了事件"+ aLong);
            }
        })
//just(T...)：直接將傳入的參數(shù)依次發(fā)送出來 
Observable.just(1,2,3,4).reduce(new BiFunction<Integer, Integer, Integer>() {
            @Override
            public Integer apply(Integer integer, Integer integer2) throws Exception {
                Log.e(TAG, "本次計(jì)算的數(shù)據(jù)是： "+integer2 +"  乘 "+ integer);
                return integer*integer2;
            }
        })        
        

2.創(chuàng)建觀察者（observer）來接受響應(yīng)事件,具體的也是有很多api

//方式一：使用直接new observer接口的方式，
new Observer<String>() {
            //該方法是在observer接收事件之前，最先回調(diào)回來的
            @Override
            public void onSubscribe(Disposable d) {
                Log.d(TAG,"onSubscribe 線程: "+Thread.currentThread().getName());
            }
              //該方法是在被觀察者發(fā)送onNext事件時(shí)，接收的事件回調(diào)，做出響應(yīng)
            @Override
            public void onNext(String s) {
                Log.d(TAG,"onNext 線程: "+Thread.currentThread().getName());

            }
              //該方法是在被觀察者發(fā)送onError事件時(shí)，接收的事件回調(diào)，做出響應(yīng)
            @Override
            public void onError(Throwable e) {
                Log.d(TAG,"onError 線程: "+Thread.currentThread().getName());
            }
              //該方法是在被觀察者發(fā)送onComplete事件時(shí)，接收的事件回調(diào)，做出響應(yīng)
            @Override
            public void onComplete() {
                Log.d(TAG,"onComplete 線程: "+Thread.currentThread().getName());
            }
        })

//方式二:使用直接new Consumer接口的方式，
new Consumer<Integer>() {
             //accept是接收回調(diào)的事件響應(yīng)
           @Override
           public void accept(Integer integer) throws Exception {
               Log.d(TAG,"結(jié)果： "+integer);
           }
       })
       

3.訂閱(subscribe)鏈接被觀察者和觀察者之間的橋梁

observable.subscribe(observer);

4.基于上面的知識(shí)點(diǎn)我們下面來具體創(chuàng)建一個(gè)工程來編寫下具體的代碼

4.1.首先在app的build.gradle文件中加入如下依賴：

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

4.2.創(chuàng)建一個(gè)Activity類，來編寫代碼

/**
 * wuminjian 2018.4.27
 */
public class MainTwoActivity extends Activity {
    public static final String TAG = "MainTwoActivity";

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.layout_dianzhan11111);
        AppSettings.getInstance(MainTwoActivity.this);

        testRxJava();
    }

    private void testRxJava() {
        Observable.create(new ObservableOnSubscribe<String>() {
            @Override
            public void subscribe(ObservableEmitter<String> e) throws Exception {
                //在這個(gè)方法里面開始向外發(fā)射事件
                e.onNext("hello");
                e.onNext("RxJava");
                e.onComplete();
            }
        }).subscribe(new Observer<String>() {
            @Override
            public void onSubscribe(Disposable d) {
                Log.d(TAG, "開始采用subscribe連接");
            }

            @Override
            public void onNext(String s) {
                Log.d(TAG,"接收結(jié)果："+s);
            }

            @Override
            public void onError(Throwable e) {
                Log.d(TAG, "對(duì)Error事件作出響應(yīng)");
            }

            @Override
            public void onComplete() {
                Log.d(TAG, "對(duì)Complete事件作出響應(yīng)");
            }
        });
    }
}

打印結(jié)果

04-26 19:58:53.100 11189-11189/? D/MainTwoActivity: 開始采用subscribe連接
04-26 19:58:53.100 11189-11189/? D/MainTwoActivity: 接收結(jié)果：hello
04-26 19:58:53.100 11189-11189/? D/MainTwoActivity: 接收結(jié)果：RxJava
04-26 19:58:53.100 11189-11189/? D/MainTwoActivity: 對(duì)Complete事件作出響應(yīng)

看以上代碼RxJava代碼是不是一條鏈?zhǔn)较聛淼哪Ｊ?，結(jié)構(gòu)很清晰，優(yōu)雅。以上主要介紹下RxJava的基本知識(shí)和具體簡單的使用，下篇文章將介紹下具體的api使用詳解。