如何对请求立即发送异步响应

Question

我正在尝试找到一种异步的方式来立即返回客户端请求的响应。

我所需要的只是记录请求数据，调用新线程请求其他服务器上昂贵的操作（一些后端操作），并且无需等待它们的响应，立即返回200状态响应给客户端。

此时此刻，我正试图用完整的未来来做这件事，但我错过了一些东西。

package com.example.controller;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.core.Logger;

import javax.servlet.http.HttpServletRequest;
import javax.ws.rs.Consumes;
import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.core.Context;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
import java.util.concurrent.CompletableFuture;

@Path("/class")
public class AsynchronousResponse {

private static final Logger LOGGER = (Logger) LogManager.getLogger(AsynchronousResponse.class.getName());
private static final int HTTP_STATUS_OK = 200;
private static final String EMPTY_CONTENT = "";

@Context
private HttpServletRequest httpRequest;

@Path("/method")
@GET
@Consumes(MediaType.APPLICATION_JSON)
public Response asyncResponseSupply() {
    LOGGER.info(httpRequest.getSession().getId() + " : New session received");
    CompletableFuture.supplyAsync(this::veryExpensiveOperations);
    LOGGER.info(httpRequest.getSession().getId() + " : Returning empty response... ");
    return Response.status(HTTP_STATUS_OK).entity(EMPTY_CONTENT).build();
}

// need to do some operations on data from httpRequest
private String veryExpensiveOperations() {
    LOGGER.info(httpRequest.toString());
    LOGGER.info("Start very expensive operations");
    try {
        Thread.sleep(3000);
        LOGGER.info("Finished");
        return "DONE";
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
        e.printStackTrace();
        LOGGER.error("Error: " + e.getMessage());
        return "ERROR";
    }
}

}

总之，我得到了立即响应，但veryExpensiveOperations（）方法似乎丢失了httpRequest值，这对我来说太糟糕了，因为我需要从客户端请求调用具有值的其他webservices。多谢帮忙！

对于我的应用程序，我使用的是Jetty Ver。9.2.18.V20160721

Answer 1

一旦完成对servlet的调度，就提交响应，并回收request和response对象。

对于servlet规范的处理，您必须使用AsyncContext（通过HttpServletRequest.startAsync()调用获得）来让容器知道请求/响应尚未完成，并且对它的处理正在非分派线程中进行（就像您的CompletableFuture.SupplyAsync()调用）

至于如何将JAX-RS和AsyncContext混合使用，我完全不知道。我甚至不知道JAX-RS是否已经更新为支持asyncContext。