问题描述
我正在以这种方式进行异步 http 调用
public CompletableFuture<String> doPost(String path,String json) {
CompletableFuture<String> result = new CompletableFuture<>();
Request request = new Request.Builder().url(this.address + path).post(RequestBody.create(json,JSON)).build();
httpClient.newCall(request).enqueue(new Callback() {
@Override
public void onFailure(@NotNull Call call,@NotNull IOException e) {
result.completeExceptionally(new TerminationException());
}
@Override
public void onResponse(@NotNull Call call,@NotNull Response response) throws IOException {
result.complete(response.body().string());
}
});
}
@Override
public void onResponse(@NotNull Call call,@NotNull Response response) throws IOException {
if (!retries.contains(responce.code()) {
result.complete(response.body().string());
} else {
// Do retry here
}
}
在重试中,我想递归调用 doPost 并使用它的返回值作为初始调用的结果。 所以它返回一些可完成的未来,如何以异步方式完成初始 CF(没有 doint .get())?
谢谢。
解决方法
您可以使用委托,例如
public CompletableFuture<String> doPost(String path,String json) {
CompletableFuture<String> result = new CompletableFuture<>();
doPostImpl(this.address + path,json,result,10);
return result;
}
private void doPostImpl(
String url,String json,CompletableFuture<String> result,int maxRetries) {
Request request = new Request.Builder()
.url(url).post(RequestBody.create(json,JSON)).build();
httpClient.newCall(request).enqueue(new Callback() {
@Override
public void onFailure(@NotNull Call call,@NotNull IOException e) {
result.completeExceptionally(new TerminationException());
}
@Override
public void onResponse(
@NotNull Call call,@NotNull Response response) throws IOException {
if(maxRetries <= 0 || !retries.contains(response.code())) {
result.complete(response.body().string());
} else {
doPostImpl(url,maxRetries - 1);
}
}
});
}
前端方法委托给接收目标未来的方法。重试时,实现方法会以相同的未来再次调用。因此,没有必要将结果从一个未来转移到另一个未来。
从字面上看问题,您可以使用
将未来的结果转移到另一个future2.whenComplete((value,throwable) -> {
if(throwable != null) future1.completeExceptionally(throwable);
else future1.complete(value);
});
但是只要重试的次数就可以创建依赖链。如上所示,没有必要这样做。