最近有時間學習些許內容，加上重新寫部落格來記錄自己的學習過程與心得

1.rxjava2 認知

rxjava作為知名的響應式程式設計庫，這半年內極大的火爆開發者中
介紹
Observable 被觀察者
|
|
subscribe() 訂閱
|
|
Observer 觀察者

依賴：
compile ‘io.reactivex.rxjava2:rxjava:2.0.5’
compile ‘io.reactivex.rxjava2:rxandroid:2.0.1’

Observable寫法：以傳送integer為例子

Observable<Integer> observable=Observable.create(new
 
 ObservableOnSubscribe<Integer>() {
            @Override
            public void subscribe(ObservableEmitter<Integer> e) throws Exception {
                e.onNext(1);
                e.onNext(2);
                e.onNext(3);
                e.onComplete();
            }
        });

Observer 寫法：

Observer<Integer> observer=new Observer<Integer>() {
            //自動重寫以下方法
            @Override
            public void onSubscribe(Disposable d) {
                Log.i(TAG, "onSubscribe: ");
            }

            @Override
            public void onNext(Integer integer) {
                Log
 
.i(TAG, "onNext: "+integer);
            }

            @Override
            public void onError(Throwable e) {
                Log.i(TAG, "onError: ");
            }

            @Override
            public void onComplete() {
                Log.i(TAG, "onComplete: ");
            }
        };

訂閱事件

 observable.subscribe(observer);

到了這裡就可以很成功的進行，完成一個完整的通路了

最後進行一站式直接操作

Observable.create(new ObservableOnSubscribe<Integer>() {
            @Override
            public void subscribe(ObservableEmitter<Integer> e) throws Exception 
                e.onNext(1);
                e.onNext(2);
                e.onNext(3);
                e.onComplete();
            }
        }).subscribe(new Observer<Integer>() {
            @Override
            public void onSubscribe(Disposable d) {
                Log.i(TAG, "onSubscribe: ");
            }

            @Override
            public void onNext(Integer integer) {
                Log.i(TAG, "onNext: "+integer);
            }

            @Override
            public void onError(Throwable e) {
                Log.i(TAG, "onError: ");
            }

            @Override
            public void onComplete() {
                Log.i(TAG, "onComplete: ");
            }
        });

只有subscribe()之後才能進行連通

順便介紹下Consumer
如果你只是想處理接收到的資料可以使用Consumer
程式碼如下

Consumer<Integer> consumer = new Consumer<Integer>() {
            @Override
            public void accept(Integer integer) throws Exception {
                Log.i(TAG, "accept: " + integer);
            }
        };

訂閱事件是一樣的，observable不變

 observable.subscribe(consumer);

2.rxjava2非同步
rxjava2的非同步處理真心非常棒
主要在於以下方法

.subscribeOn(Schedulers.newThread())//提供將Observable執行在一個新的執行緒中
.observeOn(AndroidSchedulers.mainThread())//提供將Observer執行在主執行緒中

很輕鬆的剝離非主執行緒執行的操作，很方便的對於網路，資料庫，圖片的處理
執行完整執行程式碼如下：
observable，consumer還是上面的那個
像以下程式碼，如果切換兩次執行緒，那麼

observable.subscribeOn(Schedulers.newThread())//在這個執行緒執行
          .subscribeOn(Schedulers.io())//不執行
          .observeOn(AndroidSchedulers.mainThread())//執行
          .observeOn(Schedulers.io())//切換到這個執行緒
          .subscribe(consumer);
          //這裡我們就可以靈活應用

rxjava2的內建執行緒，四種：
—Schedulers.io() ：io操作的執行緒, 通常用於網路請求,讀寫檔案
—Schedulers.computation()：需要大量計算的操作
—Schedulers.newThread() ：常規的新執行緒
—AndroidSchedulers.mainThread() ：Android的主執行緒