在并发数限制下利用 Promise 并发执行请求

2024-01-28 13:37:35

在现代网络应用中，并发请求变得越来越普遍。通过同时向服务器发送多个请求，我们可以提高应用程序的响应速度和吞吐量。但是，当并发请求的数量过大时，可能会导致服务器过载或网络拥塞。为了避免这种情况，我们需要对并发请求的数量进行限制。

Promise 是 JavaScript 中用于处理异步操作的内置对象。它可以帮助我们更轻松地编写异步代码，并使代码更易读和易于维护。

在 JavaScript 中使用 Promise 实现并发请求

在 JavaScript 中，我们可以使用 Promise.all() 方法来实现并发请求。Promise.all() 方法接受一个 Promise 对象数组作为参数，并返回一个新的 Promise 对象。当所有传入的 Promise 对象都已完成时，新的 Promise 对象才会完成。

例如，以下代码使用 Promise.all() 方法实现了三个并发请求：

const url1 = 'https://example.com/api/v1/users';
const url2 = 'https://example.com/api/v1/posts';
const url3 = 'https://example.com/api/v1/comments';

const promises = [
  fetch(url1),
  fetch(url2),
  fetch(url3)
];

Promise.all(promises)
  .then(responses => {
    const data = responses.map(response => response.json());
    return Promise.all(data);
  })
  .then(data => {
    console.log(data);
  })
  .catch(error => {
    console.error(error);
  });

在上面的代码中，我们首先定义了三个 URL，分别用于获取用户、帖子和评论的数据。然后，我们创建一个 Promise 对象数组，并将三个 fetch() 请求放入其中。接下来，我们调用 Promise.all() 方法，将 Promise 对象数组作为参数传入。

Promise.all() 方法会等待所有三个请求都完成，然后返回一个新的 Promise 对象。当新的 Promise 对象完成时，它会调用 then() 方法。在 then() 方法中，我们使用 map() 方法将每个响应对象转换为 JSON 对象，并将其放入一个新的数组中。然后，我们调用 Promise.all() 方法，将新的数组作为参数传入。

新的 Promise 对象完成时，它会调用 then() 方法。在 then() 方法中，我们将数据输出到控制台。如果在请求过程中发生错误，它会调用 catch() 方法。在 catch() 方法中，我们将错误输出到控制台。

在并发数限制下使用 Promise 并发完成请求

为了在并发数有限的情况下使用 Promise 并发完成请求，我们可以使用以下步骤：

确定要同时发送的请求数量。
创建一个 Promise 对象数组，并将请求放入其中。
调用 Promise.all() 方法，将 Promise 对象数组作为参数传入。
在 then() 方法中，处理请求结果。
在 catch() 方法中，处理请求错误。

例如，以下代码在并发数限制为 2 的情况下，使用 Promise 并发完成三个请求：

const url1 = 'https://example.com/api/v1/users';
const url2 = 'https://example.com/api/v1/posts';
const url3 = 'https://example.com/api/v1/comments';

const promises = [
  fetch(url1),
  fetch(url2),
  fetch(url3)
];

let activeRequests = 0;
let completedRequests = 0;
const maxConcurrentRequests = 2;

const processRequest = () => {
  if (activeRequests < maxConcurrentRequests && completedRequests < promises.length) {
    const request = promises[completedRequests];
    activeRequests++;
    completedRequests++;

    request.then(response => {
      activeRequests--;
      const data = response.json();
      return Promise.all(data);
    })
    .then(data => {
      console.log(data);
    })
    .catch(error => {
      activeRequests--;
      console.error(error);
    })
    .finally(() => {
      processRequest();
    });
  }
};

processRequest();

在上面的代码中，我们首先定义了三个 URL，分别用于获取用户、帖子和评论的数据。然后，我们创建一个 Promise 对象数组，并将三个 fetch() 请求放入其中。接下来，我们定义了 activeRequests 和 completedRequests 变量，用于跟踪正在进行的请求数量和已完成的请求数量。

我们还定义了一个 maxConcurrentRequests 变量，用于指定同时可以发送的请求数量。然后，我们定义了一个 processRequest() 函数，用于处理请求。

在 processRequest() 函数中，我们首先检查 activeRequests 和 completedRequests 的值。如果 activeRequests 小于 maxConcurrentRequests，并且 completedRequests 小于 promises.length，则表示我们还可以发送更多的请求。

接下来，我们从 promises 数组中获取下一个请求，并将 activeRequests 和 completedRequests 的值分别加 1。然后，我们发送请求并处理请求结果。

在请求完成时，我们将 activeRequests 的值减 1，并将请求结果输出到控制台。如果请求过程中发生错误，我们将 activeRequests 的值减 1，并将错误输出到控制台。

最后，我们调用 processRequest() 函数，以处理下一个请求。