नोड में 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

अपने कोड का उपयोग करना, मुद्दा यह है कि आप के लिए एक सॉकेट सॉकेट वस्तु पर सामान सेट करने के लिए प्रयास करने से पहले अनुरोध करने के लिए आवंटित करने के लिए इंतजार कर रहे थे नहीं किया है। यह सब इतना async है: जब अनुरोध सॉकेट वस्तु असाइन किया गया है

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(); 

'सॉकेट' घटना निकाल दिया जाता है।

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

यह एक शॉर्टकट विधि सॉकेट घटना को बांधता है और उसके बाद का समय समाप्त बनाता है:

Answer 3

इस समय वहाँ अनुरोध वस्तु पर सीधे यह करने के लिए एक विधि है।

संदर्भ: 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! 

आशा है कि मदद करता है।