在Java Web服务器上发送服务器事件

我有一个使用Spring Framework的Java Web服务器，我想使用Server Sent Events在每秒向Web客户端发送通知。在Java Web服务器上发送服务器事件

我的控制器，用于这些通知看起来像这样：

@Controller 
public class NotificationController { 

    private static final String REST_PREFIX = "/rest/notifications"; 

    @RequestMapping(value = {REST_PREFIX}, method = {RequestMethod.GET}) 
    synchronized public void getMonitoringNotifications(HttpServletRequest request, HttpServletResponse response) { 
     response.setContentType("text/event-stream;charset=UTF-8"); 
     response.setHeader("Cache-Control", "no-cache"); 
     response.setHeader("Connection", "keep-alive"); 

     try { 
      PrintWriter out = response.getWriter(); 
      int i = 0; 

      while (true) { 
       out.print("id: " + "ServerTime" + "\n"); 
       out.print("data: " + (i++) + "\n\n"); 
       out.flush(); 

       Thread.currentThread().sleep(1000); 
      } 
     } catch (Exception e) { 
      e.printStackTrace(); 
     } 
    } 
}

我的问题是，代替1秒后接收每个通知，客户端等待要被发送的所有通知。如果我尝试发送一些通知，比如30，在客户端我会在最后收到它们。

我的客户是一个简单的，因为它只监听特定端点接收通知：

<!DOCTYPE html> 
<html> 
<body> 
<h1>Notification received : </h1> 

<div id="ServerTime"></div> 

<script> 
    if (typeof (EventSource) !== "undefined") { 
    var source = new EventSource("https://10.241.53.185/rest/notifications"); 
    source.addEventListener('message', function(event) { 
    console.log(event.data); 
    }); 
    } else { 
    document.getElementById("ServerTime").innerHTML = "Working, processing, getting info...."; 
    } 
</script> 

</body> 
</html>

能否请你帮我这个问题？

谢谢

来源

2016-12-14 Ancuta

这显然不是向客户端发送信息的方式。作为结果，使用'SseEmitter'或'StreamingResponseBody'。 –

感谢您的信息。我还发现我的代码存在问题，因为我需要在不同的线程中写入打印机。 – Ancuta

您需要使用SseEmitter发送事件。见Server-Sent Events with Spring（博客）。

您还应该从单独的线程发送事件（让请求线程返回）。

来源

2017-11-10 23:23:32 rwfbc

谢谢，这真的很有帮助。 – Ancuta

在Java Web服务器上发送服务器事件

回答

相关问题