服务器发送的事件是如何工作的

Question

我在tomcat 8.0上使用java尝试了一个SSE（服务器发送事件）。以下是我注意到的几件事。

我单击一个按钮，它会自动向servlet发出请求。执行Servlet的GET方法，返回事件流。一旦收到完整的数据流，页面会再次自动发出另一个请求，再次接收相同的数据！！！我没有无限循环！！！

>

什么是正确的方法来确保事件流只发送一次到同一个连接/浏览器会话？

什么是正确的方法来确保事件流被关闭并且不会在服务器上产生资源开销？

如何区分GET和POST请求。它为什么选择GET？

在Tomcat上使用SSE是否为时过早？任何性能问题？

这是好奇者的密码，

@WebServlet("/TestServlet")
public class TestServlet extends HttpServlet {

    public void doGet(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {

        //content type must be set to text/event-stream
        response.setContentType("text/event-stream"); 
        //cache must be set to no-cache
        response.setHeader("Cache-Control", "no-cache");     
        //encoding is set to UTF-8
        response.setCharacterEncoding("UTF-8");

        PrintWriter writer = response.getWriter();

        for(int i=0; i<10; i++) {
            System.out.println(i);
            writer.write("data: "+ i +"\n\n");
            writer.flush();
            try {
                Thread.sleep(3000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        writer.close(); 
    }
}

页面上有Javascript（页面上没有其他内容），

<button onclick="start()">Start</button>

<script type="text/javascript">
    function start() {
        var eventSource = new EventSource("TestServlet");
        eventSource.onmessage = function(event) {
            console.log("data: "+event.data)
            document.getElementById('foo').innerHTML = event.data;
        };
    }
</script>

用卷发试试这个。而回应只有一次。我用的是chrome，所以这一定是chorme的问题？？

编辑：

我学到的和学到的现在都记录在我的博客-服务器发送事件中

Answer 1

浏览器尝试在每次连接关闭后大约3秒重新连接到源。您可以通过包含以“重试：”开头的行来更改超时，后跟尝试重新连接前要等待的毫秒数。

Answer 2

我强烈建议首先阅读使用服务器发送事件的流更新，以便对该技术有一个良好的总体理解。然后使用异步Servlet通过示例来跟踪服务器发送事件，了解如何将SSE专门用于Servlet技术。

Answer 3

换线

writer.write("data: "+ i +"\n\n");

到

writer.write("data: "+ i +"\r\n");

顺便说一句，你的代码将有一个严重的性能问题，因为它将保持一个线程，直到所有事件都被发送。请改用异步处理API。例如

protected void service(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
    AsyncContext actx = req.startAsync();
    actx.setTimeout(30*1000);
    //save actx and use it when we need sent data to the client.
}

然后我们可以稍后使用AsyncContext

//write some data to client when a certain event happens
actx.getResponse().getWriter().write("data: " + mydata + "\r\n");
actx.getResponse().getWriter().flush();

如果所有事件都已发送，我们可以关闭它

actx.complete();

更新1：

如果我们不想在服务器完成响应后再次重新连接服务器，我们需要关闭浏览器上的事件源。

eventSource.close();

另一种方法可能会有所帮助，即。我们设置了一个相当大的重试时间，但我没有尝试过。

protected void service(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
    AsyncContext actx = req.startAsync();
    actx.getResponse().getWriter().write("retry: 36000000000\r\n"); // 10000 hours!
    actx.getResponse().getWriter().flush();
    //save actx and use it when we need sent data to the client.
}

更新2：

我认为网络插座可能更适合你的情况。

更新3：（回答问题）

1. 服务器上实际发生了什么？在正常情况下，tomcat会创建一个线程来处理每个请求。现在发生了什么

如果使用Tomcat 8.0中默认的NIO连接器。X，在整个处理周期内，关于HTTP I/O的请求不会保持线程。如果使用BIO，线程将被保持，直到整个处理周期完成。所有线程都来自线程池，tomcat不会为每个请求创建线程。

执行eventSource。浏览器端的close（）是最佳选择。

不要忘记调用AsyncContext。在服务器端完成（）。

浏览器中的EventSource API只支持GET请求，但在服务器端没有这种限制。SSE主要用于从服务器接收事件数据。如果事件发生，浏览器可以及时接收到它，并且不需要创建新的请求来轮询它。如果您需要全双工通信，请尝试SSE的WebSocket instriad。

如果我们使用NIO连接器，应该不会有性能问题