java - 如何使用方法内部的 Java 匿名函数中获取的数据

Question

似乎是一个常见问题，但我只是不确定解决方案。

我正在使用 Vert.x 和 Java 来调用另一个服务。我正在使用 Vert.x 的 WebClient 库。当我发出 POST 请求时，参数之一是匿名函数。如果请求成功，我就会得到我的数据。

问题是在我的方法的其余部分中在匿名函数之外获取这些数据。我希望我的方法返回从匿名函数获得的数据。数据位于 body 变量中。

private JsonArray itemTypes() {
  WebClient webClient = WebClient.create(vertx);
  webCLient.post(80, "myApi.com", "/api/items")
    .sendJsonObject(new JsonObject().put("mutator", "*"), ar -> {
      if (ar.succeeded) {
        HttpResponse<JsonArray> result = ar.result();
        JsonArray body = result.body();
      } else {
        System.out.println(ar.cause().getMessage());
      }
    });
}

现在，如果我尝试在匿名函数外部声明 body 变量并在内部分配它(以便我可以返回该值)，我的 IDE 会报错 Local variable body Defined在封闭范围内必须是最终的或有效最终的。

我本质上想做这样的事情:

private JsonArray itemTypes() {
  JsonArray body;
  WebClient webClient = WebClient.create(vertx);
  webCLient.post(80, "myApi.com", "/api/items")
    .sendJsonObject(new JsonObject().put("mutator", "*"), ar -> {
      if (ar.succeeded) {
        HttpResponse<JsonArray> result = ar.result();
        body = result.body();
      } else {
        System.out.println(ar.cause().getMessage());
        body = new JsonArray();
      }
    });
  return body;
}

我尝试将 JsonArray 主体变量设置为最终变量，但这不起作用。我还尝试将整个 webClient.post(....) 调用分配给一个变量，但这也不起作用。

如何访问匿名函数外部的 body 数据，以便在我的方法中返回它？

Answer 1

您遇到的问题是 WebClient 似乎是完全异步的。这意味着当您调用 .sendJsonObject ，它基本上发送请求并立即返回；当 WebClient 等待答案时，您的代码将继续运行。

收到响应后，它会调用您提供的回调 lambda(可能在其他线程中)。这可能会在几秒钟后发生，并且您的许多其他代码可能有时间同时运行。

您需要的是让主代码等待收到响应。这可以通过多种方式完成，其中之一是创建 CompletableFuture<T> ，让回调调用 .complete(theValue)方法，然后让外部代码调用 .get()等待并接收值。

换句话说，外部代码将定义并等待 CompletableFuture<T>完成，然后有 .sendJsonObject回调为您完成所需的值。