使用封闭范围内的变量的函数节点数组

Node array of function using variables from enclosing scope

我正在尝试使用 async.parallel() 在 ip 列表上执行 dns.reverse()

代码如下:

var functions = [];
for (var i = 0; i < data.length; i++) {
    var ip = data[i].ip;
    var x = function(callback) {
        dns.reverse(ip, (err, hostnames) => {
            if (err) {
                log.error("Error resolving hostname for [" + ip + '] ' + err);
                return callback(null, err);
            }

            callback(null, hostnames);
        });
    };

    functions.push(x);
}

async.parallel(functions, (err, results) => {
    for(var i = 0; i < data.length; i++) {
        data[i]['hostnames'] = results[i];
    }

    handler(null, data);
});

发生的事情是 dns.reverse() 被所有调用使用相同的 ip(数据数组中的最后一个)调用。可能是我做错了什么。有人可以解释我的错误吗?

第一个回调在整个 for 循环完成后执行,因为它是异步的。 ip 的值将是循环的最后一次迭代中的值。 你可以放一些 console.log 来了解真正发生的事情。

正确的做法可能是:

async.parallel(data.map(({ ip }) => callback => {
    dns.reverse(ip, callback)
}), (err, results) => {
    for (var i = 0; i < data.length; i++) {
       data[i]['hostnames'] = results[i];
    }

    handler(null, data);  
})

根据每个ip创建一个新的函数数组。 每个函数都会将其回调称为 dns.reverse.

此外,return 一个新数据数组可能更好,而不是在循环内更改数据:

(err, results) => {
  const result = data.map((data, index) => ({
      ...data,
      hostnames: results[index]
  })

  handler(null, result);  
})

感谢@apokryfos,我得到了提示。为了使代码正常工作,我只需要在声明 ip 时使用 let 而不是 var。

        var functions = [];
        for (var i = 0; i < data.length; i++) {
            let ip = data[i].ip;
            var x = function(callback) {
                dns.reverse(ip, (err, hostnames) => {
                    if (err) {
                        log.error("Error resolving hostname for [" + ip + '] ' + err);
                        return callback(null, err);
                    }

                    callback(null, hostnames);
                });
            };

            functions.push(x);
        }
        async.parallel(functions, (err, results) => {
            for(var i = 0; i < data.length; i++) {
                data[i]['hostnames'] = results[i];
            }

            handler(null, data);
        });

任何有兴趣了解以下内容的人可能会有所帮助:How do JavaScript closures work?