汉兰达xJava2 实战种类文章

LacrossexJava2 实战知识梳理(1) – 后台执行耗费时间操作,实时通报 UI
更新

奇骏xJava2 实战知识梳理(2) –
总计一段时间内数据的平均值

索罗德xJava2 实战知识梳理(3) –
优化搜索联想功用

MuranoxJava2 实战知识梳理(4) – 结合 Retrofit
请求音信资源新闻

SportagexJava2 实战知识梳理(5) –
简单及进阶的轮询操作

大切诺基xJava2 实战知识梳理(6) –
基于错误类型的重试请求

福睿斯xJava2 实战知识梳理(7) – 基于 combineLatest
完成的输入表单验证

TucsonxJava2 实战知识梳理(8) – 使用 publish + merge
优化先加载缓存,再读取互连网数据的乞请进程

RxJava2 实战知识梳理(9) – 使用 timer/interval/delay
完成义务调度

LacrossexJava2 实战知识梳理(10) – 荧屏旋转导致 Activity
重建时上涨义务

EnclavexJava2 实战知识梳理(11) –
检查和测试互联网状态并机关心保护试请求

卡宴xJava2 实战知识梳理(12) – 实战讲解 publish & replay & share & refCount
& autoConnect

福睿斯xJava2 实战知识梳理(13) –
如何使得错误发生时不自行终止订阅关系

OdysseyxJava2 实战知识梳理(14) – 在 token 过期时,刷新过期 token
并再一次发起呼吁

CRUISERxJava2 实战知识梳理(15) – 完成四个简单易行的 MVP + EscortxJava + Retrofit
应用


壹 、应用背景

今天,大家以贰个请求天气数据的例子,来演示怎么着用RxJava落到实处互连网重连时的机关请求,首先,大家对这么些须要实行多个简单的叙述,整个项指标框架如下所示:

图片 1

总体框架图

  • 在选择运维时,大家会运转定位模块,该定位模块在后台每隔一段时间发起二遍定位请求,获得一定的结果后,大家透过该城市向服务器发起呼吁,以获得对应城市的天气消息举办展示。
  • 但是在获得城市之后向服务器请求天气的长河中有也许是处于没有互联网的事态,导致力不从心获得城市的天气消息并刷新界面,因而,我们须求检查和测试网络的情状,在互联网重连的时候,读取上一遍缓存的城市,向服务器发起呼吁以拿到城市相应天气消息。

正文的以身作则代码在
RxSample
的第拾一章中。

二、示例

2.1 定位模块

咱俩由此二个后台线程来效仿定位的进度,它每隔一段时间获取一次定位的结果,并将该结果通过mCityPublish发送数据给它的订阅者。

    //用于发布定位到的城市结果。
    private PublishSubject<Long> mCityPublish;

    //模拟定位模块的回调。
    private void startUpdateLocation() {
        mLocationThread = new Thread() {
            @Override
            public void run() {
                while (true) {
                    try {
                        for (long cityId : CITY_ARRAY) {
                            if (isInterrupted()) {
                                break;
                            }
                            Log.d(TAG, "重新定位");
                            Thread.sleep(5000);
                            Log.d(TAG, "定位到城市信息=" + cityId);
                            mCityPublish.onNext(cityId);
                        }
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        };
        mLocationThread.start();
    }

mCityPublish出殡消息到订阅者收到消息之间,大家还亟需做一些相当的拍卖:

    private Observable<Long> getCityPublish() {
        return mCityPublish.distinctUntilChanged().doOnNext(new Consumer<Long>() {

            @Override
            public void accept(Long aLong) throws Exception {
                saveCacheCity(aLong);
            }

        });
    }

那边我们做了两步处理:

  • 使用distinctUntilChanged对一定结果实行过滤,如果本次定位的结果和上次一直的结果同样,那么不通报订阅者。distinctUntilChanged的规律图如下所示:

    图片 2

  • 使用doOnNext,在回来结果给订阅者在此之前,先把最新二遍的定位结果存款和储蓄起来,用于在将来网络重连之后展开呼吁。

2.2 互联网状态模块

与定位模块类似,大家也亟需多个mNetStatusPublish,其项目为PublishSubject,它在网络状态发生变化时通报订阅者。那里需求注册3个广播,在收受广播之后,我们由此mNetStatusPublish照会订阅者,代码如下:

    private void registerBroadcast() {
        mReceiver = new BroadcastReceiver() {

            @Override
            public void onReceive(Context context, Intent intent) {
                if (mNetStatusPublish != null) {
                    mNetStatusPublish.onNext(isNetworkConnected());
                }
            }

        };
        IntentFilter filter = new IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION);
        registerReceiver(mReceiver, filter);
    }

在接到网络状态变化的音信之后:

   private Observable<Long> getNetStatusPublish() {
        return mNetStatusPublish.filter(new Predicate<Boolean>() {

            @Override
            public boolean test(Boolean aBoolean) throws Exception {
                return aBoolean && getCacheCity() > 0;
            }

        }).map(new Function<Boolean, Long>() {

            @Override
            public Long apply(Boolean aBoolean) throws Exception {
                return getCacheCity();
            }

        }).subscribeOn(Schedulers.io());
    }

此地大家做了两步处理:

  • 使用filter对音信实行过滤,唯有在
    联网状态还要从前早已定位到了都市
    之后才通告订阅者,filter的法则图如下所示,该操作符用于过滤掉一部分不需求的数额:

    图片 3

  • 使用map,读取当前缓存的城市名,再次回到给订阅者,map的法则图如下所示,该操作符能够用来实践变换操作。

    图片 4

2.3 网络请求模块

2.12.2中,大家独家用getCityPublish()getNetStatusPublish()来拿到被订阅者,它们分别对应于固定模块和网络状态模块发生变化时所发送的城市数据,下边来看大家经过城市数量获得城市气象新闻的代码:

    private void startUpdateWeather() {
        Observable.merge(getCityPublish(), getNetStatusPublish()).flatMap(new Function<Long, ObservableSource<WeatherEntity>>() {

            @Override
            public ObservableSource<WeatherEntity> apply(Long aLong) throws Exception {
                Log.d(TAG, "尝试请求天气信息=" + aLong);
                return getWeather(aLong).subscribeOn(Schedulers.io());
            }

        }).retryWhen(new Function<Observable<Throwable>, ObservableSource<?>>() {

            @Override
            public ObservableSource<?> apply(Observable<Throwable> throwableObservable) throws Exception {
                return throwableObservable.flatMap(new Function<Throwable, ObservableSource<?>>() {

                    @Override
                    public ObservableSource<?> apply(Throwable throwable) throws Exception {
                        Log.d(TAG, "请求天气信息过程中发生错误,进行重订阅");
                        return Observable.just(0);
                    }

                });
            }

        }).observeOn(AndroidSchedulers.mainThread()).subscribe(new Observer<WeatherEntity>() {

            @Override
            public void onSubscribe(Disposable disposable) {
                mCompositeDisposable.add(disposable);
            }

            @Override
            public void onNext(WeatherEntity weatherEntity) {
                WeatherEntity.WeatherInfo info = weatherEntity.getWeatherinfo();
                if (info != null) {
                    Log.d(TAG, "尝试请求天气信息成功");
                    StringBuilder builder = new StringBuilder();
                    builder.append("城市名:").append(info.getCity()).append("\n").append("温度:").append(info.getTemp()).append("\n").append("风向:").append(info.getWD()).append("\n").append("风速:").append(info.getWS()).append("\n");
                    mTvNetworkResult.setText(builder.toString());
                }
            }

            @Override
            public void onError(Throwable throwable) {
                Log.d(TAG, "尝试请求天气信息失败");
            }

            @Override
            public void onComplete() {
                Log.d(TAG, "尝试请求天气信息结束");
            }
        });
    }

    private Observable<WeatherEntity> getWeather(long cityId) {
        WeatherApi api = new Retrofit.Builder()
                .baseUrl("http://www.weather.com.cn/")
                .addConverterFactory(GsonConverterFactory.create())
                .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
                .build().create(WeatherApi.class);
        return api.getWeather(cityId);
    }

此处大家做了以下多少个操作:

2.4 示例演示

本章的以身作则代码在
RxSample
的第⑨一章中,大家演示三种情景:

  • 好端端联网状态,定位回调的区间为1s

    图片 6

控制台输出如下,可以看到只有当前后两次定位信息不同时才会发起网络请求天气信息:  

![](https://upload-images.jianshu.io/upload_images/1949836-4d44a2d024be5556.png)
  • 在非联网的时候进入,并只进行一回定位,然后在切换来有网的意况。
![](https://upload-images.jianshu.io/upload_images/1949836-83e7eb4c9f6252bd.gif)



此时控制台的输出如下,可以看到在网络重连之后,我们使用缓存的城市自动重新发起了请求:



![](https://upload-images.jianshu.io/upload_images/1949836-dbfacb32f0857ed4.png)

2.6 操作符

在那几个示例中,我们用到了以下二种操作符,若是有不了解的地点,大家能够去相应的链接中查看更详细的分解:


越来越多作品,欢迎访问小编的 Android 知识梳理体系:

网站地图xml地图