node.js - 限制maxsockets请求包

我尝试限制请求包maxsockets，
我用提琴手测试它并发使用了多少。

如我所见，它没有应用我尝试设置的10个限制。

我不希望请求模块使用超过10个并发

我可能做错了什么？

process.env.NODE_TLS_REJECT_UNAUTHORIZED = "0";
var loglar='idler2.txt';
var url = require('url');
var util = require('util');
var http = require('http');
var https = require('https');
var request = require('request');
var fs = require('fs');
var linkler = [];
var starttime = Math.round(new Date().getTime() / 1000);


http.globalAgent.maxSockets = 10;
https.globalAgent.maxSockets = 10;


var timeoutsure = 30 * 1000;
var success=0,fail=0;

process.on('exit', onExit);



function onExit() {
    console.log('\n%d secs,\n%d suc ,\n%d fail\n---------------------\n',
    (Math.round(new Date().getTime() / 1000)) - starttime,success,fail);
}

function logla(data)
{
    var fd = fs.openSync(loglar, 'a+');
    fs.writeSync(fd, data);
    fs.closeSync(fd);
}

for(i=0;i<1000;i++)
{
    sorgutest();
}

var r = request.defaults({'proxy':'http://127.0.0.1:8888',pool: {maxSockets: 10}});

function sorgutest()
{

r.get({url:'https://freegeoip.net/json/',pool: {maxSockets: 10}}, function optionalCallback(err, httpResponse, body) {
  if (err) {
      fail++;
    return console.error('failed: 49', err);
  }
  else {
  try {bodyjson=JSON.parse(body);
  logla(body);
  success++;
  }
  catch(e){console.log("hamina 54");}
  }
});
}

最佳答案

如文档中所述：


  请注意，如果要在循环中发送多个请求并创建多个新的池对象，则maxSockets将无法正常工作。要解决此问题，请在您的池选项中使用request.defaults，或在循环外使用maxSockets属性创建池对象。


尝试更改request.defaults的pool选项，或创建一个pool对象并在所有请求调用中使用它。

编辑：

我注意到您已经使用了request.default，解决方法应该是简单地删除r.get调用中的pool选项。

从：
r.get({url:'https://freegeoip.net/json/',pool: {maxSockets: 10}}, function optionalCallback(err, httpResponse, body) {

到：r.get({url:'https://freegeoip.net/json/'}, function optionalCallback(err, httpResponse, body) {