如何使用 Spring 引导创建事件源服务器？

Question

如何使用 spring 引导应用程序创建事件源服务器？从下面的 link 中，我没有看到 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;
    }

如何使用 Spring 引导创建事件源服务器？

How to create Event-source server using Spring boot?

java

spring

angularjs

spring-boot

eventsource