摘要：按照計(jì)劃這一期是要介紹框架結(jié)構(gòu)和設(shè)計(jì)思想的，但是考慮到將在十月底發(fā)布正式版因此決定將框架結(jié)構(gòu)和設(shè)計(jì)思想分析放到正式版發(fā)布后再做。后續(xù)我也會(huì)有一系列的文章來(lái)介紹和的區(qū)別。首選我們需要調(diào)用系統(tǒng)來(lái)獲取所有已安裝的，所以在的方法中調(diào)用。

轉(zhuǎn)載請(qǐng)注明出處：[https://zhuanlan.zhihu.com/p/...

RxJava系列1(簡(jiǎn)介)

RxJava系列2(基本概念及使用介紹)

RxJava系列3(轉(zhuǎn)換操作符)

RxJava系列4(過(guò)濾操作符)

RxJava系列5(組合操作符)

RxJava系列6(從微觀角度解讀RxJava源碼)

RxJava系列7(最佳實(shí)踐)

有點(diǎn)標(biāo)題黨了，其實(shí)談不上什么最佳實(shí)踐。前段時(shí)間公司實(shí)行996，所以也沒(méi)什么時(shí)間和精力來(lái)更新博客（好吧~我承認(rèn)是我懶~）。因此這篇文章只是簡(jiǎn)單的通過(guò)兩個(gè)例子介紹了RxJava在生產(chǎn)環(huán)境中的使用。不過(guò)本篇中的每個(gè)例子我都配上了完整的代碼。

按照計(jì)劃這一期是要介紹RxJava框架結(jié)構(gòu)和設(shè)計(jì)思想的，但是考慮到Netflix將在十月底發(fā)布RxJava2.0正式版；因此決定將RxJava框架結(jié)構(gòu)和設(shè)計(jì)思想分析放到2.0正式版發(fā)布后再做。后續(xù)我也會(huì)有一系列的文章來(lái)介紹RxJava1.x和2.x的區(qū)別。

第一個(gè)例子我們需要在Android設(shè)備上展示已安裝的第三方app列表，關(guān)于環(huán)境搭建、依賴配置、RecyclerView的使用等這些基礎(chǔ)內(nèi)容我就不做陳述了。需要了解的同學(xué)可以去GitHub上把項(xiàng)目clone下來(lái)看看。這里我主要講講如何通過(guò)RxJava實(shí)現(xiàn)核心功能。

首選我們需要調(diào)用系統(tǒng)api來(lái)獲取所有已安裝的app，所以在OnSubscribe的call方法中調(diào)用getApplicationInfoList()。但是getApplicationInfoList()獲取的數(shù)據(jù)并不能完全滿足我們的業(yè)務(wù)需求：

由于我們只需要展示手機(jī)上已安裝的第三方App，因此需要通過(guò)filter操作符來(lái)過(guò)濾掉系統(tǒng)app；

ApplicationInfo并不是我們所需要的類型，因此需要通過(guò)map操作符將其轉(zhuǎn)換為AppInfo；

由于獲取ApplicationInfo、過(guò)濾數(shù)據(jù)、轉(zhuǎn)換數(shù)據(jù)相對(duì)比較耗時(shí)，因此需要通過(guò)subscribeOn操作符將這一系列操作放到子線程中來(lái)處理；

而要將信息展示在頁(yè)面上涉及到UI操作，因此需要通過(guò)observeOn操作符將onNext、onCompleted、onError調(diào)度到主線程，接著我們?cè)谶@些方法中更新UI。

下面是核心代碼：

final PackageManager pm = MainActivity.this.getPackageManager();
Observable.create(new Observable.OnSubscribe() {
        @Override
        public void call(Subscriber subscriber) {
            List infoList = getApplicationInfoList(pm);
            for (ApplicationInfo info : infoList) {
                subscriber.onNext(info);
            }
            subscriber.onCompleted();
        }
    }).filter(new Func1() {
        @Override
        public Boolean call(ApplicationInfo applicationInfo) {
            return (applicationInfo.flags & ApplicationInfo.FLAG_SYSTEM) <= 0;
        }
    }).map(new Func1() {

        @Override
        public AppInfo call(ApplicationInfo applicationInfo) {
            AppInfo info = new AppInfo();
            info.setAppIcon(applicationInfo.loadIcon(pm));
            info.setAppName(applicationInfo.loadLabel(pm).toString());
            return info;
        }
    }).subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(new Subscriber() {
        @Override
        public void onCompleted() {
            mAppListAdapter.notifyDataSetChanged();
            mPullDownSRL.setRefreshing(false);
        }

        @Override
        public void onError(Throwable e) {
            mPullDownSRL.setRefreshing(false);
        }

        @Override
        public void onNext(AppInfo appInfo) {
            mAppInfoList.add(appInfo);
        }
    });

程序執(zhí)行效果圖：

完整的代碼我放到了GitHub上，有興趣大家可以去clone下來(lái)自己運(yùn)行看看。

源碼地址：https://github.com/BaronZ88/HelloRxAndroid

RxJava + Retrofit2幾乎是Android應(yīng)用開(kāi)發(fā)的標(biāo)配了，這個(gè)例子中我們就來(lái)聊聊這二者是如何配合起來(lái)幫助我們快速開(kāi)發(fā)的。

Retrofit2中一個(gè)標(biāo)準(zhǔn)的接口定義是這樣的：

@GET("weather")
Observable getWeather(@Query("cityId") String cityId);

現(xiàn)在有了RxJava，一個(gè)基本的網(wǎng)絡(luò)請(qǐng)求我們便可以這樣實(shí)現(xiàn)：

ApiClient.weatherService.getWeather(cityId)
                 .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Action1() {
                    @Override
                    public void call(Weather weather) {
                        weatherView.displayWeatherInformation(weather);
                    }
                });

但有時(shí)候可能一開(kāi)始我們并不知道cityId，我們只知道cityName。所以就需要我們先訪問(wèn)服務(wù)器，拿到對(duì)應(yīng)城市名的cityId，然后通過(guò)這個(gè)cityId再去獲取天氣數(shù)據(jù)。

同樣的，我們需要定義一個(gè)獲取cityId的接口：

@GET("city")
Observable getCityIdByName(@Query("cityName") String cityName);

緊接著我們便可以使用無(wú)所不能的RxJava來(lái)實(shí)現(xiàn)需求了。

ApiClient.weatherService.getCityIdByName("上海")
             .flatMap(new Func1>() {
                 @Override
                 public Observable call(String cityId) {
                     return ApiClient.weatherService.getWeather(cityId);
                 }
             }).subscribeOn(Schedulers.io())
             .observeOn(AndroidSchedulers.mainThread())
             .subscribe(new Action1() {
                 @Override
                 public void call(Weather weather) {
                     weatherView.displayWeatherInformation(weather);
                 }
             });

哇哦！~ so easy！！！媽媽再也不用擔(dān)心....

源碼地址：https://github.com/BaronZ88/WeatherStyle

WeatherStyle)這個(gè)項(xiàng)目還在開(kāi)發(fā)中，這個(gè)項(xiàng)目不只包含了RxJava和Retrofit的使用，同時(shí)還包含MVP、ORMLite、RetroLambda、ButterKnife等等開(kāi)源庫(kù)的使用

RxJava1.X的系列文章就到此結(jié)束了，由于本人對(duì)RxJava的理解有限，這一系列文章中如有錯(cuò)誤還請(qǐng)大家指正。在使用RxJava過(guò)程中有任何疑問(wèn)也歡迎大家和我交流。共同學(xué)習(xí)！共同進(jìn)步！

好啦，我們RxJava2見(jiàn)！~

如果大家喜歡這一系列的文章，歡迎關(guān)注我的知乎專欄和GitHub。

知乎專欄：https://zhuanlan.zhihu.com/baron

GitHub：https://github.com/BaronZ88