Java Frühling SseEmitter/ResponseBodyEmitter: Ermitteln Browser neu geladen

Question

Ich benutze serverseitige Ereignisse (SSE) in Java Spring. Jedes Mal, wenn ein neuer Client abonniert das Ereignis Service, den ich den folgenden Code an dem REST-Controller ausführen:

SseEmitter emitter = new SseEmitter(-1L); 
emitter.onCompletion(() -> { 
     logger.debug(TAG + "Emitter completed."); 
     emitters.remove(emitter); 
    }); 
return emitter; 

Dann, wenn ein Ereignis an den Kunden mitgeteilt werden muß ich ausführen:

for (ResponseBodyEmitter emitter: emitters) { 
     emitter.send("Message #1"); 
} 

Das Problem Wenn einer der Clients den Browser neu lädt, wird der Emitter nicht (wie erwartet) abgeschlossen, und beim Aufruf des obigen Codes erhalte ich eine Ausnahme für unterbrochene Pipes. Erst nachdem diese Ausnahme ausgelöst wurde, sehe ich, dass der Emitter abgeschlossen ist.

Gibt es eine Möglichkeit, dieses Problem zu lösen?

Answer 1

Wenn der Browser neu lädt, wird es eine neue EventSource zu Ihrem Server einrichten, richtig? Ihr Problem ist mit dem alten, das keinen Client-Endpunkt mehr hat.

Ich schlage vor, Sie versuchen zu erkennen, dass es die gleiche Client-Verbindung ist, und dann explizit auf dem alten Emitter aufrufen.

In meinem Fall kann ich dies anhand eines Tokens erkennen, das von der EventSource als URL-Parameter übergeben wird. Wenn ich den neu erstellten Emitter an ein "Benutzerobjekt" anschließe, vergewissere ich mich, dass ich den vorherigen Emitter abgeschlossen habe, bevor ich das Neue der Benutzerfeldvariablen zugewiesen habe.

Aus Ihrem Code scheint es, dass Sie eine Liste oder einen Satz von Emittern haben. Können Sie vielleicht stattdessen eine Karte erstellen, in der Sie eine Client-Identität als Schlüssel und den Emitter als Wert haben?

Ich kann Ihnen nicht genau sagen, welche Information als Client-Identität zu verwenden ist, da alles von Ihrer Anwendung abhängt. In meinem Fall ist es ein JWT-Token, aber Sie könnten vielleicht einfach ein Client-Nummerierungsschema erstellen ...