Java - 从 OkHttp 异步 GET 中检索结果答案

【问题标题】：Java - Retrieving Result from OkHttp Asynchronous GETJava - 从 OkHttp 异步 GET 中检索结果
【发布时间】：2017-07-07 14:24:07
【问题描述】：

所以我在 Spring Boot 中有一个 Web 应用程序，其中有一部分我向 API 发出许多 HTTP 请求，如果发出太多请求，它似乎会超时。我听说从同步请求切换到异步请求可能有助于解决这个问题。

使用 OkHttp，这是我的同步 GET 请求的样子：

private JSONObject run(String url) throws Exception {
    Request newRequest = new Request.Builder()
            .url(url)
            .addHeader("Authorization", token)
            .build();

    try (Response response = client.newCall(newRequest).execute()) {
        if (!response.isSuccessful()) throw new IOException("Unexpected code " + response);
        return new JSONObject(response.body().string());

    }
}

我通过解析响应正文将响应作为 JSON 对象返回。但是，在尝试使用 OkHttp 异步调用时，似乎我不能使用相同的方法。这是我到目前为止所拥有的：

public void runAsync(String url) throws Exception {
    Request request = new Request.Builder()
            .url(url)
            .addHeader("Authorization", token)
            .build();

    client.newCall(request).enqueue(new Callback() {
        @Override public void onFailure(Call call, IOException e) {
            e.printStackTrace();
        }

        @Override public void onResponse(Call call, Response response) throws IOException {
            if (!response.isSuccessful()) throw new IOException("Unexpected code " + response);

            System.out.println(response.body().string());
        }
    });
}

我不能简单地将结果作为 JSON 返回，因为响应包含在回调方法中，该方法的返回值为 void。关于如何获得与提取响应的同步 GET 类似的结果的任何想法？

【问题讨论】：

这并没有真正获得更改为异步调用的任何好处。理想情况下，您会向调用您的 Web 框架返回类似 Future 的内容，并且它将异步处理未来的完成。如果您必须为您发出的单个请求向调用者返回完整的结果，那么无论它是什么同步调用。另一种可能性是您的最终结果取决于许多请求，在这种情况下，让这些请求同步并发执行会有所帮助。
嗯，很有趣。在我的例子中，有许多 HTTP 请求的目的是解析和聚合所有结果并将内容存储在字符串中。听起来同步并发请求可能是我需要做的。那么这种异步方法不适合我的问题吗？
实际上这听起来仍然很理想。您可以让异步任务同时获取数据并同时解析，然后同步阻塞，直到所有单独的结果都完成
我明白了！好吧，感谢您的帮助，我将花一些时间尝试了解期货和并发性，然后我将尝试实施您在帖子中推荐的内容。

标签： java spring asynchronous okhttp okhttp3

【解决方案1】：

我不是 Spring Boot 的用户，所以这不是一个完整的答案。但是如果它支持返回一个 Future，那么从 OkHttp 回调到一个 Future 的桥接就很简单了。

这可能是相关的https://spring.io/guides/gs/async-method/

至于生产未来

public class OkHttpResponseFuture implements Callback {
  public final CompletableFuture<Response> future = new CompletableFuture<>();

  public OkHttpResponseFuture() {
  }

  @Override public void onFailure(Call call, IOException e) {
    future.completeExceptionally(e);
  }

  @Override public void onResponse(Call call, Response response) throws IOException {
    future.complete(response);
  }
}

然后将工作排入队列

  OkHttpResponseFuture callback = new OkHttpResponseFuture();
  client.newCall(request).enqueue(callback);

  return callback.future.thenApply(response -> {
    try {
      return convertResponse(response);
    } catch (IOException e) {
      throw Throwables.propagate(e);
    } finally {
      response.close();
    }
  });

如果您有多个请求要处理，您可以分别提交它们，然后等待所有结果可用，然后再合并并返回

  public static <T> CompletableFuture<List<T>> join(List<CompletableFuture<T>> futures) {
    CompletableFuture[] cfs = futures.toArray(new CompletableFuture[futures.size()]);

    return CompletableFuture.allOf(cfs)
        .thenApply(v -> combineIndividualResults(c));
  }

【讨论】：