Node.js ws库中ws.on与ws.onmessage的区别及问题解析

先帮你理清这个问题，其实核心是Node.js的ws库和浏览器原生WebSocket API的事件绑定差异，你遇到的报错也和这个直接相关。

1. 两者的本质区别 #

（1）ws.onmessage：浏览器API的兼容写法 #

这是浏览器原生WebSocket对象的标准属性，用来赋值消息接收的回调函数。在ws库中，虽然也支持这个写法，但有个关键差异：

• 浏览器中onmessage的回调参数是一个MessageEvent对象，你需要通过event.data获取实际的数据；
• 但在ws库中，直接赋值onmessage时，回调的参数就是原始的data（可能是Buffer或字符串），不过这种写法是ws库为了兼容浏览器API做的适配，并不是它的原生事件绑定方式。

（2）ws.on('message', callback)：Node.js EventEmitter原生写法 #

ws库的WebSocket实例本质是继承了Node.js的EventEmitter类，所以它的标准事件绑定方式是用on()方法（和Node.js里所有事件驱动的模块一致，比如http、fs）。

• 这种方式下，回调函数的第一个参数就是接收到的数据（同样可能是Buffer或字符串），这也是ws库官方推荐的写法；
• 它支持绑定多个同事件的回调函数，而直接赋值onmessage会覆盖之前的回调。

2. 你的报错原因分析 #

你之前用wss.onmessage = (data) => {}时出现unknown compression method错误，大概率是因为：
虽然参数看起来都是data，但在某些场景下，ws库的onmessage兼容写法在处理二进制数据时，传递的Buffer格式或处理逻辑和on('message')有细微差异，导致pako.inflate无法正确解析火币API返回的gzip数据。而改用on('message')后，数据传递符合ws库的原生逻辑，所以pako能正常解压数据。

3. 额外的小建议（针对你的代码） #

• 记得把const WebSocket = require('ws');和const pako = require('pako');移到函数外面，不要在函数内部重复引入模块，这是Node.js的最佳实践；
• 处理data时，可以先判断一下类型，避免字符串数据带来的问题，比如：

wss.on('message', (data) => {
    let text;
    if (Buffer.isBuffer(data)) {
        text = pako.inflate(data, { to: 'string' });
    } else {
        text = data;
    }
    // 后续解析逻辑...
})

内容的提问来源于stack exchange，提问作者GerM