1

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

例如，假设我想记录（或最终转换）用户的 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)，没有任何东西打印到客户端，但消息被发送到服务器。

虽然这里没有列出，但我也尝试使用 Writable 流，它确实在客户端上打印消息，但它永远不会发送到服务器（如果我在 Writable 流中执行 this.push(...)，它似乎仍然没有发送到服务器）

我在这里想念什么？

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

4

2 回答 2

1

看来我需要更改以下行

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

对此

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

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

于 2017-04-28T15:55:15.750 回答
0

您没有从流中写入任何数据。

您需要this.push(chunk)或将呼叫更改cb为cb(null, chunk)。

有关更多信息，请参阅有关实现转换流的文档。

于 2017-04-28T00:25:09.517 回答