java sse

SSE (Server-Sent Events) 是一种基于 HTTP 的服务器推送技术，用于在客户端与服务器之间建立持久的连接，实现服务器向客户端发送消息的功能。在 Java 中，可以使用 Servlet 3.0 API 中的 javax.servlet.sse 包来实现 SSE。

具体来说，需要在 Servlet 中创建一个实现 javax.servlet.Servlet 的类，并在其中重写 doGet 方法。在 doGet 方法中，需要创建 javax.servlet.http.HttpServletRequest 和 javax.servlet.http.HttpServletResponse 对象，并设置响应的 Content-Type 为 text/event-stream。然后，可以使用 HttpServletResponse 对象的 getWriter 方法获取输出流，并通过输出流向客户端发送消息。

下面是一个使用 Java 实现 SSE 的示例代码：

import java.io.IOException;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

public class MyServlet extends HttpServlet {

    private static final long serialVersionUID = 1L;

    private ScheduledExecutorService executorService;

    @Override
    public void init() throws ServletException {
        super.init();
        executorService = Executors.newSingleThreadScheduledExecutor();
    }

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

        executorService.scheduleAtFixedRate(new Runnable() {

            private int count = 0;

            @Override
            public void run() {
                count++;
                try {
                    resp.getWriter().write("data: " + count + "\n\n");
                    resp.getWriter().flush();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }, 0, 1, TimeUnit.SECONDS);
    }

    @Override
    public void destroy() {
        super.destroy();
        executorService.shutdown();
    }

}

在上面的代码中，我们使用 ScheduledExecutorService 来定时向客户端发送消息。每秒钟向客户端发送一条消息，并将消息内容设置为当前的计数器值。注意，每条消息都需要以 data: 开头，并以两个换行符结尾，这是 SSE 的协议规定。客户端在接收到消息后，需要解析消息内容并进行相应的处理。