Node.js捕获Home Assistant WebSocket数据无法解码的问题求助

你遇到的问题核心是：直接监听底层socket的data事件拿到的是WebSocket协议的原始帧数据，不是实际传输的JSON消息内容。WebSocket协议会对消息进行帧封装（包含掩码、操作码等协议头信息），所以直接转字符串会出现乱码，自然无法JSON解析。

解决方案：用WebSocket库解析帧数据 #

不要直接操作底层socket，改用能处理WebSocket帧的库（比如ws）来代理并解析消息。下面是修改后的完整代码：

const http = require('http');
const httpProxy = require('http-proxy');
const WebSocket = require('ws');

// 创建HTTP代理
const proxy = httpProxy.createProxyServer({
  target: { host: 'localhost', port: 8123 }
});

const proxyServer = http.createServer((req, res) => {
  console.log('HTTP请求已接收');
  proxy.web(req, res);
});

// 处理WebSocket升级请求
proxyServer.on('upgrade', (req, clientSocket, head) => {
  console.log('WebSocket升级请求已接收');

  // 连接到Home Assistant的WebSocket服务
  const haWs = new WebSocket(`ws://localhost:8123${req.url}`);

  // 客户端->HA的消息转发与解析
  clientSocket.on('data', (data) => {
    // 把原始帧转发给HA
    haWs.send(data);
  });

  // HA->客户端的消息转发与解析
  haWs.on('message', (message) => {
    // 这里拿到的是已经解帧后的实际消息
    console.log('收到HA的WebSocket消息：', message.toString());
    try {
      const jsonData = JSON.parse(message);
      console.log('解析后的JSON数据：', jsonData);
    } catch (err) {
      console.error('JSON解析失败：', err);
    }
    // 把消息转发给客户端
    clientSocket.write(message);
  });

  // 处理连接关闭
  clientSocket.on('close', () => haWs.close());
  haWs.on('close', () => clientSocket.end());

  // 处理错误
  haWs.on('error', (err) => console.error('HA WS连接错误：', err));
  clientSocket.on('error', (err) => console.error('客户端WS连接错误：', err));
});

// 启动代理服务器
proxyServer.listen(8080, () => {
  console.log('代理服务器已启动，监听端口8080');
});

代码说明 #

1. 引入ws库来处理WebSocket帧的编解码，不需要手动解析原始字节流
2. 分别监听客户端和HA之间的消息流动：
   • 客户端发给HA的原始帧直接转发
   • HA返回的消息已经被ws库解帧，直接转字符串就能得到JSON格式的内容，可正常解析
3. 同时处理连接关闭和错误事件，保证代理稳定性

注意事项 #

• 先安装依赖：npm install http-proxy ws
• 把前端的WebSocket连接地址改成代理地址（比如ws://localhost:8080/api/websocket）

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