9

我正在熟悉 nodejs 中的流,我有一个问题:

我有我认为是最简单的nodejs“回声服务器”,即一个服务器,它通过请求流接收到的任何内容都简单地通过管道返回响应流。它有效,但有一个警告。客户端仅在关闭提交流后才接收回数据。这是服务器代码:

var http = require('http')
var server = http.createServer(function (req, res) {
  req.pipe(res);
});
server.listen(8000);

这是我测试它的方法:

做以下工作就好了

term1> node server.js&

term2> echo 'hello world!'|curl --no-buffer --data-binary  @-  'http://localhost:8000'
hello world!

但是,它之所以有效,是因为 echo 在完成后关闭了它的输出文件描述符,即,服务器在其客户端完成发送内容之前不会写入任何内容:

term2>
term2> yes|curl --no-buffer --data-binary  @-  'http://localhost:8000'

(这里这条线永远卡住了)

我希望这yes会很快填充流缓冲区,所以我会开始看到 y 很快回来。不幸的是,他们从不这样做。

这是预期的吗?我应该如何使用流/管道才能达到预期的效果?顺便说一句,我不在乎输出是否会以块的形式返回......我知道这将是流(或底层文件 i/o)发挥缓冲魔法的结果。

谢谢您的帮助

4

1 回答 1

4

好的,我想我知道我做错了什么。server.js工作正常……就是这curl打破了管道。显然,该@-选项将标准输入视为文件,即读取其全部内容然后提交。我找不到如何curl在阅读内容时制作管道。我认为这是不可行的,因为curl想要将文件的内容视为普通的 HTTP post 表单值..

无论如何,我使用一个简单的 nodejs 客户端修改了上面的示例,该客户端正在执行我想要的操作:

term2> cat client.js
var http = require('http');
var req = http.request('http://localhost:8000', function(res) {
  res.pipe(process.stdout);
});
process.stdin.pipe(req);

term2> yes|node client.js
y
y
...

nodejs 流和管道摇滚!!

于 2013-06-19T12:36:12.720 回答