Sorgente Java SseEmitter/ResponseBodyEmitter: rileva il caricamento del browser

Question

Utilizzo gli eventi lato server (SSE) in Java Spring. Ogni volta che un nuovo cliente sottoscrive il servizio di eventi eseguo il seguente codice al controllore REST:

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

Poi, ogni volta che un evento deve essere notificato ai clienti eseguo:

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

Il problema è che quando uno dei client ricarica il browser, l'emettitore non viene completato (come mi aspettavo) e ottengo un'eccezione di pipe non corretta quando si chiama il codice sopra. Solo dopo che questa eccezione è stata attivata, vedo che l'emettitore è stato completato.

C'è un modo per risolvere questo problema?

Answer 1

Quando il browser viene ricaricato, verrà stabilita una nuova EventSource sul server, giusto? Il tuo problema è con quello vecchio, che non ha più un endpoint client.

Suggerisco di provare a rilevare che è lo stesso client che si connette e quindi chiama esplicitamente completo sul vecchio emettitore.

Nel mio caso posso rilevare questo in base a un token che passa l'EventSource come parametro URL. Quando collego l'emettitore appena creato a un "oggetto utente", mi assicuro di completare l'emettitore precedente prima di assegnare il nuovo alla variabile del campo utente.

Dal tuo codice, sembra che tu abbia una lista o una serie di emettitori. Puoi magari renderlo una mappa, dove hai l'identità del client come chiave e l'emettitore come valore?

Non posso dire esattamente quale informazione utilizzare come identità del client, poiché tutto dipende dall'applicazione. Nel mio caso è un token JWT, ma potresti semplicemente creare uno schema di numerazione client ...