@WebServlet(urlPatterns = "/streaming",asyncSupported = true)
public static class StreamingServlet extends HttpServlet {

    private static final long serialVersionUID = 1L;
    private ExecutorService executorService = Executors.newCachedThreadPool();

    @Override
    protected void doGet(HttpServletRequest request, HttpServletResponse response)
        throws ServletException, IOException {
        // 设置响应内容类型为SSE
        response.setContentType("text/event-stream");
        response.setCharacterEncoding("UTF-8");
        // 开启异步上下文
        final AsyncContext asyncContext = request.startAsync();
        // 使用线程池执行任务
        executorService.execute(() -> {
            try {
                PrintWriter writer = response.getWriter();
                for (int i = 0; i < 10; i++) {
                    // 发送数据
                    writer.write("data: " + i + "\n\n");
                    writer.flush();

                    // 模拟数据产生的延迟
                    Thread.sleep(1000);
                }
            } catch (IOException | InterruptedException e) {
                e.printStackTrace();
            } finally {
                asyncContext.complete();
            }
        });
    }
    @Override
    public void destroy() {
        // 关闭线程池
        executorService.shutdown();
    }
}