node.JS中操作websocket的核心是使用ws库创建服务器和客户端，通过事件驱动实现双向通信。首先安装ws库，创建http服务器并绑定WebSocket服务器，监听connection事件处理客户端连接，利用message、close、Error事件处理消息收发、连接关闭和错误。客户端通过new WebSocket()连接服务器，使用onopen、onmessage、onclose、onerror进行交互。数据传输通过send()发送，message事件接收，注意数据类型统一。错误处理需监听error事件，区分服务器与连接级错误；关闭事件通过close回调获取code和reason，判断关闭原因并执行重连或资源清理，确保应用健壮性。
在Node.js中操作WebSocket，我们通常会借助成熟的第三方库，最流行且功能全面的当属
ws
库。它提供了一套简洁而强大的API，无论你是想搭建一个WebSocket服务器，还是构建一个WebSocket客户端，都能轻松实现实时双向通信。核心思路无非就是监听连接、处理消息、以及在适当时候关闭连接，这一切在Node.js异步非阻塞的特性下显得尤其高效。
Node.js中如何操作WebSocket，其核心在于利用
ws
这样的库来创建服务器实例，监听客户端连接请求，并在连接建立后，通过事件监听器处理消息的接收与发送。这包括了设置服务器端口、定义消息处理逻辑（如
on('message')
）、处理连接断开（
on('close')
）和错误（
on('error')
）等关键步骤。对于客户端，同样是创建WebSocket实例，指定服务器地址，然后通过类似的事件监听机制与服务器进行交互。
Node.js中搭建WebSocket服务器的基本步骤是什么？
说实话，第一次接触WebSocket的时候，总觉得它是个挺神秘的东西，毕竟和传统的HTTP请求/响应模式大相径庭。但当你真的上手用
ws
库在Node.js里搭起来，会发现它其实非常直观。我个人觉得，最关键的就是理解“事件驱动”这个核心。
搭建WebSocket服务器，首先你得安装
ws
库：
npm install ws
。然后，代码层面大致是这样的：
const WebSocket = require('ws'); const http = require('http'); // WebSocket通常运行在HTTP服务器之上 // 创建一个HTTP服务器，WebSocket服务器可以依附于它 const server = http.createServer((req, res) => { res.writeHead(200, { 'Content-Type': 'text/plain' }); res.end('WebSocket server is running.n'); }); // 创建WebSocket服务器实例，并绑定到HTTP服务器 const wss = new WebSocket.Server({ server }); wss.on('connection', ws => { console.log('一个新的客户端连接了！'); ws.on('message', message => { // 收到消息，这里可以做各种处理，比如广播给所有连接的客户端 console.log(`收到消息: ${message}`); // 假设我们只是把收到的消息原封不动地发回去 ws.send(`服务器收到你的消息: ${message}`); }); ws.on('close', () => { console.log('一个客户端断开连接了。'); }); ws.on('error', error => { console.error('WebSocket 错误:', error); }); // 连接建立后，也可以主动向客户端发送消息 ws.send('欢迎连接到我的WebSocket服务器！'); }); // 启动HTTP服务器，监听端口 const PORT = 8080; server.listen(PORT, () => { console.log(`WebSocket服务器在 http://localhost:${PORT} 上运行`); });
这段代码里，我们先创建了一个普通的HTTP服务器，这并不是必须的，但很多时候WebSocket会和HTTP服务共用端口，或者WebSocket协议握手就是基于HTTP的。然后，我们把
WebSocket.Server
实例绑定到这个HTTP服务器上。
wss.on('connection', ...)
是关键，每当有新的客户端连接成功，这个回调函数就会被触发，并传入一个代表该客户端连接的
ws
对象。所有的消息收发、错误处理和连接关闭，都是围绕这个
ws
对象进行的。
如何在Node.js WebSocket客户端与服务器之间发送和接收数据？
客户端与服务器之间的数据交换，是WebSocket的核心价值所在。在我看来，它最大的魅力就是那种“实时性”和“双向性”，感觉就像是开了一条专线，想发就发，想收就收，不用像HTTP那样每次都得“请求-响应”走一套流程。
服务器端发送和接收数据：
在上面的服务器代码中，我们已经看到了接收数据和发送数据的例子。
- 接收数据： 通过
ws.on('message', message => { ... })监听客户端发送过来的消息。
message
通常是Buffer类型，如果你发送的是文本，需要
message.toString()
来转换。
- 发送数据： 通过
ws.send(data)
方法向特定的客户端发送数据。
data
可以是字符串、Buffer或ArrayBuffer。
客户端发送和接收数据：
客户端的逻辑与服务器端异曲同工，也是基于事件的。你可以用浏览器内置的
WebSocket
API，也可以在Node.js环境中使用
ws
库作为客户端。这里以Node.js客户端为例：
const WebSocket = require('ws'); // 连接到服务器 const ws = new WebSocket('ws://localhost:8080'); ws.onopen = () => { console.log('成功连接到WebSocket服务器。'); // 连接成功后，可以立即发送消息 ws.send('你好，服务器！我是客户端。'); }; ws.onmessage = Event => { // 收到服务器发送过来的消息 console.log(`收到服务器消息: ${event.data}`); // 可以在收到特定消息后，再发送一条消息 if (event.data.includes('欢迎')) { setTimeout(() => { ws.send('服务器，我收到你的欢迎了！'); }, 1000); } }; ws.onerror = error => { console.error('WebSocket客户端错误:', error); }; ws.onclose = () => { console.log('与服务器的连接已关闭。'); }; // 模拟一段时间后客户端主动关闭连接 setTimeout(() => { if (ws.readyState === WebSocket.OPEN) { ws.close(); console.log('客户端主动关闭连接。'); } }, 5000);
这里需要注意
event.data
，它直接包含了服务器发送过来的数据。无论是服务器还是客户端，发送的数据类型最好保持一致，或者在接收端做好类型转换和解析工作，比如约定好都发送json字符串，然后
JSON.parse()
。这种数据格式的统一，是保证通信顺畅的关键。
Node.js WebSocket连接中如何处理错误和关闭事件？
处理错误和连接关闭，这绝对是构建任何健壮网络应用不可或缺的一环。在我做项目的时候，早期总是把重心放在“功能实现”上，而对异常处理考虑不足，结果线上环境一出问题就抓瞎。后来才明白，优雅地处理异常和关闭，才是区分一个玩具项目和生产级应用的标志。
错误处理 (
ws.on('error', ...)
):
无论是服务器还是客户端，
error
事件都至关重要。它会在网络问题、协议解析错误、或者其他底层错误发生时被触发。
在服务器端：
wss.on('connection', ws => { // ... 其他事件监听 ... ws.on('error', error => { // 捕获特定客户端连接的错误 console.error('单个客户端连接错误:', error.message); // 这里可以记录日志，或者尝试关闭这个有问题的连接 // ws.terminate(); // 强制关闭，不发送任何关闭帧 }); }); wss.on('error', error => { // 捕获整个WebSocket服务器的错误，比如端口被占用等 console.error('WebSocket服务器全局错误:', error.message); // 对于服务器全局错误，可能需要重启服务或者报警 });
针对单个
ws
实例的错误，通常是该连接自身的问题。而
wss
（WebSocket服务器）实例上的错误，则可能是更全局性的问题，比如服务器启动失败。
在客户端：
ws.onerror = error => { console.error('WebSocket客户端连接错误:', error); // 客户端错误可能意味着连接失败、断开，或者数据传输问题 // 此时可以尝试重连，或者通知用户连接异常 };
客户端的错误处理同样重要，它决定了你的应用在网络不稳定或服务器故障时，能否给出友好的提示或进行自动恢复。
关闭事件 (
ws.on('close', ...)
/
ws.onclose
):
连接的关闭是正常生命周期的一部分，但它也可能因为异常而发生。理解关闭事件的
code
和
reason
非常有用。
在服务器端：
wss.on('connection', ws => { // ... ws.on('close', (code, reason) => { console.log(`客户端连接关闭。Code: ${code}, Reason: ${reason ? reason.toString() : '无'}`); // code 是一个数字，表示关闭的原因，比如 1000 表示正常关闭 // reason 是一个可选的字符串，提供更多细节 // 可以在这里清理与该客户端相关的资源，比如从活跃连接列表中移除 }); });
在客户端：
ws.onclose = event => { console.log(`与服务器的连接已关闭。Code: ${event.code}, Reason: ${event.reason}`); // event.code 和 event.reason 与服务器端类似 // 根据关闭码判断是否需要自动重连，例如： if (event.code !== 1000) { // 1000是正常关闭 console.log('连接异常关闭，尝试重连...'); // setTimeout(() => { /* 重新创建WebSocket连接 */ }, 3000); } };
code
有很多标准值，例如
1000
表示正常关闭，
1001
表示端点离开（比如浏览器页面关闭），
1006
表示异常关闭（无关闭帧）。通过判断这些
code
，我们可以更智能地处理连接断开后的逻辑，比如是否进行重连，或者记录日志进行分析。这种细节的处理，往往能大大提升应用的鲁棒性。
评论（已关闭）
评论已关闭