// 引入 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 中文站