Nodejs流（错误：发送后无法设置标头）

Question

我正在尝试从 Braintree 服务器构建一个 api。参考这个文档https://developers.braintreepayments.com/javascript+node/reference/general/result-handling/search-results

要从他们的服务器访问所有交易，我必须返回一个节点流。

前

app.get('/project', function(req, res) {
  if(req.user) {

      var stream = gateway.transaction.search(function (search) {
        search.customerId().is(req.user.id);
      });

      stream.on("ready", function () {
        console.log(stream.searchResponse);
      });

      stream.on("data", function (data) {
        res.json(data) // can't set headers after they are sent. 
      });

  }
});

我了解流以块的形式返回数据，因此上面的 res.json() 很可能被多次调用，从而导致 Error: Can't set headers after they are sent。

所以我的问题是如何将这些数据以一个块的形式发送给客户端？ nodejs 流让我感到困惑，我将阅读更多关于它的内容，但如果了解如何在不重新发送标头的情况下将数据发送到客户端，那就太好了。

Answer 1

您不应该对data 事件做出任何假设，除非您从中读取的流处于对象模式。你可以得到一个 data 事件或一百个（当然取决于输入大小），因为 TCP 是一个流。

您可能想要的是这样的东西（假设stream 不在对象模式下）：

app.get('/project', function(req, res) {
  if(req.user) {

      var stream = gateway.transaction.search(function (search) {
        search.customerId().is(req.user.id);
      });

      stream.on("ready", function () {
        console.log(stream.searchResponse);
      });

      var buf = '';
      stream.on("data", function (data) {
        buf += data;
      });

      stream.on("end", function() {
        res.setHeader('Content-Type', 'application/json');
        res.send(buf);
      });

  }
});

或者只是将流通过管道传递给响应：

app.get('/project', function(req, res) {
  if(req.user) {

      var stream = gateway.transaction.search(function (search) {
        search.customerId().is(req.user.id);
      });

      stream.on("ready", function () {
        console.log(stream.searchResponse);
      });

      res.setHeader('Content-Type', 'application/json');

      stream.pipe(res);
  }
});

对于对象流，您可能会这样做：

app.get('/project', function(req, res) {
  if(req.user) {

      var stream = gateway.transaction.search(function (search) {
        search.customerId().is(req.user.id);
      });

      stream.on("ready", function () {
        console.log(stream.searchResponse);
      });

      var result = [];
      stream.on("data", function (data) {
        result.push(data);
      });

      stream.on("end", function() {
        res.json(result);
      });

  }
});