Wie erstelle ich einen Event-Source-Server mit Spring Boot?

Question

Wie erstellt man Ereignisquelle Server mit Spring-Boot-Anwendung? Von dem folgenden Link sehe ich kein Java-Spring-Boot-Beispiel. Jede Referenz würde helfen.

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

Answer 1

Dies ist eine einfache Implementierung mit Feder 4.2. Nehmen Sie nicht die Berücksichtigung der Faden, dann ist es nur zu Demonstrationszwecken:

@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

Ich habe mit dem folgenden Code versucht, neu geschrieben von @codependent ‚s Lösung mein Bedürfnis gerecht zu werden. Es reagiert. Beenden Sie die Verbindung jedoch niemals, wenn die Browser-Registerkarte geschlossen wird. Es läuft auf der Serverseite. Alles was mit HTTP GET hier zu tun ist?

@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; 
    }