使用 RxJava 和 Retrofit 链接两个 Web 服务调用

Question

我正在使用 RxJava 和 Retrofit。我的基本要求是，我想链接两个 api 调用，它们将一个接一个地被调用。在调用第二个 api 时，从第一个 api 收到的响应用作输入。在互联网上阅读了一些东西后，我曾经使用平面图来实现这一点。在执行此操作时，我正在显示加载程序。有时它运行平稳，但在某些情况下，此加载程序冻结。 DDMS 显示“跳过 300 帧，应用程序可能在其主线程上做太多工作”的日志。我怀疑我的一个网络调用正在主线程上运行。我无法弄清楚如何链接这两个调用，以便可以在后台顺利调用它们而不妨碍我的主线程。任何帮助是极大的赞赏 。提前致谢 这是我迄今为止尝试过的

private CompositeSubscription mSubscriptions = new CompositeSubscription();

Subscription subscription = Observable.just(getAddress())
          .subscribeOn(Schedulers.newThread())
          .flatMap(address -> mPlatformApi.secondWebService(address.getLatitude(),address.getLongitude())
          .observeOn(AndroidSchedulers.mainThread())
          .subscribe(modelTwo ->
          {
            //updating My ui
          }, throwable -> {

            //Error Handling
          });

mSubscriptions.add(subscription);


private android.location.Address getAddress(){
    String addressString = "";//some Address String
    Geocoder coder = new Geocoder(getActivity());
    android.location.Address address=null;
    try {
      ArrayList<android.location.Address> addressList = (ArrayList<android.location.Address>) coder.getFromLocationName(addressString, 1);
      if(addressList !=null && addressList.size()>0) {
        address = addressList.get(0);
      } else {

      }
    } catch (IOException e) {
      e.printStackTrace();
    }
    return address;
  }

//My Retrofit call
Observable<modelTwo> secondWebService(@Path("lat") double lat,@Path("lon") double lon);

Answer 1

考虑一下：

final android.location.Address address = getAddress();
Subscription subscription = Observable.just(address) ...

这等同于您的代码，但也应该明确指出，getAddress() 在 RxJava 参与并有机会干预之前就已评估。换句话说，当您使用just 时，subscribeOn 只能将地址的发射（在您的Subscriber 上调用onNext(address)）移动到另一个线程。但是，地址的创建 - 即您的getAddress - 将在您到达这一点时已经在主线程上发生。

将getAddress 实际移动到另一个线程的最简单方法是使用defer：

Subscription subscription = Observable.defer(new
          Func0<Observable<android.location.Address>>() {

              @Override
              public Observable<android.location.Address> call() {
                  return Observable.just(getAddress());
              }
          })
          .subscribeOn(Schedulers.newThread())
          .flatMap(address -> mPlatformApi.secondWebService(address.getLatitude(),address.getLongitude()    )
          .observeOn(AndroidSchedulers.mainThread())
          .subscribe(modelTwo ->
          {
            //updating My ui
          }, throwable -> {
            //Error Handling
          });

这样，整个Func0 将在newThread() 上执行——不仅是just，还有getAddress。