如何捕获Node.js Socket发送出去的数据？

API 探路者

2026-8-12

问题解答

当服务器为远程节点时，Node.js的net.Socket本身没有提供直接捕获已发送数据的事件，但可以通过以下几种方式实现需求：

1. 封装`write`方法（代码层面最直接方案）

直接重写客户端Socket实例的write方法，在调用原生write前记录要发送的数据：

const net = require('net');

const socket = new net.Socket();
socket.on('data', (buffer) => {
  console.log(`Client received ${buffer}`);
});

// 封装write方法
const originalWrite = socket.write;
socket.write = function(data, encoding, callback) {
  // 捕获并记录发送的数据
  console.log(`Client sent: ${data.toString(encoding || 'utf8')}`);
  return originalWrite.call(this, data, encoding, callback);
};

socket.connect(8080, '远程服务器IP');

setTimeout(() => {
  socket.write('Hello');
}, 100);
setTimeout(() => {
  socket.write('Hi');
}, 200);

这种方式不管服务器是本地还是远程，都能准确捕获客户端要发送的内容，同时不影响原有发送逻辑。

2. 结合`drain`事件确认发送状态（可选）

如果需要确认数据已被系统缓冲区接收（即将发送到网络），可以配合drain事件：

let pendingData = [];

socket.write = function(data, encoding, callback) {
  pendingData.push(data.toString(encoding || 'utf8'));
  const result = originalWrite.call(this, data, encoding, callback);
  if (!result) {
    // 缓冲区已满，等待drain
    socket.once('drain', () => {
      console.log(`Client sent (confirmed): ${pendingData.join(', ')}`);
      pendingData = [];
    });
  } else {
    console.log(`Client sent (confirmed): ${data.toString(encoding || 'utf8')}`);
  }
  return result;
};

drain事件触发时，说明之前阻塞的写操作已完成，数据已被系统接收。