如何在Node中设置http.request（）的超时时间？

Question

我试图设置HTTP客户端上使用http.request没有运气的超时。到目前为止我做的是这样的：

var options = { ... } 
var req = http.request(options, function(res) { 
    // Usual stuff: on(data), on(end), chunks, etc... 
} 

/* This does not work TOO MUCH... sometimes the socket is not ready (undefined) expecially on rapid sequences of requests */ 
req.socket.setTimeout(myTimeout); 
req.socket.on('timeout', function() { 
    req.abort(); 
}); 

req.write('something'); 
req.end(); 

任何提示？

Answer 1

好奇，如果您直接使用net.sockets，会发生什么情况？下面是一些示例代码，我放在一起测试目的：

var net = require('net'); 

function HttpRequest(host, port, path, method) { 
    return { 
    headers: [], 
    port: 80, 
    path: "/", 
    method: "GET", 
    socket: null, 
    _setDefaultHeaders: function() { 

     this.headers.push(this.method + " " + this.path + " HTTP/1.1"); 
     this.headers.push("Host: " + this.host); 
    }, 
    SetHeaders: function(headers) { 
     for (var i = 0; i < headers.length; i++) { 
     this.headers.push(headers[i]); 
     } 
    }, 
    WriteHeaders: function() { 
     if(this.socket) { 
     this.socket.write(this.headers.join("\r\n")); 
     this.socket.write("\r\n\r\n"); // to signal headers are complete 
     } 
    }, 
    MakeRequest: function(data) { 
     if(data) { 
     this.socket.write(data); 
     } 

     this.socket.end(); 
    }, 
    SetupRequest: function() { 
     this.host = host; 

     if(path) { 
     this.path = path; 
     } 
     if(port) { 
     this.port = port; 
     } 
     if(method) { 
     this.method = method; 
     } 

     this._setDefaultHeaders(); 

     this.socket = net.createConnection(this.port, this.host); 
    } 
    } 
}; 

var request = HttpRequest("www.somesite.com"); 
request.SetupRequest(); 

request.socket.setTimeout(30000, function(){ 
    console.error("Connection timed out."); 
}); 

request.socket.on("data", function(data) { 
    console.log(data.toString('utf8')); 
}); 

request.WriteHeaders(); 
request.MakeRequest(); 

Answer 2

使用你的代码，问题是你有没有等待一个插座，以试图设置的东西Socket对象之前被分配到请求。它们都是异步的：

var options = { ... } 
var req = http.request(options, function(res) { 
    // Usual stuff: on(data), on(end), chunks, etc... 
}); 

req.on('socket', function (socket) { 
    socket.setTimeout(myTimeout); 
    socket.on('timeout', function() { 
     req.abort(); 
    }); 
}); 

req.on('error', function(err) { 
    if (err.code === "ECONNRESET") { 
     console.log("Timeout occurs"); 
     //specific error treatment 
    } 
    //other error treatment 
}); 

req.write('something'); 
req.end(); 

当请求被分配一个套接字对象时，会触发'套接字'事件。

Answer 3

这时有直接请求对象上做到这一点的方法：

request.setTimeout(timeout, function() { 
    request.abort(); 
}); 

这是结合到插座事件的快捷方式，然后创建超时。

参考：Node.js v0.8.8 Manual & Documentation

Answer 4

的罗布·埃文斯anwser工作正常但对我来说，当我使用request.abort（），它发生抛出一个插座挂断错误，保持未处理。

我不得不添加一个错误处理程序请求对象：

var options = { ... } 
var req = http.request(options, function(res) { 
    // Usual stuff: on(data), on(end), chunks, etc... 
} 

req.on('socket', function (socket) { 
    socket.setTimeout(myTimeout); 
    socket.on('timeout', function() { 
     req.abort(); 
    }); 
} 

req.on('error', function(err) { 
    if (err.code === "ECONNRESET") { 
     console.log("Timeout occurs"); 
     //specific error treatment 
    } 
    //other error treatment 
}); 

req.write('something'); 
req.end(); 

Answer 5

您应该通过参考请求像下面

var options = { ... } 
 
var req = http.request(options, function(res) { 
 
    // Usual stuff: on(data), on(end), chunks, etc... 
 
}); 
 

 
req.setTimeout(60000, function(){ 
 
    this.abort(); 
 
}.bind(req); 
 
req.write('something'); 
 
req.end();

请求错误事件会得到触发

req.on("error", function(e){ 
 
     console.log("Request Error : "+JSON.stringify(e)); 
 
    });

Answer 6

我 - 这里是做socket.setTimeout

var request=require('https').get(
    url 
    ,function(response){ 
     var r=''; 
     response.on('data',function(chunk){ 
      r+=chunk; 
      }); 
     response.on('end',function(){ 
      console.dir(r);   //end up here if everything is good! 
      }); 
     }).on('error',function(e){ 
      console.dir(e.message); //end up here if the result returns an error 
      }); 
request.on('error',function(e){ 
    console.dir(e);     //end up here if a timeout 
    }); 
request.on('socket',function(socket){ 
    socket.setTimeout(1000,function(){ 
     request.abort();    //causes error event ↑ 
     }); 
    }); 

Answer 7

有更简单的方法的不易混淆的方式。

而不是使用的setTimeout或插座直接工作，
我们可以在客户端中的“选项”使用“超时”使用

下面是服务器和客户端的代码，在3个部分。

模块和选项部分：

'use strict'; 

// Source: https://github.com/nodejs/node/blob/master/test/parallel/test-http-client-timeout-option.js 

const assert = require('assert'); 
const http = require('http'); 

const options = { 
    host: '127.0.0.1', // server uses this 
    port: 3000, // server uses this 

    method: 'GET', // client uses this 
    path: '/', // client uses this 
    timeout: 2000 // client uses this, timesout in 2 seconds if server does not respond in time 
}; 

服务器部分：

function startServer() { 
    console.log('startServer'); 

    const server = http.createServer(); 
    server 
      .listen(options.port, options.host, function() { 
       console.log('Server listening on http://' + options.host + ':' + options.port); 
       console.log(''); 

       // server is listening now 
       // so, let's start the client 

       startClient(); 
      }); 
} 

客户端部分：

function startClient() { 
    console.log('startClient'); 

    const req = http.request(options); 

    req.on('close', function() { 
     console.log("got closed!"); 
    }); 

    req.on('timeout', function() { 
     console.log("timeout! " + (options.timeout/1000) + " seconds expired"); 

     // Source: https://github.com/nodejs/node/blob/master/test/parallel/test-http-client-timeout-option.js#L27 
     req.destroy(); 
    }); 

    req.on('error', function (e) { 
     // Source: https://github.com/nodejs/node/blob/master/lib/_http_outgoing.js#L248 
     if (req.connection.destroyed) { 
      console.log("got error, req.destroy() was called!"); 
      return; 
     } 

     console.log("got error! ", e); 
    }); 

    // Finish sending the request 
    req.end(); 
} 


startServer(); 

如果你把所有的上述3个部分在一个文件中，“一.js“，然后运行：

node a.js 

然后，输出将是：

startServer 
Server listening on http://127.0.0.1:3000 

startClient 
timeout! 2 seconds expired 
got closed! 
got error, req.destroy() was called! 

希望有所帮助。