如何使用RxJ在Angular中限制并发API请求

npm install rxjs

import { Observable, of, concat } from 'rxjs';
import { mergeMap, map, catchError } from 'rxjs/operators';

function makeRequest(url: string): Observable<any> {
  return Observable.create(observer => {
    // 发起API请求
    fetch(url)
      .then(response => response.json())
      .then(data => {
        observer.next(data);
        observer.complete();
      })
      .catch(error => {
        observer.error(error);
      });
  });
}

const urls = ['url1', 'url2', 'url3']; // 替换为你的API请求URL列表

const concurrentRequests = 2; // 同时发起的API请求数量

const requests = urls.map(url => makeRequest(url));

concat(...requests)
  .pipe(
    mergeMap(request => request.pipe(
      map(response => response),
      catchError(error => of(error))
    ), concurrentRequests)
  )
  .subscribe(response => {
    // 处理API响应
    console.log(response);
  });