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

圖片來(lái)自網(wǎng)絡(luò)

轉(zhuǎn)載請(qǐng)注明出處：http://www.itdecent.cn/p/b0d8d3a5d3fc

前言

有點(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ū)別。

示例一、獲取手機(jī)上已安裝的App

第一個(gè)例子我們需要在Android設(shè)備上展示已安裝的第三方app列表，關(guān)于環(huán)境搭建、依賴(lài)配置、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ù)并不能完全滿(mǎn)足我們的業(yè)務(wù)需求：

  1. 由于我們只需要展示手機(jī)上已安裝的第三方App，因此需要通過(guò)filter操作符來(lái)過(guò)濾掉系統(tǒng)app；
  2. ApplicationInfo并不是我們所需要的類(lèi)型，因此需要通過(guò)map操作符將其轉(zhuǎn)換為AppInfo；
  3. 由于獲取ApplicationInfo、過(guò)濾數(shù)據(jù)、轉(zhuǎn)換數(shù)據(jù)相對(duì)比較耗時(shí)，因此需要通過(guò)subscribeOn操作符將這一系列操作放到子線(xiàn)程中來(lái)處理；
  4. 而要將信息展示在頁(yè)面上涉及到UI操作，因此需要通過(guò)observeOn操作符將onNext、onCompleted、onError調(diào)度到主線(xiàn)程，接著我們?cè)谶@些方法中更新UI。

下面是核心代碼：

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

        @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<AppInfo>() {
        @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實(shí)現(xiàn)獲取天氣數(shù)據(jù)

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<Weather> 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<Weather>() {
                    @Override
                    public void call(Weather weather) {
                        weatherView.displayWeatherInformation(weather);
                    }
                });

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

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

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

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

ApiClient.weatherService.getCityIdByName("上海")
             .flatMap(new Func1<String, Observable<Weather>>() {
                 @Override
                 public Observable<Weather> call(String cityId) {
                     return ApiClient.weatherService.getWeather(cityId);
                 }
             }).subscribeOn(Schedulers.io())
             .observeOn(AndroidSchedulers.mainThread())
             .subscribe(new Action1<Weather>() {
                 @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)注我的知乎專(zhuān)欄、GitHub、簡(jiǎn)書(shū)博客。

最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀(guān)點(diǎn)，簡(jiǎn)書(shū)系信息發(fā)布平臺(tái)，僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容