const express = require('express');const app = express();const ws = require('ws').Server;const wss = new ws({port: 3001});var sockets = [];wss.on('connection', function(ws) { ws.send('连接成功'); sockets.push(ws); ws.on('message', function(data) { ws.send(data); try { sockets.forEach(function (socket) { if (ws != socket) { socket.send(data); } }); } catch (err) { console.log(err); } }); ws.on('error', function(e) { console.log(e); }); ws.on('close', function(e) { console.log(e); });});app.use(express.static(__dirname)).listen(3000, 'localhost');app.get('/', (req, res) => { res.sendFile(__dirname+'/websocket.html');});
websocket