改造及RxJava，避免回调地狱

所以目前，林制作带有日期参数一个异步网络请求（使用改造），并且如果与该原位缺口200的响应代码，请求返回（或者如果它的429，400，或如果响应正文是空的，无论哪个最容易确定），我在1天前用日期参数发出一个新的请求。同样，如果这一请求回来了原位缺口200的响应代码，我做一个日期比之前的早1天，共计3个可能的请求如果前两个失败多了一个请求。改造及RxJava，避免回调地狱

我目前正在与一群回调的实现这一目标，并呼吁建立与-1为每个尝试一天执行请求的新方法。

我知道我可以实现与Rx和内置的Rx功能改造探索一个清晰的解决方案。这将如何完成？

来源

2015-12-21 Orbit

什么改装版本？ –

@NikoYuwono 2.0.0-β2 – Orbit

检查我的答案 –

首先，你需要在你的依赖

compile 'com.squareup.retrofit:adapter-rxjava:2.0.0-beta2' 
compile 'io.reactivex:rxandroid:1.0.1'

，然后添加RxAndroid和RxJava适配器需要电话适配器注册到改造声明

Retrofit retrofit = new Retrofit.Builder() 
     .baseUrl(myBaseurl) 
     .addConverterFactory(GsonConverterFactory.create()) 
     .addCallAdapterFactory(RxJavaCallAdapterFactory.create()) 
     .build();

然后你就可以改变你的服务接口返回类型从呼叫到可观察

public interface MyAPIService { 

    @POST("user") 
    Call<User> getUser(); 

    @POST("user") 
    Observable<Response<User>> getUserWithRxJava(); 

    @POST("user_friends") 
    Observable<Response<List<User>>> getUserFriends(); 
}

并且t他是链接调用

myService.getUserWithRxJava() 
    .observeOn(AndroidSchedulers.mainThread()) 
    .flatMap(new Func1<Response<User>, Observable<Response<List<User>>>>() { 
     @Override 
     public Observable<List<Home>> call(Response<User> responseUser) { 
      // You can also use responseUser.code to get the response code 
      // but isSuccess() function will return true if the code 
      // is in the range [200..300) 
      if (responseUser.isSuccess()) { 
       return myService.getUserFriends(); 
      } else { 
       // You can also use Observable.empty() if you want to ignore unsuccessful response 
       return Observable.error(myThrowable); 
      } 
     } 
    }) 
    .subscribe(new Subscriber<Response<List<User>>>() { 
     @Override 
     public void onCompleted() { 
      // TODO Completed 
     } 

     @Override 
     public void onError(Throwable e) { 
      // TODO Handle the error 
     } 

     @Override 
     public void onNext(Response<List<User>> friendListResponse) { 
      // TODO do something with the data 
      // To get the serialized data you can use friendListResponse.body(); 
     } 
    });

来源

2015-12-21 09:15:05

非200的响应应该回来为RetrofitError对象，其中包含Response对象的状态代码的例子。

你可以做这样的事情：

observable 
    .retryWhen(new RetryStrategy()) 
    .subscribe(...);

和RetryStrategy可能是这样的（注意，我用retrolambda，所以无论你看到->只是一个新的匿名内部类替换）：

public class RetryStrategy implements Func1<Observable<? extends Throwable>, Observable<?>> { 

    public RetryStrategy() {} 

    @Override 
    public Observable<?> call(Observable<? extends Throwable> attempts) { 
     return attempts.flatMap((throwable) -> { 
      if (throwable instanceof RetrofitError) { 
       RetrofitError error = (RetrofitError) throwable; 
       if (error.getKind() == RetrofitError.Kind.HTTP) { 
        if (error.getResponse().getStatus() == 401) { 

         // This is where you attempt to recover 
         return someRecoveryObservable???; 
        } 
       } 
      } 

      // Bubble any other errors back up, e.g. connection loss. 
      return Observable.error(throwable); 
     }); 
    } 
}

你也可以实现Exponential Backoff这里加入支持重试次数，在你的恢复阶段使用Observable.timer(long, TimeUnit)沿（和计算基础上尝试的当前数量的时间）。 Spotty连接问题有时会从这种方法中大大受益 - 尤其是在火灾后遗症中忘记执行的任务。

来源

2015-12-24 21:12:52 drhr

改造及RxJava，避免回调地狱

回答

相关问题