RxJava之网络请求最常见的三种场景

 更新时间:2018年05月14日 09:39:15   作者:塞上牧羊空许约  
本文想阐述一下当你开发Android应用并采用RxJava作为你的架构,尤其是有关网络请求时最常见的三种场景。这篇文章主要介绍了RxJava之网络请求最常见的三种场景,具有一定的参考价值,感兴趣的小伙伴们可以参考一下

本文想阐述一下当你开发Android应用并采用RxJava作为你的架构,尤其是有关网络请求时最常见的三种场景。

我使用Retrofit来作为网络层,简单的内存缓存-HashMap来做缓存,也可以使用Room或者其他数据库实现来替代。
Retrofit接口有如下的一些简单方法,它获取一个事件列表。

@GET("events")
Single<List<Event>> getEventsFeed(...);

通过我的Repository接口来暴露,可订阅如下:

Single<List<Event>> source =
  remoteRepository.getEventsFeed(...);
source
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(data -> {
        // Do something with data e.g. pass it to a view.
      },
      throwable -> {
        // Handle error e.g. get view to show dialog.
      }
    );

下面的例子中,我们将会改变“源”的定义方式,其余代码不变,这也是RxJava的优点之一,可以将复杂的异步任务串连起来,但是执行和观察结果的代码却可以保持不变。

现在说一下开发一个基本或中等复杂应用时会遇到的三种情形。
1.从缓存或者网络获取数据
2.发起两个请求,第二个请求依赖于第一个。
3.同时发起多个请求,并结合他们的结果。

从缓存或者网络获取数据

如果有缓存则从缓存中取值,否则从网络获取。

Maybe<List<Event>> source1 =
  cacheRepository.getEventsFeed(...);
Single<List<Event>> source2 =
  networkRepository.getEventsFeed(...);
Maybe<List<Event>> source = 
    Maybe.concat(source1, source2.toMaybe()).firstElement();

这里我们使用concat操作符将两个observable连接在一起,然而firstElement意味着我们只关心第一个发射出来的值。所以如果缓存有值,这个值将会被发射并且调用onCompleted,此值即为返回值。网络请求也将不会被调用,这也是我们所期待的。如果缓存没有值,然后它便会调用onCompleted,此时也没有发射任何一个值。因此网络请求将会发生。使用MayBe暗示着观察不到值的可能,例如,缓存为空且网络也没有返回结果。

发起两个请求,第二个请求依赖于第一个

从网络上取值并使用其部分结果发起另外一个网楼请求来获取真正想要的数据。

Single<User> source1 =
  networkRepository.getMyProfile(...);
Single<List<Tweet>> source = source1.flatMap(user -> {
    return networkRepository.getUserTweets(user.getTwitterId());
  });

同时发起多个请求,并结合他们的结果。

我有三个网络请求,它们互不依赖,我想同时执行以提高响应时间。等到三个请求都结束后才发射值。

Single<List<Event>> source1 =
  networkRepository.getEventsFeed(...);
Single<List<Bookmark>> source2 =
  networkRepository.getBookmarks(...);
Single<Stats> source3 =
  networkRepository.getUserStats(...);

Single<MyViewModel> source =
  Single.zip(source1, source2, source3, MyViewModel::new);

这个例子中,我们使用zip操作符来合并这三个Observables.它们被结合为一个MyViewModel的POJO.其构造参数与源Observables的类型匹配

public MyViewModel(List<Event>, List<Bookmark>, Stats) {...}

当你订阅这个源Observable时,将会同时发起三个网络请求,但是只有当它们都完成后才将新的MyViewModel实例发射出去。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

相关文章

  • Android实现下载进度条效果

    Android实现下载进度条效果

    vivo商店在下载应用的时候,底部有一个圆角矩形的下载进度条,中间有一个进度文字,而且进度和文字交汇的时候,交汇部分的文字会从蓝色边为白色,会有一种一半白色字,一半蓝色字的效果。本文将仿照该样式实现一个
    2021-06-06
  • Kotlin RecyclerView滚动控件详解

    Kotlin RecyclerView滚动控件详解

    RecyclerView是Android一个更强大的控件,其不仅可以实现和ListView同样的效果,还有优化了ListView中的各种不足。其可以实现数据纵向滚动,也可以实现横向滚动(ListView做不到横向滚动)。接下来讲解RecyclerView的用法
    2022-12-12
  • Android基于BaseExpandableListAdapter实现的二级列表仿通话记录功能详解

    Android基于BaseExpandableListAdapter实现的二级列表仿通话记录功能详解

    这篇文章主要介绍了Android基于BaseExpandableListAdapter实现的二级列表仿通话记录功能,结合具体实例形式分析了Android实现通话记录功能的布局与功能相关操作技巧,需要的朋友可以参考下
    2017-07-07
  • Android适配安卓6.0蓝牙通讯实现过程

    Android适配安卓6.0蓝牙通讯实现过程

    这篇文章主要为大家详细介绍了Android适配安卓6.0蓝牙通讯实现过程,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2016-09-09
  • Android使用GridView实现日历的方法

    Android使用GridView实现日历的方法

    本篇文章主要介绍了Android使用GridView实现日历的方法,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-08-08
  • Adnroid打造通用的带进度条的WebView

    Adnroid打造通用的带进度条的WebView

    这篇文章主要为大家详细介绍了Adnroid打造通用的带进度条的WebView的相关资料,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2016-09-09
  • Android控件RecyclerView实现混排效果仿网易云音乐

    Android控件RecyclerView实现混排效果仿网易云音乐

    这篇文章主要为大家详细介绍了Android控件RecyclerView实现混排效果,仿网易云音乐,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2017-10-10
  • Android通过Webservice操作sqlserver数据库实例代码

    Android通过Webservice操作sqlserver数据库实例代码

    这篇文章主要介绍了Android通过Webservice操作sqlserver数据库的相关知识,对webservice操作数据库相关知识感兴趣的朋友一起学习吧
    2016-01-01
  • android实现滚动文本效果

    android实现滚动文本效果

    这篇文章主要为大家详细介绍了android实现滚动文本效果,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2020-05-05
  • Android 解决使用SearchView时软键盘不支持actionSearch的问题

    Android 解决使用SearchView时软键盘不支持actionSearch的问题

    本文主要介绍使用SearchView时软键盘不支持actionSearch,这里提供了解决方案,希望能帮助开发Android应用的同学
    2016-07-07

最新评论