使用Retrofit + RxJava在请求之间进行数据传输

Question

我决定在我的项目中使用Retrofit 2.0 + RxJava。 主要问题是我不完全理解它应该如何。

首先，所有请求都发送到我的服务器API，并且每个请求都必须具有accessToken。

比如我想用我的API让所有的书：

1.Send要求得到的accessToken要求

用的accessToken值2.注册回复

3.插入此值getBookRequest

4.发送getBookRequest，然后得到与JSONArray图书的回复

问题是我该如何做到这一点？

现在我有只得到accessTokenValue方法：

public void accessToken() { 
    ApiMethods methods = ApiFactory.connect(); 
    methods.getAccess(MAIN_URL + ACCESS_URL) 
      .timeout(15, TimeUnit.SECONDS) 
      .retry(3) 
      .subscribeOn(Schedulers.newThread()) 
      .map(new Func1<List<GetAccess>, AccessToken>() { 
       @NonNull 
       @Override 
       public AccessToken call(List<GetAccess> getAccesses) { 
        double xA = (double) getAccesses.get(0).A; 
        double xB = (double) getAccesses.get(0).B; 
        double xC = (double) getAccesses.get(0).C; 
        passDouble = //...SOME MANIPULATING WITH VALUES...// 
        id = getAccesses.get(0).ID; 
        AccessToken token = new AccessToken(); 
        token.setId(String.valueOf(id)); 
        token.setToken(String.valueOf(passDouble)); 
        token.setIsCompleted(true); 


        return token; 
       } 
      }) 
      .onErrorReturn(new Func1<Throwable, AccessToken>() { 
       @Override 
       public AccessToken call(Throwable throwable) { 
        return new AccessToken(String.valueOf(id), String.valueOf(passDouble), false); 
       } 
      }) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .subscribe(new Action1<AccessToken>() { 
       @Override 
       public void call(AccessToken accessToken) { 
        //EventBus.getDefault().post(accessToken); 
       } 
      }); 
} 

我应该用Observable.zip还是其他什么东西？用第一个请求的值实现对我的服务器的第二个请求的更好方法是什么？

Answer 1

解决您的问题的方法是链接2个不同的可观察对象：获取访问令牌 - >然后获取书籍列表。

我建议让您的accessToken这个样子的：

public Observable<AccessToken> accesstoken() { 
    ApiMethods methods = ApiFactory.connect(); 
    return methods.getAccess(MAIN_URL + ACCESS_URL) 
      .timeout(15, TimeUnit.SECONDS) 
      .retry(3) 
      .subscribeOn(Schedulers.newThread()) 
      .map(new Func1<List<GetAccess>, AccessToken>() { 
       @NonNull 
       @Override 
       public AccessToken call(List<GetAccess> getAccesses) { 
        double xA = (double) getAccesses.get(0).A; 
        double xB = (double) getAccesses.get(0).B; 
        double xC = (double) getAccesses.get(0).C; 
        passDouble = //...SOME MANIPULATING WITH VALUES...// 
          id = getAccesses.get(0).ID; 
        AccessToken token = new AccessToken(); 
        token.setId(String.valueOf(id)); 
        token.setToken(String.valueOf(passDouble)); 
        token.setIsCompleted(true); 


        return token; 
       } 
      }) 
      .onErrorReturn(new Func1<Throwable, AccessToken>() { 
       @Override 
       public AccessToken call(Throwable throwable) { 
        return new AccessToken(String.valueOf(id), String.valueOf(passDouble), false); 
       } 
      }); 
} 

然后你可以使用它像这样：

accessToken() 
     .flatMap(new Func1<AccessToken, Observable<List<Book>>>() { 
      @Override 
      public Observable<?> call(AccessToken accessToken) { 
       ApiMethods methods = ApiFactory.connect(); 
       return methods.getBookRequest(accessToken); 
      } 
     }) 
     .observeOn(AndroidSchedulers.mainThread()) 
     .subscribe(new Action1<List<Book>>() { 
      @Override 
      public void call(List<Book> books) { 
       // handle your list of books 
      } 
     }); 

这里的关键是flatMap运算符链这两个观测。