PROBLEMA
Se desea enviar un mensaje a todos los clientes conectados al Servidor websockets/ws
creado mediante el paquete express-ws
.
Se utiliza el método send()
del objeto ws
, el cual es una instancia de la Clase WebSocket
.
Dicho método sólo envía un mensaje al cliente que originó el evento message
. Se desea enviar un mensaje a todos los clientes conectados al servidor.
SOLUCIÓN
El tipo de mensaje que deseas enviar es conocido como difusión (broadcast) y es el tipo de mensaje que se envía a todos los clientes conectados al servidor.
El método send()
por si solo no funciona para enviar este tipo de mensaje, y no existe un método directo para enviar un mensaje de este tipo en websockects
. Por lo cual debemos crear nuestro propio método.
Para ello necesitamos conocer la lista de clientes conectados al Servidor. Esto lo logramos usando el método getWss()
que tiene una propiedad llamada clients
la cual es una lista de todos los clientes conectados al servidor WS.
La forma de obtener esta lista es:
const expressWs = require('express-ws')(app);
// ...
const clients = expressWS.getWss().clients;
Ahora, para enviar el mensaje de difusión a todos los clientes conectados, podríamos hacer lo siguiente:
clients.forEach(client => {
client.send('Hola mundo');
});
Nuestro código (muy sencillo) podría quedar así:
const expressWs = require('express-ws')(app);
//...
app.ws('/mensajes', (ws, req)=>{
ws.on('message', msg => {
const clients = expressWS.getWss().clients;
clients.forEach(client => {
client.send(msg);
});
});
});
De esta forma cada usuario conectado al servidor WS recibirá el mensaje.
Esto es una solución al problema planteado en la pregunta. Sin embargo, hay un par de detalles con la lógica de este código:
- El mensaje enviado por un cliente será devuelto a todos los usuarios incluyendo al mismo cliente.
- El mensaje será enviado a todos los clientes, no sólo a aquellos que hayan accedido a una ruta específica.
Esos problemas serían parte de otra pregunta y si ese es el caso, te invito a realizar la misma en el sitio.