流上的 ECONNREFUSED 错误未由错误事件处理并尝试捕获

Question

我正在使用 npm request 模块将传入的请求转发到另一台服务器：

app.get("/somepath", function(req, res) {
    var url = proxySetting.global.url + req.url;
    req.pipe(request(url)).pipe(res);
});

这里：proxySetting.global.url == http://localhost:4000

现在当我将这样的传入请求转发到目标服务器时，如果目标服务器(localhost:4000) 已关闭或请求在目标服务器上挂起。

会出现ECONNREFUSED或挂断错误等错误。

尝试使用下面的域模块捕获这些错误

var d = domain.create();
d.on("error", function(err) {
    console.log("Error occoured while forwarding request");
    console.log(err);
    res.status(500).send("Error occoured while forwarding request");
});
d.run(function() {
    req.pipe(request(url)).pipe(res);
});

尝试在几种组合中捕获错误事件

    var request = require("request");

module.exports = function(proxySetting) {
    return function(req, res, next) {
        var url = proxySetting.global.url + req.url;
        url = url.replace(/([^:]\/)\/+/g, "$1") // replacing multiple slashes with one
        console.log("Forwarding request to: " + url);

        function errorHandler(err) {
            console.log("Error occoured while forwarding request");
            console.log(err);
            res.status(500).send("Error occoured while forwarding request");
        }
        req.on("error", errorHandler);
        res.on("error", errorHandler);
        req.pipe(request(url).on("error",errorHandler)).pipe(res);
    };
};

但仍然向进程抛出异常并且服务器崩溃 我现在正在做的一种方法是

process.on('uncaughtException', function(err) {
  console.log("Some unhandled error occoured");
  console.log(err);
  console.log("Stopping server");
  process.exit(1);
});

但我认为 catch uncaughtException 和 handle 不是一个合适的解决方案

Answer 1

看来，您没有对"errorHandler" 中的响应对象采取行动，如果您看到您的代码块（如下所示），则res 超出范围。

function errorHandler(err) {
    console.log("Error occoured while forwarding request");
    console.log(err);
    res.status(500).send("Error occoured while forwarding request"); 
} 
req.on("error", errorHandler); 
res.on("error", errorHandler); 
req.pipe(request(url).on("error", errorHandler)) .pipe(res);

但是，如果您在错误句柄中对响应对象进行操作，则不会有任何uncaughtException。

我已经创建了一个解决方案，如果代理服务器宕机，它将作用于错误句柄上的响应对象，因此它不会命中 uncaughtException 事件。

这是解决方案。

var response ;

app.get('/', function(req, res){
    var url = "http://localhost:3001" + req.url;
    response = res; // I am setting res to global variable here
    req.pipe(request(url).on("error",errorHandler)).pipe(res);

});


function errorHandler(err) {
    response.status(500).send("Error occoured while forwarding request");
}

process.on('uncaughtException', function(err) {
  console.log("Some unhandled error occoured");
  console.log(err);
  console.log("Stopping server");
  process.exit(1);
});

这里uncaughtException事件不会被调用，我已经签入了repo的解决方案，你可以试一试。回购位置 - here 。

成功案例使用“Run1.sh”，代理服务器宕机案例使用“Run2.sh”。