使用RxJava怎么实现网络请求

使用RxJava怎么实现网络请求？很多新手对此不是很清楚，为了帮助大家解决这个难题，下面小编将为大家详细讲解，有这方面需求的人可以来学习下，希望你能有所收获。

网站建设哪家好，找创新互联建站！专注于网页设计、网站建设、微信开发、微信小程序开发、集团企业网站建设等服务项目。为回馈新老客户创新互联还提供了澜沧免费建站欢迎大家使用！

我使用Retrofit来作为网络层，简单的内存缓存-HashMap来做缓存，也可以使用Room或者其他数据库实现来替代。

Retrofit接口有如下的一些简单方法，它获取一个事件列表。

@GET("events")
Single> getEventsFeed(...);

通过我的Repository接口来暴露，可订阅如下：

Single> 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> source1 =
  cacheRepository.getEventsFeed(...);
Single> source2 =
  networkRepository.getEventsFeed(...);
Maybe> source = 
    Maybe.concat(source1, source2.toMaybe()).firstElement();

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

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

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

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

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

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

Single> source1 =
  networkRepository.getEventsFeed(...);
Single> source2 =
  networkRepository.getBookmarks(...);
Single source3 =
  networkRepository.getUserStats(...);

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

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

public MyViewModel(List, List, Stats) {...}

看完上述内容是否对您有帮助呢？如果还想对相关知识有进一步的了解或阅读更多相关文章，请关注创新互联行业资讯频道，感谢您对创新互联的支持。