【已解决】Nodejs中调用async.map如何传递获得的结果？

【已解决】Nodejs中调用async.map如何传递获得的结果？

在Node.js中，async.map 是一个非常有用的工具，用于将一个数组中的每个元素进行异步处理，并将结果收集到一个新的数组中。你提到的问题是关于如何正确地将 async.map 的结果传递给外部调用函数。

示例代码

假设你有一个包含 URL 的数组，你想检查每个 URL 是否存在（即是否返回 404 错误）。你可以使用 async.map 来实现这一目标，并将结果传递给外部调用函数。

const async = require('async');
const request = require('request');

var getExistAdLocPage = function(data, callback) {
    async.map(data, function(item, innerCallback) {
        const url = item['url'];
        
        request(url, (err, res, body) => {
            if (err) {
                return innerCallback(err);
            }

            if (res.statusCode === 404) {
                innerCallback(null, { stat: 'page not exist', name: item['name'] });
            } else {
                innerCallback(null, { stat: 'success', name: item['name'], data: body });
            }
        });
    }, function(err, results) {
        if (err) {
            return callback(err);
        }

        // 将结果传递给外部调用函数
        callback(null, results);
    });
};

// 调用示例
const urls = [
    { name: 'URL1', url: 'http://example.com/page1' },
    { name: 'URL2', url: 'http://example.com/page2' },
    { name: 'URL3', url: 'http://example.com/page3' }
];

getExistAdLocPage(urls, (err, results) => {
    if (err) {
        console.error('Error:', err);
    } else {
        console.log('Results:', results);
    }
});

解释

1. 定义 getExistAdLocPage 函数:

   • 这个函数接受两个参数：data（包含 URL 的数组）和 callback（用于传递结果的回调函数）。

2. 使用 async.map:

   • async.map 遍历 data 数组中的每个元素，并对每个元素执行异步操作（在这里是请求 URL）。
   • 对于每个 URL，我们使用 request 模块来发起 HTTP 请求。
   • 如果请求成功且状态码不是 404，则将结果标记为 “success”；否则，标记为 “page not exist”。

3. 处理结果:

   • async.map 的回调函数接收两个参数：err 和 results。
   • 如果有错误发生，直接通过 callback 返回错误。
   • 如果没有错误，将 results 传递给外部调用函数的 callback。

这样，你就可以通过 callback 将 async.map 的结果传递给外部调用函数。