// 引入必要的模块
const WebSocket = require('ws');
// 创建一个 WebSocket 服务器,监听端口 8080
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');
ws 模块 (npm install ws),然后通过 require 引入。WebSocket.Server 创建一个 WebSocket 服务器,并指定监听端口为 8080。connection 事件。每次连接都会创建一个新的 WebSocket 实例 ws。message 事件以接收来自客户端的消息,并通过 wss.clients.forEach 将消息广播给所有连接的客户端。close 事件并输出日志。这个示例展示了如何创建一个简单的 WebSocket 服务器,接收消息并广播给所有连接的客户端。
上一篇:js string slice
下一篇:nodejs websocket
Laravel PHP 深圳智简公司。版权所有©2023-2043 LaravelPHP 粤ICP备2021048745号-3
Laravel 中文站