继续求教新手问题 Nodejs 使用request模块在循环中发送请求

继续求教新手问题 Nodejs 使用request模块在循环中发送请求

我有一个需求，例如我有个数组A,每个数组元素的是Object，其实有一个属性是URL ,我需要用request向每个URL发送一个请求，然后获得想要的数据写到每个对象中例如： A.forEach(function(item) { 想要的数据 = request(item.url); item.数据 = 想要的数据； });

有谁能帮个忙，新手求教

5 回复

当然可以！在Node.js中使用request模块在循环中发送HTTP请求，并将结果存储回对象中，可以通过异步操作来实现。这里提供一个简单的示例代码，以及对代码的解释。

首先，确保你已经安装了request模块。如果还没有安装，可以通过npm安装它：

npm install request

接下来是示例代码：

const request = require('request');

// 示例数组A，包含多个具有URL的对象
let A = [
    { id: 1, url: 'http://example.com/data1' },
    { id: 2, url: 'http://example.com/data2' },
    { id: 3, url: 'http://example.com/data3' }
];

// 定义一个函数用于处理每个请求
async function fetchData(url) {
    return new Promise((resolve, reject) => {
        request(url, (error, response, body) => {
            if (!error && response.statusCode === 200) {
                resolve(body); // 成功获取数据后返回body
            } else {
                reject(error || new Error('Failed to fetch data'));
            }
        });
    });
}

// 使用forEach循环并等待所有请求完成
A.forEach(async item => {
    try {
        const data = await fetchData(item.url);
        item.data = data; // 将获取的数据存储到对象中
        console.log(`Item ${item.id} fetched successfully`);
    } catch (error) {
        console.error(`Error fetching data for item ${item.id}:`, error.message);
    }
});

console.log('All requests have been sent.');

代码解释

  1. 引入request模块：首先，我们引入request模块。
  2. 定义数组A：数组A包含几个对象，每个对象都有一个URL属性。
  3. 定义fetchData函数：这是一个异步函数，它接收一个URL作为参数，并通过request模块发送GET请求。当请求成功时，它返回响应体（即数据）；如果请求失败，则抛出错误。
  4. 循环处理每个对象：我们使用forEach方法遍历数组A中的每个对象。对于每个对象，我们调用fetchData函数，并等待其完成。一旦数据获取成功，我们将数据存储到该对象的data属性中。
  5. 输出信息：最后，我们在控制台输出一些信息以跟踪请求的状态。

这段代码展示了如何在Node.js中使用request模块处理异步HTTP请求，并且如何在循环中处理这些请求。希望这对您有所帮助！


request(host, function (error, response, data) {

}); 说的是这个？

用async模块顺序执行，不然会乱套。

异步回调，写个回调闭包一下就可以了。

在Node.js中使用request模块在循环中发送HTTP请求时，需要注意异步操作的问题。因为request是异步的，所以在循环中直接调用request会导致所有请求并发执行，而不会等待每个请求完成后再处理下一个。

为了解决这个问题，可以使用async库中的eachSeries方法来确保请求按顺序执行。以下是一个完整的示例代码：

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

let A = [
    { url: 'http://example.com/1', data: null },
    { url: 'http://example.com/2', data: null },
    { url: 'http://example.com/3', data: null }
];

async.eachSeries(A, (item, callback) => {
    request(item.url, (error, response, body) => {
        if (!error && response.statusCode == 200) {
            item.data = body; // 将获取的数据存储到对象中
            console.log(`Data for ${item.url}:`, body);
        } else {
            console.error(`Error fetching ${item.url}`, error);
        }
        callback(); // 结束当前迭代
    });
}, (err) => {
    if (err) {
        console.error("An error occurred during the process", err);
    } else {
        console.log("All requests completed successfully.");
    }
});

解释

  1. 引入依赖：首先需要安装request和async模块。可以使用npm命令安装：

    npm install request async

  2. 定义数组：假设我们有一个包含多个对象的数组A，每个对象都有一个url属性。

  3. 使用async.eachSeries：async.eachSeries确保数组中的每个元素都按顺序处理，即它会先处理第一个元素，直到完成，再处理下一个。

  4. 发起请求：在eachSeries的回调函数中，我们使用request发送HTTP请求。请求成功后，将响应体（数据）保存到对应的对象中。

  5. 结束迭代：当请求完成后，通过调用callback()来结束当前迭代。如果所有请求都完成，则外部的eachSeries回调会被调用，并打印结果。

这种方法可以有效地避免并发请求带来的问题，并确保请求按顺序执行。

回到顶部