Angular中如何分批执行超大批量Http Post请求？

核心思路 #

将大数组按每50个一组拆分，每个批次内部用combineLatest并行发起请求，批次之间用concat串行执行，确保上一批所有请求完成后再启动下一批，避免一次性发起过多请求触发限制。

步骤1：实现数组拆分工具函数 #

先写一个通用的数组拆分函数，把原始数据数组分成指定大小的子数组：

private chunkArray<T>(array: T[], size: number): T[][] {
  const chunks = [];
  for (let i = 0; i < array.length; i += size) {
    chunks.push(array.slice(i, i + size));
  }
  return chunks;
}

步骤2：修改请求调用逻辑 #

替换原来直接用combineLatest(peticionesI3)的代码，改成分批执行：

return this.httpService.doPost(url, data1, '')
  .pipe(
    switchMap(r => combineLatest(peticionesI2)),
    switchMap(() => {
      // 拆分原始数据为每50个一组的批次
      const dataBatches = this.chunkArray(dataArrayI3, 50);
      
      // 每个批次生成一个并行请求的Observable
      const batchObservables = dataBatches.map(batch => 
        combineLatest(batch.map(data => this.httpService.doPost(url, data, '')))
      );
      
      // 用concat串行执行所有批次，前一批完成再启动下一批
      return concat(...batchObservables);
    })
  );

可选：收集所有请求结果 #

如果需要将所有批次的请求结果合并成一个完整数组（和原来combineLatest的输出结构一致），可以用scan操作符累加结果：

return this.httpService.doPost(url, data1, '')
  .pipe(
    switchMap(r => combineLatest(peticionesI2)),
    switchMap(() => {
      const dataBatches = this.chunkArray(dataArrayI3, 50);
      const batchObservables = dataBatches.map(batch => 
        combineLatest(batch.map(data => this.httpService.doPost(url, data, '')))
      );
      
      // 累加每个批次的结果，最终返回完整的结果数组
      return concat(...batchObservables).pipe(
        scan((totalResults, currentBatchResults) => [...totalResults, ...currentBatchResults], [])
      );
    })
  );

关键说明 #

• combineLatest：用于同一批次内的并行请求，提高单批次的处理效率
• concat：严格按顺序执行批次，只有当前一个批次的所有请求都完成后，才会触发下一批请求，避免并发数超限
• 拆分大小可根据实际限制调整（比如改成20或100），不需要固定50

内容的提问来源于stack exchange，提问作者user2171002