REST 端点：没有 return 值的异步执行

Question

我的问题可能很容易解决，但我现在不明白。在我的 Quarkus-App 中，我有一个 REST-Endpoint，它应该调用一个方法，不要等待结果并立即 return 一个 202-HTTP-Statuscode。

@POST
@Produces(MediaType.APPLICATION_JSON)
@Consumes(MediaType.APPLICATION_JSON)
public Response calculateAsync(String input) {
    process();
    return Response.accepted().build();
}

我已经阅读了关于 Vert.x 和异步处理的 Quarkus 文档。但重点是：处理是异步完成的，但客户端等待结果。我的客户不需要等待，因为没有 return 值。这有点像批处理的调用。

所以我需要类似 new Thread 的东西，但需要所有 Quarkus-Context。

Answer 1

您可以在参数中使用 @Suspended AsyncResponse response 并使方法 return void 下面是类似方法的示例：

    @GET
    @Produces(MediaType.TEXT_PLAIN)
    public void hello(@Suspended AsyncResponse response) throws InterruptedException {
        response.resume(Response.ok().build());
        Thread.sleep(10000);
        System.out.println("Do some work");
    }

Answer 2

我们找到了解决方案：

@POST
@Produces(MediaType.APPLICATION_JSON)
@Consumes(MediaType.APPLICATION_JSON)
public Response calculateAsync(String input) {
    Uni.createFrom().item(input).emitOn(Infrastructure.getDefaultWorkerPool()).subscribe().with(
            item -> process(input), Throwable::printStackTrace
    );

    return Response.accepted().build();
}

REST 端点：没有 return 值的异步执行

REST-Endpoint: Async execution without return value

asynchronous

jax-rs

quarkus