时间戳

首页 > 解决方案 > 为什么请求管道在此代码中包含标头？

node.js - 为什么请求管道在此代码中包含标头？

问题描述

我有一个关于 http 服务器和管道请求的奇怪情况。

根据我过去的经验，当将 http 服务器的请求对象通过管道传输到某种可写流时，它不包含标头，仅包含有效负载。

然而今天，我写了一些非常简单的代码，出于某种原因，我花了过去 2 个小时试图弄清楚为什么它将标题写入文件（超级混乱！）

这是我的代码：

server = http.createServer((req, res) => {
  f = '/tmp/dest'
  console.log(`writing to ${f}`)
  s = fs.createWriteStream(f)
  req.pipe(s)
  req.on('end', () => {
    res.end("done")
  })
})

server.listen(port)

我使用以下curl命令对此进行测试：

curl -XPOST  -F 'data=@test.txt' localhost:8080

这就是我在阅读时得到的/tmp/dest：

--------------------------993d19e02b7578ff
Content-Disposition: form-data; name="data"; filename="test.txt"
Content-Type: text/plain

hello - this is some text


--------------------------993d19e02b7578ff--

为什么我在这里看到标题？我希望它只写有效载荷

我有一个大约一年前写的代码，它直接流式传输到一个没有标题的文件，我不明白有什么不同，但是这个成功了：

imageRouter.post('/upload', async(req, res) => {
  if(!req.is("image/*")) {
    let errorMessage = `the /upload destination was hit, but content-type is ${req.get("Content-Type")}`;
    console.log(errorMessage);
    res.status(415).send(errorMessage);
    return;
  }

  let imageType = req.get("Content-Type").split('/')[1];
  let [ err, writeStream ] = await getWritableStream({ suffix: imageType });
  if (err) {
    console.log("error while trying to write", err);
    return res.status(500).end();
  }

  let imageName = writeStream.getID();
  req.on('end', () => {
    req.unpipe();
    writeStream.close();
    res.json({
      imageRelativeLink: `/images/${imageName}`,
      imageFullLink: `${self_hostname}/images/${imageName}`
    });
  });
  req.pipe(writeStream);
});

有什么不同？为什么我一年前的代码（最后一个块）在没有表单数据/标题的情况下写入？结果文件只是一个图像，没有文本，但是这次（第一个块）在结果文件中显示了 http 标头

标签： node.jshttp-streaming

解决方案

不要使用管道，而是尝试使用 on('data') 并引用 req.data 来提取内容。这将允许 http 库处理 HTTP 正文格式并为您处理“标题”（实际上：表单部分描述符）。

节点流消费者 API

    server = http.createServer((req, res) => {
      f = '/tmp/dest'
      console.log(`writing to ${f}`)
      s = fs.createWriteStream(f)
      req.on('data', chunk) => {
          s.write(chunk);
      }
      req.on('end', () => {
        s.close();
        res.end("done")
      })

})

server.listen(port)

推荐阅读