在运行时使用Jersey决定同步或异步响应

Question

@Path("resource")
public class Resource {
    @GET
    @Produces({MediaType.TEXT_PLAIN})
    public Response get() {
        return Response.ok("Hello there!").build();
    }
}

@Path("resource")
public class Resource {
    @GET
    @Produces({MediaType.TEXT_PLAIN})
    public void get(@Suspended final AsyncResponse r) {
        r.resume(Response.ok("Hello there!").build()); // usually called somewhere from another thread
    }
}

根据某些参数，我希望在运行时决定GET请求应该同步还是异步处理。在这两种情况下，资源endpoint的URL(http://server/resource)必须相同。这可能吗？

当然，正如您在上面的示例中所看到的，可以通过调用AsyncResponse.Resume(...)以异步方式伪造同步版本。但是，我会避免创建异步响应的开销。

Answer 1

JAX-RS异步服务器API是关于容器如何管理请求的。但它仍然会保留请求，不会影响客户体验。

引用关于异步服务器API的Jersey文档：

注意，使用服务器端异步处理模型不会改善客户端感知的请求处理时间。然而，当请求仍在队列中等待处理或处理仍在另一个专用线程上运行时，它将释放初始请求处理线程到I/O容器，从而增加服务器的吞吐量。释放的I/O容器线程可用于接受和处理新传入的请求连接。

@Provider
@PreMatching
public class PreMatchingFilter implements ContainerRequestFilter {

    @Override
    public void filter(ContainerRequestContext requestContext) throws IOException {

        if (requestContext.getHeaders().get("X-Use-Async") != null) {
            requestContext.setRequestUri(yourNewURI);
        }
    }
}

我还没有测试下面的解决方案，但它应该可以工作。您可以为同步和异步方法保留相同的URL，只是为每个方法接受不同的内容类型。

例如：

• 同步方法:@consumes（“application/vnd.example.sync+text”）
• 异步方法:@consumes（“application/vnd.example.async+text”）

if (useSync) {
    requestContext.getHeaders().putSingle(
        HttpHeaders.CONTENT_TYPE, "application/vnd.example.sync+text");
} else {
    requestContext.getHeaders().putSingle(
        HttpHeaders.CONTENT_TYPE, "application/vnd.example.async+text");
}