如何在Node.js的net.Socket()中获取TCP的ACK/PSH标志信息？

首先明确：Node.js的net.Socket确实不提供直接访问TCP头部标志（比如PSH、ACK）的能力，所以你想靠TCP标志判断数据包结束的路子走不通。

其实MySQL/MariaDB的协议本身就定义了数据包的边界，根本不用依赖TCP层的信息——每个MySQL数据包的开头都有3个字节表示数据包长度，加上1个字节的序列号。你要做的就是先读取这4个字节，算出当前数据包的总长度，然后累计接收数据，直到达到这个长度，就说明完整的数据包已经接收完毕。

这是标准且可靠的处理方式，所谓“解析负载低效”的担心是多余的，因为这本来就是协议规定的处理流程，反而比依赖TCP标志稳定得多（PSH标志的触发逻辑由操作系统和网络栈控制，服务器不一定会在最后一个应用层数据包上设置PSH，用它判断极易出错）。

修改后的代码示例如下：

private send(write: Buffer, onData: OnDataCallback) {
  let remainingBytes = 0;
  const buffers: Buffer[] = [];

  const handleData = (chunk: Buffer) => {
    // 未确定数据包总长度时，先解析头部
    if (remainingBytes === 0) {
      // 前3字节为小端序的数据包长度
      remainingBytes = chunk.readUInt24LE(0);
      // 跳过4字节头部（3字节长度 + 1字节序列号），取有效负载
      const payloadChunk = chunk.slice(4);
      buffers.push(payloadChunk);
      remainingBytes -= payloadChunk.length;
    } else {
      // 已确定长度，直接累加数据
      buffers.push(chunk);
      remainingBytes -= chunk.length;
    }

    // 检查是否已接收完完整数据包
    if (remainingBytes <= 0) {
      this.socket.off("data", handleData);
      // 拼接所有分片并回调
      onData(Buffer.concat(buffers));
      // 重置状态，准备下一次接收
      buffers.length = 0;
      remainingBytes = 0;
    }
  };

  this.socket.on("data", handleData);
  this.socket.write(write);
}

额外说明：如果遇到超过16MB的超大数据包，MySQL会采用分块传输方式，此时需要根据序列号判断是否为同一个逻辑数据包的分片，继续累加直到所有分块接收完成。

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