如何使用Spring启动创建事件源服务器？

Question

如何使用spring启动应用程序创建事件源服务器？ 从下面的链接中，我没有看到Java-spring启动示例。 任何参考将有所帮助。

http://www.html5rocks.com/en/tutorials/eventsource/basics/

Answer 1

这是Spring 4.2的简单实现。不要顾及线程，它的存在只是用于演示目的：

@RestController 
public class AccountsRestController { 

    @RequestMapping("/accounts/alerts") 
    public SseEmitter getAccountAlertsNoPathVariable(HttpSession session) { 

     SseEmitter emitter = new SseEmitter(Long.MAX_VALUE); 

     Thread t1 = new Thread(() ->{ 
      try { 
       int i = 0; 
       // Send 10000 messages 
       while(++i<=10000){ 
        Thread.sleep(1000); 
        System.out.println("Sending"); 
        try{ 
         emitter.send(new Alert((long)i, "Alert message"+i)); 
        }catch(ClientAbortException cae){ 
         //The client is not there anymore, we get out of the loop 
         i = 10000; 
        } 
       } 
       emitter.complete(); 
      } catch (IOException | InterruptedException e) { 
       e.printStackTrace(); 
      } 
     }); 
     t1.start(); 

     return emitter; 
    } 

Answer 2

我试着下面的代码，从@codependent的解决方案重写，以满足我的需要。它的回应。但是，在浏览器选项卡关闭时不要终止连接。它继续在服务器端运行。任何与HTTP GET有关的事情？

@RequestMapping(value = "/getNotificationCount/{userId}",method = RequestMethod.GET) 
    public SseEmitter getNotificationCount(@PathVariable("userId") String userId, HttpServletResponse response){ 
     SseEmitter emitter = null; 
     try { 
      emitter = new SseEmitter(); 

      while(true) { 
       try{ 
        int count= myService.getNotificationCount(Integer.parseInt(userId)); 
        emitter.send(count); 
        Thread.sleep(30 * // minutes to sleep 
           60 * // seconds to a minute 
           1000); // milliseconds to a second 

       }catch(ClientAbortException cae){ 
        LOGGER.info("ClientAbortException Breaking the notification stream"); 
        break; 
       } 
      } 

      //Closes the stream 
      emitter.complete(); 

     } catch (Exception e) { 
      //Closes the stream 
      emitter.complete(); 
     } 

     return emitter; 
    }