我决定在我的项目中使用Retrofit 2.0 + RxJava。主要问题是我不完全明白它应该如何。
首先,所有请求都是针对我的服务器 API,并且每个请求都必须具有 accessToken。
例如,我想使用我的 API 获取所有书籍:
1.发送请求以获取访问令牌请求
2.使用访问令牌值获取回复
3.将此值插入到获取书籍请求
4.发送getBookRequest,然后用JSONArray的书籍得到回复
问题是我应该怎么做?
现在我只有获取访问令牌值的方法:
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);
}
});
}
我应该使用可观察.zip还是其他东西?使用第一个请求中的值实现对服务器的第二个请求的更好方法是什么?
问题的解决方案是链接 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
运算符。