单TCP Socket上实现多路复用连接的Node.js技术咨询

先明确：你想通过readableHighWaterMark和writableHighWaterMark控制分片大小的思路不可行——TCP的分片是由操作系统TCP栈、网络链路（比如路由器MTU）决定的，Node.js的这些配置只是控制本地流的缓冲区阈值，没法强制TCP发送固定大小的数据包，所以依赖分片大小来识别前缀的方案根本靠不住。

给你几个实际能用的解决方案：

1. 固定长度头部+消息体模式（最可靠） #

这是工业界最常用的TCP消息分包方案，完全规避分片问题：

• 每条消息的结构分成两部分：固定字节数的长度头 + 实际消息内容
  • 比如用4字节无符号整数（UInt32）作为长度头，这个数值代表后续消息内容的字节数
  • 消息内容里再包含你的程序标识（比如"1:"）和具体消息体
• 接收方逻辑：
  1. 先累计接收数据，直到凑够4字节的长度头
  2. 解析出长度头对应的字节数，再继续累计接收对应长度的消息内容
  3. 拿到完整的消息内容后，再拆分程序标识和消息体，分发到对应程序

举个Node.js的简单示例：

// 发送端（A机器）
function sendMessage(socket, appId, content) {
  const msg = `${appId}:${content}`;
  const lengthBuf = Buffer.alloc(4);
  lengthBuf.writeUInt32BE(msg.length, 0); // 大端序写入长度
  socket.write(Buffer.concat([lengthBuf, Buffer.from(msg)]));
}

// 接收端（B机器）
let remainingBuf = Buffer.alloc(0);
socket.on('data', (chunk) => {
  remainingBuf = Buffer.concat([remainingBuf, chunk]);
  
  // 循环处理所有完整的消息
  while (remainingBuf.length >= 4) {
    const msgLength = remainingBuf.readUInt32BE(0);
    // 检查是否已经收到完整的消息内容
    if (remainingBuf.length >= 4 + msgLength) {
      const msgContent = remainingBuf.slice(4, 4 + msgLength).toString();
      // 拆分程序标识和消息
      const [appId, content] = msgContent.split(':', 2);
      // 分发到对应程序（比如B.1或B.2）
      if (appId === '1') {
        // 传给B.1
      } else if (appId === '2') {
        // 传给B.2
      }
      // 截取剩余未处理的缓冲区
      remainingBuf = remainingBuf.slice(4 + msgLength);
    } else {
      // 消息内容还没接收完整，等待下一个data事件
      break;
    }
  }
});

2. 特殊分隔符法（简单但需注意转义） #

如果你不想处理二进制头部，可以用特殊的分隔符标记每条消息的结束：

• 比如选一个业务消息里不会出现的字符/字符串作为分隔符，比如|||END|||
• 发送端在每条消息（带程序标识）末尾加上分隔符
• 接收端累计数据，直到遇到分隔符，就把之前的内容作为完整消息处理，再拆分标识分发

⚠️ 注意：如果业务消息里可能出现分隔符，必须提前对消息体里的分隔符进行转义，接收端再反转义，否则会导致消息拆分错误。

3. 基于现有协议封装（偷懒但高效） #

如果不想自己造轮子，可以直接用成熟的应用层协议来做路由：

• 比如用MQTT协议：把A.1/B.1对应一个主题（比如app/1），A.2/B.2对应另一个主题（app/2），TCP连接作为MQTT的底层传输，天然支持多主题消息路由
• 或者用WebSocket的子协议，自定义帧结构来携带程序标识，WebSocket本身已经解决了TCP分片的分包问题

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