Вы на правильном пути. std :: sort
будет использовать operator & lt;
в качестве функции сравнения по умолчанию. Поэтому для сортировки ваших объектов вам придется либо перегрузить bool operator & lt; (const T & amp ;, const T & amp;)
, либо предоставить функтор, который выполняет сравнение, например:
struct C {int i; static bool before (const C & amp; c1, const C & amp; c2) {return c1.i & lt; c2.i; }}; bool operator & lt; (const C & amp; c1, const C & amp; c2) {return c1.i & gt; c2.i; } std :: vector & lt; C & gt; значения; std :: sort (values.begin (), values.end ()); // использует оператор & lt; std :: sort (values.begin (), values.end (), C :: before);
Преимущество использования функтора заключается в том, что вы можете использовать функцию с доступом к закрытым членам класса.
В этот момент существует способ сделать это непосредственно на объекте запроса:
request.setTimeout(timeout, function() {
request.abort();
});
Это метод ярлыков, который привязывается к событию сокета, а затем создает тайм-аут.
Для меня - здесь менее запутанный способ сделать 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 ↑
});
});
Существует более простой метод.
Вместо использования 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 части в один файл «a.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!
Надеюсь, что это поможет.
Вы должны передать ссылку на запрос, как показано ниже
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));
});
Любопытно, что произойдет, если вместо этого вы используете прямое 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();
Используя ваш код, проблема в том, что вы не дождались назначения сокета для запроса, прежде чем пытаться установить материал на объект сокета. Это все 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();
Событие 'socket' запускается, когда запросу присваивается объект сокета.
Rob Evans 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();
myTimeout
? (edit: docs say: То же, что и привязка к событию таймаута nodejs.org/api/… )
– Ben Muircroft
20 September 2016 в 21:08
ECONNRESET
может случиться в обоих случаях: клиент закрывает сокет, а сервер закрывает соединение. Чтобы определить, было ли это сделано клиентом, вызвав abort()
, существует специальное abort
событие
– Derp
8 November 2016 в 10:16
Разрабатывая ответ @douwe здесь, вы должны поместить таймаут в HTTP-запрос.
// TYPICAL REQUEST
var req = https.get(http_options, function (res) {
var data = '';
res.on('data', function (chunk) { data += chunk; });
res.on('end', function () {
if (res.statusCode === 200) { /* do stuff with your data */}
else { /* Do other codes */}
});
});
req.on('error', function (err) { /* More serious connection problems. */ });
// TIMEOUT PART
req.setTimeout(1000, function() {
console.log("Server connection timeout (after 1 second)");
req.abort();
});
this.abort () также прекрасен.