5

我正在使用request-promise模块来检查站点是否正在使用代理。我正在尝试找到足够快以在 5 秒内回答的代理。因此，如果请求在 5 秒内没有超时，我只会添加对象。

对于某些代理，即使 promise 解析，节点脚本也会挂起一段时间。我找不到这个延迟的原因。我看到它打印Done但它挂起。1 分 10 秒后，脚本退出。这是由于我的代码或开放套接字的操作系统问题等导致的挂起吗？

const rp =  require('request-promise');
const testProxies = [
    {
       "ipAddress": "80.241.219.83",
       "port": 3128,
    },
    {
        "ipAddress": "45.55.27.246",
        "port": 80
    },
    {
        "ipAddress": "144.217.197.71",
        "port": 8080,
    },
    {
        "ipAddress": "104.131.168.255",
        "port": 80,
    },
    ];

function CheckSites(sitesArray,site) {
    let ps = [];
    for (let i = 0; i < sitesArray.length; i++) {
        let proxy = sitesArray[i];

        let ops = {
            method: 'GET',
            resolveWithFullResponse: true,
            proxy: 'http://' + proxy.ipAddress + ':' + proxy.port,
            uri:site,
        };
        let resp =  rp.get(ops);
        ps.push(resp);
    }
    return Promise.all(ps.map(function (p) {
        p.time =  Date.now();
        return p
            .then(function (a) {
                return {'header':a.headers,'time':Date.now() - p.time};
            })
            .timeout(5000)
            .catch(function (e) {
                return {};
            })
    }))
}
CheckSites(testProxies,'https://www.example.com').then(function (object) {
    console.log('Done!');
    console.log(object);
}).catch(function (err) {
    console.log('Exception: ' + err);
});
4

1 回答 1

1

对于您的用例，我建议您使用Promise.race()它的行为方式，Promise.all但是一旦最快的代理响应，您就会收到回调。

我对该错误进行了更多调查，这似乎是一个request模块问题，当您使用超时时，他们只是不关闭连接并且处于挂起状态

于 2017-08-25T08:17:05.617 回答