// 引入 WebSocket 库
const WebSocket = require('ws');
// 创建 WebSocket 服务器
const wss = new WebSocket.Server({ port: 8080 });
// 当有新的客户端连接时触发
wss.on('connection', (ws) => {
console.log('新客户端已连接');
// 监听来自客户端的消息
ws.on('message', (message) => {
console.log(`收到消息: ${message}`);
// 广播消息给所有连接的客户端
wss.clients.forEach((client) => {
if (client.readyState === WebSocket.OPEN) {
client.send(`广播消息: ${message}`);
}
});
});
// 当客户端断开连接时触发
ws.on('close', () => {
console.log('客户端已断开');
});
});
console.log('WebSocket 服务器已启动,监听端口 8080');
require('ws')
引入 WebSocket 库。new WebSocket.Server()
创建一个 WebSocket 服务器,并指定监听端口为 8080。connection
事件。每个连接的客户端会触发一次该事件。message
事件,当收到客户端发送的消息时,可以进行处理(例如广播给其他客户端)。OPEN
状态的客户端。close
事件,可以在此处执行清理操作。上一篇:js string slice
下一篇:nestjs websocket
Laravel PHP 深圳智简公司。版权所有©2023-2043 LaravelPHP 粤ICP备2021048745号-3
Laravel 中文站