java使用Server-sent events异步发送消息，使用线程池，线程使用完关闭线程，防止线程暴增，示例代码

使用线程池来处理Server-sent events异步发送消息是一种比较常见的做法。为了防止线程暴增，需要在线程使用完毕后及时关闭线程。示例代码如下：

public class SSEServlet extends HttpServlet {
    private ExecutorService executor;

    @Override
    public void init() {
        executor = Executors.newFixedThreadPool(10);
    }

    @Override
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        response.setContentType("text/event-stream");
        response.setCharacterEncoding("UTF-8");

        PrintWriter out = response.getWriter();

        // 异步发送消息
        executor.execute(() -> {
            try {
                while (true) {
                    // 生成消息
                    String message = generateMessage();

                    // 发送消息
                    out.write("data: " + message + "\n\n");
                    out.flush();

                    // 等待一段时间
                    Thread.sleep(1000);
                }
            } catch (InterruptedException e) {
                // 线程被中断，结束任务的执行
            } finally {
                // 关闭输出流
                out.close();
            }
        });
    }

    @Override
    public void destroy() {
        // 关闭线程池
        executor.shutdownNow();
    }

    private String generateMessage() {
        // 生成消息的代码
    }
}

在上面的示例代码中，我们通过调用`Executors.newFixedThreadPool()`方法来创建一个固定大小的线程池，然后在`doGet()`方法中提交异步任务来发送消息。在异步任务中，我们通过使用`PrintWriter`对象来发送消息，并且在任务执行完成后关闭输出流。在`destroy()`方法中，我们调用`executor.shutdownNow()`方法来立即关闭线程池。需要注意的是，在异步任务中需要处理`InterruptedException`异常，以便在任务被中断时及时结束任务的执行。