对于node.js HTTP，res.end() 如何保证套接字断开连接？

Question

这是node.js的end实现：

OutgoingMessage.prototype.end = function(data, encoding) {
  if (this.finished) {
    return false;
  }
  if (!this._header) {
    this._implicitHeader();
  }

  if (data && !this._hasBody) {
    console.error('This type of response MUST NOT have a body. ' +
                  'Ignoring data passed to end().');
    data = false;
  }

  var ret;

  var hot = this._headerSent === false &&
            typeof(data) === 'string' &&
            data.length > 0 &&
            this.output.length === 0 &&
            this.connection &&
            this.connection.writable &&
            this.connection._httpMessage === this;

  if (hot) {
    // Hot path. They're doing
    //   res.writeHead();
    //   res.end(blah);
    // HACKY.

    if (this.chunkedEncoding) {
      var l = Buffer.byteLength(data, encoding).toString(16);
      ret = this.connection.write(this._header + l + CRLF +
                                  data + '\r\n0\r\n' +
                                  this._trailer + '\r\n', encoding);
    } else {
      ret = this.connection.write(this._header + data, encoding);
    }
    this._headerSent = true;

  } else if (data) {
    // Normal body write.
    ret = this.write(data, encoding);
  }

  if (!hot) {
    if (this.chunkedEncoding) {
      ret = this._send('0\r\n' + this._trailer + '\r\n'); // Last chunk.
    } else {
      // Force a flush, HACK.
      ret = this._send('');
    }
  }

  this.finished = true;

  // There is the first message on the outgoing queue, and we've sent
  // everything to the socket.
  if (this.output.length === 0 && this.connection._httpMessage === this) {
    debug('outgoing message end.');
    this._finish();
  }

  return ret;
};

来源：https://github.com/joyent/node/blob/master/lib/http.js#L645

显然，只有当 output.length === 0 时，连接才“完成”。

因此，如果仍有数据等待写入，并且接收客户端由于某种原因无法接收该数据，那么请求是否会结束？

我还看到过这样的问题：在尝试结束 Flash 上传器发出的 http 请求时，结束无效。我最终做了以下事情，这确实有帮助：

    res.end(failureJSON, 'utf8');
    req.once('end', function _destroyConn() {
        req.connection.destroy();
    });

看起来很黑客。无论如何，是否需要使用 req.connection.destroy 的这种行为来保证与套接字的断开连接？

Answer 1

不幸的是，res.end() 并不直接“保证套接字断开连接”，因为它需要考虑 HTTP Keep-Alive。根据文档，end 告诉服务器所有内容都已发送，并且响应已完成。是否立即断开连接完全取决于服务器对象。

为了更具体地回答您的问题，重要的是响应需要发出 finish 事件。如果您看一下 _finish() 的实现，它几乎只是发出事件。

正如您所指出的，它并不总是直接调用 _finish()…但它确实设置了 this.finished = true。当_flush()执行时，它会发送所有剩余的数据，然后调用_finish()。

这有点复杂，我认为我不能在没有犯错的风险的情况下详细讨论。

至于连接有时不会关闭，您是否检查过 keep-alive 配置是否正确？如果默认使用 keep-alive 设置 HTTP 连接，则调用 end 将不会关闭套接字。

如果您打印出res.shouldKeepAlive，它会告诉您服务器是否正在尝试使用keep-alive。如果您想阻止服务器执行此操作，请在请求处理程序开始时将其设置为 false。

Answer 2

我不知道这是否对您有帮助，因为我正在为节点 4.4+ 构建框架，但我已经确认您可以在响应中发送 Connection: close 标头，以让节点关闭连接。

let res = getResponseSomehow()

res.statusCode = 408
res.setHeader("Connection", "close")
res.end()

另外，您的销毁代码可以使用以下调整：

// First we give node the time to close the connection
// We can give it 2 seconds
let socket = getSocketSomehow();
let timer = setTimeout(function() {
  socket.destroy();
}, 2000);

socket.on("close", function() {
  clearTimeout(timer);
});

我不太确定这是否是您想要的 close 事件。我通常尝试使用库并远离 net api，所以这只是一个猜测。