泽西岛异步响应和响应

Question

我想返回一个临时重定向，使用AsyncACK。

下面的“工作”（因为没有错误），但似乎不是异步的（它一次处理一个请求）。

    @GET
    public Response doLoad(@Suspended final AsyncResponse asyncResponse,
            @QueryParam("path") String path)  {

        Response response = veryExpensiveOperation(path);
        asyncResponse.resume(response);
        return response;
    }

    private Response veryExpensiveOperation(String path)  {
        // veryExpensiveOperation
    }

这应该工作吗？如果我明确需要像https://jersey.github.io/documentation/latest/async.html#d0e9895一样启动一个新线程，返回响应是什么样子的？

Answer 1

我不认为您正在正确使用异步上下文。从我所看到的，您正在阻塞请求处理线程。你不应该在vertx中阻止这个线程。如何做到如下：

    @GET
    public void doLoad(@Suspended final AsyncResponse asyncResponse,
            @QueryParam("path") String path)  {

        CompletableFuture<Response> future = veryExpensiveOperation(path);
        future.thenAccept(resp -> asyncResponse.resume(resp));
    }    

    private CompletableFuture<Response> veryExpensiveOperation(String path){
        CompletableFuture<Response> completableFuture = new CompletableFuture<>();

        new Thread(() -> {
            //do expensive stuff here
            completableFuture.complete(Response.ok().entity("Completed").build());
        }).start();

        return completableFuture;
    }