25 lines
839 B
JavaScript
25 lines
839 B
JavaScript
|
// Importaciones
|
||
|
|
const WebSocket = require('ws');
|
||
|
|
const http = require('http');
|
||
|
|
|
||
|
|
// Creamos una instacia del servidor HTTP (Web)
|
||
|
|
const server = http.createServer();
|
||
|
|
// Creamos y levantamos un servidor de WebSockets a partir del servidor HTTP
|
||
|
|
const wss = new WebSocket.Server({ server });
|
||
|
|
|
||
|
|
// Escuchamos los eventos de conexión
|
||
|
|
wss.on('connection', function connection(ws) {
|
||
|
|
// Escuchamos los mensajes entrarntes
|
||
|
|
ws.on('message', function incoming(data) {
|
||
|
|
// Iteramos todos los clientes que se encuentren conectados
|
||
|
|
wss.clients.forEach(function each(client) {
|
||
|
|
if (client.readyState === WebSocket.OPEN) {
|
||
|
|
// Enviamos la información recibida
|
||
|
|
client.send(data);
|
||
|
|
}
|
||
|
|
});
|
||
|
|
});
|
||
|
|
});
|
||
|
|
|
||
|
|
// Levantamos servidor HTTP
|
||
|
|
server.listen(8080);
|