Как создать сервер источника событий с помощью Spring загрузки?

Question

Как создать сервер событий с использованием весеннего загрузочного приложения? Из приведенной ниже ссылки я не вижу пример загрузки 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 «s, чтобы удовлетворить свою потребность. Его ответ. Но никогда не завершайте соединение, когда вкладка браузера закрывается. Его работа выполняется на стороне сервера. Все, что связано с 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; 
    }