服务器发送事件如何工作

服务器发送事件如何工作

更改此行

writer.write("data: "+ i +"nn");

至

writer.write("data: "+ i +"rn");

顺便说一句，您的代码将出现严重的性能问题，因为它将保留线程，直到发送所有事件为止。请改用异步处理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 happensactx.getResponse().getWriter().write("data: " + mydata + "rn");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: 36000000000rn"); // 10000 hours!    actx.getResponse().getWriter().flush();    //save actx and use it when we need sent data to the client.}

更新2：

我认为Websocket可能更适合您的情况。

更新3 ：（回答问题）

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

如果使用Tomcat 8.0.X中默认的NIO连接器，则在整个处理周期内，有关请求的HTTP I /
O将不会容纳线程。如果使用BIO，则将保留一个线程，直到整个处理周期结束。所有线程均来自线程池，tomcat不会为每个请求创建线程。

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

不要

eventSource.close()

在浏览器端是最好的选择。

1. 确保事件流关闭且服务器上没有资源开销的正确方法是什么？
   

不要忘记在服务器端调用AsyncContext.complete（）。

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

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

1. 在Tomcat上使用SSE还为时过早吗？有性能问题吗？
   

如果我们使用NIO连接器和异步处理API，应该不会有性能问题。我不知道Tomcat NIO连接器是否成熟，但是除非我们尝试尝试，否则永远不会知道。