何时为流式响应编写标头？

Question

我正在使用 node-mssql 模块从 express api 查询 SQL 服务器，并将行（带有一些中间步骤）传送到响应流。我想避免写入标头，直到我知道查询不会在任何行之前产生错误，这样我就可以向客户端发送有用的错误消息，而不是使用 express 默认处理程序终止流。但是，express 在某些时候会编写默认标头，我无法识别。

我已尝试在管道中的 .once('data',) 侦听器中编写标头，但此时某些默认行为已为我编写标头，这会产生错误。

let request = await new sql.Request(pool);

res.writeHead(200, {
        'Transfer-Encoding': 'chunked',
        'charset' : 'utf-8',
        'Content-Type': 'application/json',
        'Content-Encoding': 'gzip'        
    })

ndjsonStream.on('error', next)

request.pipe(ndjsonStream)
    .pipe(transformer)
    .pipe(gzip)
    .pipe(res);

上述方法有效，但我无法传递有用的错误消息。

let request = await new sql.Request(pool);

ndjsonStream.once('data', () => {
    res.writeHead(200, {
        'Transfer-Encoding': 'chunked',
        'charset' : 'utf-8',
        'Content-Type': 'application/json',
        'Content-Encoding': 'gzip'        
    })
})

ndjsonStream.on('error', next)

request.pipe(ndjsonStream)
    .pipe(transformer)
    .pipe(gzip)
    .pipe(res);

request.query(query);

这会产生错误，因为 express 在此侦听器触发之前为我编写了一些标题，即 content-type: text/html。

Error [ERR_HTTP_HEADERS_SENT]: Cannot set headers after they are sent to the client

Answer 1

http 响应的工作方式是，您必须在开始发送任何数据之前编写 http 标头。这就是http响应格式的设计方式。因此，如果您要通过管道传输响应，则必须编写标头，然后通过管道传输并注意错误。您无法更改该顺序。

我想避免写标题，直到我知道查询不会在任何行之前产生错误

这样做的唯一方法是将整个响应预加载到内存中（这样您就知道在获取所有数据时没有发生错误），然后您可以编写标头，然后写入响应（如果没有错误）和如果出现错误，请编写不同的标头和不同的响应。

如果您是管道，那么根据定义，标头已经被写入，并且数据可能在错误发生之前已经开始发送。这是管道的一个缺点，就像您正在使用它一样。它有一些优点（比如可能会降低内存使用率和非常简单的编码），但是这样做确实没有很好的方法来处理错误。无需尝试真正非常喜欢多个 mime 部分，并允许您附加最终的 mime 部分以传达有关错误的更多信息并创建自己的管道解决方案，该解决方案不仅会在错误时挂断套接字，而且还允许您要终止当前的 mime 部分并添加另一个部分，如果您使用管道，则表示您接受它提供的简单错误通信。