39 lines
1.2 KiB
JavaScript
39 lines
1.2 KiB
JavaScript
|
|
// 首先获取到一个 WebSocketServer 类
|
|
var WebSocketServer = require("ws").Server;
|
|
|
|
// 创建 WebSocket 服务器
|
|
var wss = new WebSocketServer({
|
|
port : 3000
|
|
})
|
|
|
|
// 该数组用于保存所有的客户端连接实例
|
|
var clients = [];
|
|
|
|
// 当客户端连接上 WebSocket 服务器的时候
|
|
// 就会触发 connection 事件，该客户端的实例就会传入此回调函数
|
|
wss.on("connection", function(client){
|
|
// 将当前客户端连接实例保存到数组里面
|
|
clients.push(client);
|
|
console.log(`当前有${clients.length}个客户端在线...`);
|
|
|
|
// 给传入进来的客户端连接实例绑定一个 message 事件
|
|
client.on('message', function(msg){
|
|
console.log("收到的消息为：" + msg);
|
|
// 接下来需要将接收到的消息推送给其他所有的客户端
|
|
for(var c of clients){
|
|
if(c !== client){
|
|
c.send(msg.toString());
|
|
}
|
|
}
|
|
})
|
|
|
|
client.on('close',function(){
|
|
var index = clients.indexOf(this);
|
|
clients.splice(index, 1);
|
|
console.log(`当前有${clients.length}个客户端在线...`);
|
|
})
|
|
})
|
|
|
|
console.log("Web Socket 服务器已经启动....");
|