En Spring Boot, cuando intentamos enviar un evento enviado por el servidor, solo envía un evento de error que contiene datos: {"timeout":-1} cuando intentamos conectarnos y la conexión se cierra. La clase Spring Boot es la siguiente
@RestController @CrossOrigin(origins = "*") public class SsePushNotificationRestController { private static final Logger log = LoggerFactory.getLogger(SsePushNotificationRestController.class); private SseEmitter emitter; @GetMapping("/test") public String getString(){ try { emitter.send("User connected"); log.info("User connected"); emitter.complete(); } catch (Exception e) { log.info("Error while sending message to client: " + e.getMessage()); } return "placeholder"; } @GetMapping("/emitter") public SseEmitter eventEmitter(@RequestParam String userId) { emitter = new SseEmitter(-1L); return emitter; } }Y nuestro código de cliente es el siguiente:
const eventSource = new EventSource('http://localhost:8080/emitter?userId=testUser'); eventSource.addEventListener("message", (event) => { console.log(event); }); eventSource.addEventListener("open", (event) => { console.log("connection opened"); }); eventSource.addEventListener("error", (e) => { if (e.readyState === EventSource.CLOSED) { console.log('closed'); } else { console.log(e); } e.target.close(); }); document.getElementById("btn").onclick = e => { fetch('http://localhost:8080/test').then( data => console.log(data)).catch(data => console.log(data)); }; Inmediatamente, se crea un error antes de que podamos hacer clic en el botón para generar un evento.
¿Qué podría estar mal?
¿Qué dice tu terminal de arranque Spring? Creo que necesito esa información para solucionar el error de su programa. Por cierto, permitir el intercambio de recursos de origen cruzado para solicitudes de cualquier fuente (usando comodines) es una práctica muy, muy mala.
Una posible razón de error es que algo anda mal cuando crea una instancia de SSEemitter. (nuevo SSeEmitter(-1L))
SSeEmitter (Tiempo de espera largo) está creando un evento del lado del servidor con el tiempo de espera establecido, dice. Entonces, si el tiempo de espera es -1, supongo que se agotaría inmediatamente y devolvería la respuesta de tiempo de espera. Entonces no sería un error, solo funcionaría como está escrito