nodejs, http.request超时控制

场景: 使用nodejs请求外部网页,要求规定时间内返回

依赖库: http/https

方案:

由于nodejs自身没有对http连接的可配置的超时控制机制,需要自行增加

/**

 * if timeout, emit "timeout" event, abort request, and emit "abort" event for response

 * @param options

 * @param timeout

 * @param callback

 */

function httpGetWithTimeoutSupport(options, timeout, callback) {

    var timeoutEvent;

    var req = http.get(options, function(res) {

        res.on("end", function() {

            clearTimeout(timeoutEvent);

            console.log("end");

        })

        res.on("close", function(e) {

            clearTimeout(timeoutEvent);

            console.log("close");

        })

        res.on("abort", function() {

            console.log("abort");

        });

        callback(res);

    });

    req.on("timeout", function() {

        console.log("timeout received");

        if (req.res) {

            req.res.emit("abort");

        }

        req.abort();

    });

    timeoutEvent = setTimeout(function() {

        req.emit("timeout");

    }, timeout);

    return req;

}

httpGetWithTimeoutSupport(url.parse("http://www.google.com"), 1000, function(res){

     var data = "";

    res.on("data", function(d) {

        data += d;

    });

    res.on("end", function() {

        console.log(data);

    })

});

nodejs自带一个默认的2分钟的强制超时, 见http.js;这个超时会导致close事件发生,错误代码为"timeout". 同时超时是针对连接而非单个的请求的(一个连接上有许多请求).

评论

2 楼 白黑山河 2011-07-05  

console.log的确出现了两次，不过这个日志输出不是重点，只是表示可以在这里注册一个事件。
事件的注册可以重复的，上面一个事件注册是为了消除超时事件，下面一个事件注册是用于具体的逻辑。
blog里毕竟不能把具体的业务直接放出来，console.log是一种取巧的替代方式

1 楼 windyrobin 2011-07-05  

怎么两个
res.on("end", function() {
        console.log(data);
    })

重复料把