Node.js处理客户端请求超时：ECONNRESET错误捕获失败

问题分析 #

你绑定的req错误事件未触发，大概率是因为错误并非来自原始请求本身，而是发生在转发到接收方的请求链路中，或者流通过pipe传输时错误被传播到下游对象，未被显式捕获。

解决方法 #

1. 显式处理转发请求的错误 #

当你将原始请求流转发到目标API时，必须为创建的转发请求（如http.request生成的对象）绑定error事件，同时处理原始请求、响应流的错误：

const http = require('http');
app.put('/upload', (req, res) => {
    // 监听原始请求错误
    req.on('error', (e) => {
        console.log('原始请求错误:', e.message);
        res.status(500).end('上传代理出错');
    });

    // 创建转发到接收方的请求
    const proxyReq = http.request({
        hostname: '目标API地址',
        port: 80,
        path: '/目标上传路径',
        method: 'PUT',
        headers: req.headers // 传递原始请求头，注意按需调整Host等字段
    }, (proxyRes) => {
        // 回传接收方的响应给文件提供者
        proxyRes.pipe(res);
        // 监听接收方响应流的错误
        proxyRes.on('error', (e) => {
            console.log('接收方响应错误:', e.message);
            res.status(500).end('上传代理出错');
        });
    });

    // 关键：监听转发请求的错误（含ECONNRESET）
    proxyReq.on('error', (e) => {
        console.log('转发请求错误:', e.message);
        if (e.code === 'ECONNRESET') {
            console.log('文件提供者请求超时断开');
            res.status(408).end('上传超时');
        } else {
            res.status(502).end('目标服务不可用');
        }
    });

    // 将原始请求流转发到目标API
    req.pipe(proxyReq);
});

2. 使用stream.pipeline替代pipe（推荐） #

pipe方法不会自动处理流的销毁和错误传播，而stream.pipeline可以统一处理整个流链路的错误，避免遗漏：

const { pipeline } = require('stream');
const http = require('http');

app.put('/upload', (req, res) => {
    const proxyReq = http.request({
        hostname: '目标API地址',
        port: 80,
        path: '/目标上传路径',
        method: 'PUT',
        headers: req.headers
    }, (proxyRes) => {
        // 处理接收方响应的回传
        pipeline(proxyRes, res, (err) => {
            if (err) console.log('响应回传错误:', err.message);
        });
    });

    proxyReq.on('error', (e) => {
        console.log('转发请求错误:', e.message);
        res.status(502).end('目标服务不可用');
    });

    // 用pipeline管理整个文件流转发链路，统一捕获错误
    pipeline(req, proxyReq, (err) => {
        if (err) {
            console.log('流转发错误:', err.message);
            if (err.code === 'ECONNRESET') {
                res.status(408).end('上传超时');
            } else {
                res.status(500).end('上传代理出错');
            }
        }
    });
});

3. 全局错误兜底（避免进程崩溃） #

添加进程级别的错误监听，防止未捕获的错误导致服务崩溃：

process.on('uncaughtException', (err) => {
    console.log('未捕获异常:', err.message);
    // 此处可做必要的资源清理，建议后续重启进程
});

process.on('unhandledRejection', (reason) => {
    console.log('未处理Promise拒绝:', reason);
});

内容的提问来源于stack exchange，提问作者Prashant Onkar