Nodejs write after end 错误

Nodejs write after end 错误

以下是简化的代码：

let server = http.createServer(async function (req, res) {
    let req2 = web.request({
            hostname: reqUrl.hostname,
            path: reqUrl.path,
            method: req.method,
            headers: headers,
            agent: false,
        }, function (res2) {
            res.on('error', function (e) { if (e) { console.log(Date() + ':res.error,' + e.message); } err(e, res); });
            res2.on('error', function (e) { if (e) { console.log(Date() + ':res2.error,' + e.message); } err(e, res); });
            res.writeHead(res2.statusCode, res2.statusMessage, res2.headers);
            res2.pipe(res);
        });
        req2.setTimeout(10 * 1000, function (e) { if (e) { console.log(Date() + ':req2.timeout,' + e.message); } err(e, res); });
        req2.on('error', function (e) { if (e) { console.log(Date() + ':req2.error,' + e.message); } err(e, res); });
        req.pipe(req2);
})

问题是为什么偶尔会出现打印出 res.error,write after end ？

一般来说 write after end 是在 end 之后继续调用 write 才会触发的错误吧？我这里没有调用任何 end 和 write ，只有 pipe ，是 pipe 内部有错误么？


4 回复

async function (req, res) {}
是什么用法？


es7

一般是没有等回调完成就发送请求。

在Node.js中遇到“write after end”错误，通常意味着你尝试在一个已经结束的流（stream）上写入数据。这种错误常见于处理文件写入或网络响应时。为了避免这种错误，你需要确保在流结束后不再写入数据。

以下是一个简单的示例，展示如何正确使用Node.js的fs模块来写入文件，并避免“write after end”错误：

const fs = require('fs');
const stream = fs.createWriteStream('example.txt');

// 写入一些数据
stream.write('Hello, world!', (err) => {
  if (err) throw err;
});

// 结束写入流
stream.end((err) => {
  if (err) throw err;
  console.log('Stream ended.');
  
  // 尝试在流结束后写入数据（这将导致错误）
  // stream.write('This will cause an error', (err) => {
  //   if (err) console.error(err); // Error: write after end
  // });
});

// 正确的做法：在流未结束前写入数据
// 如果需要在某个条件下继续写入，应该检查流的状态
// 但通常，一旦调用stream.end()，就不应该再写入

为了避免这种错误，你可以在逻辑上确保不会在stream.end()之后调用stream.write()。如果需要在特定条件下继续写入，可以考虑重新创建流或检查流的状态（虽然Node.js的流API不直接提供检查是否已结束的方法，但你可以通过维护自己的状态变量来实现）。

总之，处理流时，要仔细管理它们的生命周期，确保不会在它们关闭后继续写入数据。

回到顶部