node.js - 如何在 Node 中拦截传出的tcp消息？

Question

如何编写一个截取消息的简单流？

例如，假设我要记录(或最终转换)由用户的socket.write(...)调用通过网络发送的消息。

以下是尝试执行此操作的最小程序:

const net    = require('net');
const stream = require('stream');

const socket = new net.Socket();

const transformer = new stream.Transform({
  transform(chunk,e,cb){
    console.log("OUT:"+chunk.toString());
    cb();
  }});
//const client = socket.pipe(transformer); // <= prints "OUT:" on client, but nothing on server
const client = transformer.pipe(socket); // <= prints nothing on client, but "hello world" on server

socket.on('data', (data)=>{ console.log("IN:"+data.toString()); });
socket.connect(1234, 'localhost', ()=>{ client.write("hello world"); });

当我执行socket.pipe(transformer)时，客户端会打印“OUT:”(就像我想要的那样)，但实际上并没有向服务器发送任何内容。当我交换管道位置transformer.pipe(socket)时，什么都不会打印到客户端，而是将消息发送到服务器。

尽管未在此处列出，但我也尝试使用可写流，该流确实在客户端上打印消息，但是永远不会发送到服务器(如果我在可写流中执行this.push(...)，它将仍然似乎没有发送到服务器)

我在这里想念什么？

编辑:为清楚起见重新格式化了代码并更新了文本

Answer 1

看来我需要更改以下行

socket.connect(1234, 'localhost', ()=>{ client.write("hello world"); });

对此

socket.connect(1234, 'localhost', ()=>{ transformer.write("hello world"); });

这是基于@ Mr.Phoenix的评论。我期望.pipe()返回一个我可以使用的新流。我相信这就是Java的netty框架的工作方式，并且我一直期望节点流以相同的方式工作。