异步servlet不在单独的线程中执行异步任务[重复]

Question

我正在探索使用Spring Boot的异步servlet。据我所知，异步servlet用于在一个线程中执行长时间运行的任务，而不是容器为处理请求而启动的线程，这样容器就可以使用自己的线程来处理其他连接。基于这样的理解，我尝试了以下代码：

@WebServlet(asyncSupported = true, urlPatterns = "/demo")
@Component
public class demo extends HttpServlet {



    /**
     * @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse
     *      response)
     */
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        final AsyncContext context = request.startAsync();
        ServletOutputStream stream = response.getOutputStream();
        WriteListener listener = new WriteListener() {

            @Override
            public void onWritePossible() throws IOException {
                System.out.println(Thread.currentThread().getId());
                ServletOutputStream output = context.getResponse().getOutputStream();
                if (output.isReady()) {
                    try {
                        TimeUnit.SECONDS.sleep(10);
                    } catch (InterruptedException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                    output.print("Heloooooooooo");
                }
                context.complete();
            }

            @Override
            public void onError(Throwable throwable) {
                throwable.printStackTrace(System.err);
                context.complete();
            }
        };

        stream.setWriteListener(listener);
        System.out.println(Thread.currentThread().getId());

    }

    /**
     * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse
     *      response)
     */
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException,
            IOException {
        // TODO Auto-generated method stub
    }

}

但问题是，运行doGet的同一线程正在调用OnWriteProbabile方法。不是应该不一样吗？

Answer 1

在doGet方法中，您已经创建了一个AsyncContext，您有责任将它进一步传递给一个不同的线程，该线程将通过设置result-servlet容器不会为您创建一个新线程来完成处理（稍后）。

在asynccontext传递给不同的线程之后，doget可以立即返回，从而释放servlet容器的执行器线程来服务新的请求。

基于您的代码的示例：

protected void doGet(HttpServletRequest request, HttpServletResponse response) throws IOException {
    final AsyncContext context = request.startAsync();
    System.out.println("Servlet container thread before async started: " 
        + Thread.currentThread().getName());
    new Thread(new Runnable() {
        @Override
        public void run() {
                try {
                    System.out.println("New thread started: " 
                         + Thread.currentThread().getName());
                    ServletOutputStream output = context.getResponse().getOutputStream();
                    TimeUnit.SECONDS.sleep(3);
                    System.out.println("New thread writing response: " 
                        + Thread.currentThread().getName());
                    output.print("Hi!");
                    context.complete();
                } catch (Throwable e) {
                    e.printStackTrace();
                }
        }
    }).start();
    System.out.println("Servlet container thread returning: " 
        + Thread.currentThread().getName());
}

Servlet container thread before async started: http-nio-8080-exec-1
Servlet container thread returning: http-nio-8080-exec-1
New thread started: Thread-3
New thread writing response: Thread-3

如果您使用Spring Boot，您可以实现一个控制器，它返回一个可调用，Spring Framework将确保可调用是在一个生命周期由Spring管理的不同线程中执行的。

如果您想在没有Spring的情况下执行此操作（这也很好），通常可以通过将AsyncContext放在队列中，并让一个ExecutorService使用排队的请求来完成此操作。