Rxjava Rxandroid入門基礎

1.前言

Rxjava官方github位址：https://github.com/ReactiveX/RxJava

Rxandroid官方github位址：https://github.com/ReactiveX/RxAndroid

Rxjava是啥？

官方的解釋是這樣的：

“a library for composing asynchronous and event-based programs using observable sequences for the Java VM”

意思是：一個在 Java VM 上使用可觀測的序列來組成異步的、基于事件的程式的庫

說白了Rxjava就是java語言開發中用于異步操作。一開始可看到Rxjava的時候還以為是一個基于java的一種新的語言，從官方的解釋也可以看出來。Rx并不是一種新的語言，而是一種普通的Java模式，類似于觀察者模式（Observer Pattern），可以将它看作一個普通的Java類庫，是以你可以立即使用RxJava。而RxAndroid是RxJava的一個針對Android平台的擴充，主要用于 Android 開發。

對Rxjava還不明白的可以參考：

給 Android 開發者的 RxJava詳解：http://gank.io/post/560e15be2dca930e00da1083
深入淺出RxJava（一：基礎篇）http://blog.csdn.net/lzyzsd/article/details/41833541

大頭鬼的文章，翻譯的國外的文章，比較早一點，還算詳細。
這一系列呼嘯而過的文章，比較詳細，我很推薦，比較新。 Android RxJava使用介紹（一） Hello

World：http://blog.csdn.net/job_hesc/article/details/45798307

2.Rxjava基本工作流程：

RxJava最核心的兩個東西是Observables（被觀察者，事件源）和Subscribers（觀察者）。Observables發出一系列事件，Subscribers處理這些事件。在Subscribers接受到事件結果之前我們可以很友善地對結果做出各種處理攔截等等。

RxJava 的觀察者模式大緻如下圖：

Rxjava Rxandroid入門基礎Rxjava Rxandroid入門基礎

對于android開發者來說，隻需要在build.gradle檔案中加入:

compile 'io.reactivex:rxandroid:1.2.0'
compile 'io.reactivex:rxjava:1.1.5'

就可以了。

3.Hello World

寫什麼程式都要先來一個hello world，下面就是rxjava的hello world：

private void rxTest(){
        /***************************************正常步驟******************************************/
        /**消息源，被觀察着**/
        Observable <String> myObservable = Observable.create(
                new Observable.OnSubscribe<String>() {
                    @Override
                    public void call(Subscriber<? super String> subscriber) {
                        subscriber.onNext("Hello world!!");
                        subscriber.onCompleted();
                    }
                }
        );
        /**接受處，觀察者**/
        Subscriber<String> mySubscriber = new Subscriber<String>() {
            @Override
            public void onCompleted() {

            }

            @Override
            public void onError(Throwable e) {

            }

            @Override
            public void onNext(String s) {
                Log.d("danxx" ,"onNext--->"+s);
            }
        };
        /**注冊觀察者**/
        myObservable.subscribe(mySubscriber);

        /***************************************簡化步驟******************************************/
        /**Integer類型參數**/
        Observable.just().subscribe(
                new Action1<Integer>() {
                    @Override
                    public void call(Integer integer) {
                        Log.d("danxx" ,"Integer--->"+integer);
                    }
                }
        );
        /**String類型參數**/
        Observable.just("String args").subscribe(
                new Action1<String>() {
                    @Override
                    public void call(String s) {
                        Log.d("danxx" ,"String--->"+s);
                    }
                }
        );

        /***************************************map操作******************************************/
        /**map感覺就是一個中間加工廠，可以把結果做處理，減少觀察者的處理步驟**/
        Observable.just("I am ->")
        .map(new Func1<String, String>() {
            @Override
            public String call(String s) {
                /**map處理結果**/
                return s+"map";
            }
        }).subscribe(new Action1<String>() {
            @Override
            public void call(String s) {
                Log.d("danxx" ,"map 處理後的結果 String--->"+s);
            }
        });
    }

4.Rxjava操作符

上面我們看到了map操作符，其實Observable的create也是操作符，Rxjava操作符其實就是就java中的方法，隻是換了一種稱呼。Rxjava的操作符有很多很多，詳盡的操作符請看官網的說明，當然是英文版的。Rxjava operators位址：http://reactivex.io/documentation/operators.html

下面是大概列舉一下：

Creating Observables(Observable的建立操作符)，比如：Observable.create()、Observable.just()、Observable.from()等等；

Transforming Observables(Observable的轉換操作符)，比如：observable.map()、observable.flatMap()、observable.buffer()等等；

Filtering Observables(Observable的過濾操作符)，比如：observable.filter()、observable.sample()、observable.take()等等；

Combining Observables(Observable的組合操作符)，比如：observable.join()、observable.merge()、observable.combineLatest()等等；

Error Handling Operators(Observable的錯誤處理操作符)，比如:observable.onErrorResumeNext()、observable.retry()等等；

Observable Utility Operators(Observable的功能性操作符)，比如：observable.subscribeOn()、observable.observeOn()、observable.delay()等等；

Conditional and Boolean Operators(Observable的條件操作符)，比如：observable.amb()、observable.contains()、observable.skipUntil()等等；

Mathematical and Aggregate Operators(Observable數學運算及聚合操作符)，比如：observable.count()、observable.reduce()、observable.concat()等等；

其他如observable.toList()、observable.connect()、observable.publish()等等；

呼嘯而過大神有三篇文章來介紹Rxjava操作符：

Android RxJava使用介紹（二） RxJava的操作符：http://blog.csdn.net/job_hesc/article/details/46242117
Android RxJava使用介紹（三） RxJava的操作符：http://blog.csdn.net/job_hesc/article/details/46495281
Android RxJava使用介紹（四） RxJava的操作符：http://blog.csdn.net/job_hesc/article/details/46612015

呼嘯而過大神的四篇文章建議你認真讀完。

5. Rxjava的進階使用

Rxjava的進階用法那就是結合Rxandroid和retrofit網絡請求庫做http等網絡請求，由于retrofit網絡請求并不是異步的，需要自己去開線程異步操作，剛好rxjava就是為java異步而生的，是以Rxjava、Rxandroid和retrofit就很天然地結合到一起了，一起使用可以很好實作MVP這樣的結構設計。

Rxjava既然是為異步而生，當然它也可以處理檔案讀寫，資料庫讀寫，檔案下載下傳等等，之前需要用線程異步實作的，現在都可以用Rxjava了。也許你現在還無法感受到Rxjava的優越之處，下面的demo會慢慢體會到的：

（1）Rxjava讀檔案操作

/**
     * 遞歸周遊記憶體尋找視訊檔案
     * @param f
     * @return
     */
    private Observable<File> listFiles(final File f){
        if(f.isDirectory()){
            return Observable.from(f.listFiles()).flatMap(new Func1<File, Observable<File>>() {
                @Override
                public Observable<File> call(File file) {
                    /**如果是檔案夾就遞歸**/
                    return listFiles(file);
                }
            });
        } else {
            /**是視訊檔案就通知觀察者**/
            if (f.exists() && f.canRead() && FileUtils.isVideo(f)) {
                return Observable.just(f);
            }else{
                /**非視訊檔案就傳回null**/
                return null;
            }
        }
    }
    /**
      * 調用讀取視訊檔案
      * rootFile 可以為記憶體卡根目錄
      */
    private void ReadVideoFileByRxjava(File rootFile) {
        Observable.just(rootFile)
                .flatMap(new Func1<File, Observable<File>>() {
                    @Override
                    public Observable<File> call(File file) {
                        return listFiles(file);
                    }
                })
                .subscribe(
                    new Subscriber<File>() {
                        @Override
                        public void onCompleted() {
                            Log.d("danxx", "onCompleted");
                        }

                        @Override
                        public void onError(Throwable e) {
                        }
                        @Override
                        public void onNext(File file) {
                            String name = file.getName();
                            String size = FileUtils.showFileSize(file.length());
                            String path = file.getPath();
                            /**視訊檔案bean存入到ArrayList**/
                            videoBeans.add(new VideoBean(name, path, size));
                            Log.d("danxx", "name--->" + name);
                        }
                    }
                );
    }

（2）Rxjava做網絡請求

配合Retrofit2.0做http請求：

使用Retrofit需要在build.gradle檔案中加上：

dependencies {
    compile 'com.squareup.retrofit:retrofit:2.0.0-beta2'
    // retrofit 2.0 以後需要自己添加gson和rxjava依賴
    compile 'com.squareup.retrofit:converter-gson:2.0.0-beta2'
    compile 'com.squareup.retrofit:adapter-rxjava:2.0.0-beta2'
    }

MainActivity.java：

public class MainActivity extends AppCompatActivity {

    public String img_classify = "http://www.tngou.net/";

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        getByRxJava();
    }

    private void getByRxJava() {
        Retrofit retrofit = new Retrofit.Builder().baseUrl(img_classify)
                .addConverterFactory(GsonConverterFactory.create())
                .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
                .build();
        APIService service = retrofit.create(APIService.class);
        Observable<MeizhiClassify> observable = service.getMeizhiClassify();
        observable.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Subscriber<MeizhiClassify>() {
                    @Override
                    public void onCompleted() {
                        Toast.makeText(getApplicationContext(),
                                "Completed",
                                Toast.LENGTH_SHORT)
                                .show();
                    }

                    @Override
                    public void onError(Throwable e) {
                        Toast.makeText(getApplicationContext(),
                                "Error:" + e.getMessage(),
                                Toast.LENGTH_SHORT)
                                .show();
                    }

                    @Override
                    public void onNext(MeizhiClassify meizhiClassify) {
                        if (meizhiClassify != null) {
                            Log.d("danxx", "data--->" + meizhiClassify.getTngou().size());
                        }
                    }
                });
    }

}

APIService.java 接口，用于Rxjava與Retrofit之間的連結，當然Retrofit網絡請求也可以不使用Rxjava。

import retrofit.http.GET;
import rx.Observable;

/**
 */
public interface APIService {
    @GET("tnfs/api/classify")
    Observable<MeizhiClassify> getMeizhiClassify();
}

MeizhiClassify.java解析類，就是Gson會把http請求得到的資料序列化成這個類：

import java.util.List;

/**
 * Created by Danxx on 2016/6/13.
 * 圖檔分類bean
 */
public class MeizhiClassify {


    public boolean status;

    public List<TngouEntity> tngou;

    public boolean isStatus() {
        return status;
    }

    public void setStatus(boolean status) {
        this.status = status;
    }

    public List<TngouEntity> getTngou() {
        return tngou;
    }

    public void setTngou(List<TngouEntity> tngou) {
        this.tngou = tngou;
    }

    public static class TngouEntity {
        public String description;
        public int id;
        public String keywords;
        public String name;
        public int seq;
        public String title;

        public String getDescription() {
            return description;
        }

        public void setDescription(String description) {
            this.description = description;
        }


        public void setId(int id) {
            this.id = id;
        }


        public void setKeywords(String keywords) {
            this.keywords = keywords;
        }


        public void setName(String name) {
            this.name = name;
        }

        public void setSeq(int seq) {
            this.seq = seq;
        }

        public void setTitle(String title) {
            this.title = title;
        }
    }
}

6.Tips

有一些大神的文章很好，大家可以去看看：

rxjava_for_android：https://github.com/cn-ljb/rxjava_for_android

Awesome-RxJava：https://github.com/lzyzsd/Awesome-RxJava

Rxjava Rxandroid入門基礎Rxjava Rxandroid入門基礎

Rxjava Rxandroid入門基礎

1.前言

2.Rxjava基本工作流程：

3.Hello World

4.Rxjava操作符

5. Rxjava的進階使用

（1）Rxjava讀檔案操作

（2）Rxjava做網絡請求

6.Tips

繼續閱讀

RxJava 變換、組合、合并操作符

RxJava—操作符（過濾、合并、轉換）RxJava—過濾、合并、轉換

RxJava2和Retrofit2配合使用詳解

Retrofit結合RxJava2使用

RxJava(二：Observable 建立，組合與過濾)

RxJava學習筆記之Subscription

RxJava+Retrofit+OkHttp深入淺出-mvp（使用篇）RxJava+Retrofit+OkHttp深入淺出-mvp（使用篇）

retrofit+RxJava+okhttp簡便封裝實作網絡請求（詳解）寫在開頭寫在後面

項目中關于Retrofit2.0+RxJava＋OkHttp的封裝和使用

手寫Rxjava+Retrofit+Mvp手寫Rxjava+Retrofit+Mvp

RxJava學習筆記Rxjava 的原理

RxJava 學習筆記

Rxjava學習筆記

Rxjava的學習筆記Rxjava的學習筆記

RXJava學習筆記（3）

RxJava 學習筆記二