使用RxJS concat调用API遇错误后如何继续发起请求？

你现在遇到的问题核心在于concat的特性：一旦序列里某个Observable抛出错误，整个concat流会直接终止，不再执行后续请求。而你把catchError加在整个concat流后面，只会捕获一次错误就结束整个流——这显然不是你想要的效果。

正确的思路是给每个单独的API请求Observable添加独立的错误捕获，让单个请求的错误被隔离处理，不会影响整个concat序列的执行。

修改后的代码示例 #

getData() {
  // 可以初始化一个数组来收集所有错误（按需使用）
  this.requestErrors = [];

  concat(
    ...this.data.map(asset => 
      this.assetService.requestData({ assetId: asset._id })
        .pipe(
          catchError(error => {
            // 记录当前请求的错误详情，方便后续排查
            console.log(`资产ID ${asset._id} 请求失败:`, error);
            this.requestErrors.push({ assetId: asset._id, error });
            
            // 返回一个不会抛出错误的Observable，让concat继续执行下一个请求
            // 可选：用EMPTY（需导入import { EMPTY } from 'rxjs';）则不会向subscribe传递null值
            return of(null);
          })
        )
    )
  )
  .subscribe(
    response => {
      if (response) {
        // 只处理成功的请求响应
        console.log('请求成功:', response);
        // 这里添加你的成功逻辑，比如把响应数据存入列表
      }
    },
    () => {
      // 注意：因为每个请求的错误都被单独捕获了，这个全局错误回调几乎不会触发
    },
    () => {
      // 所有请求（成功/失败）都执行完毕时触发
      console.log('全部API请求处理完成');
      if (this.requestErrors.length > 0) {
        console.log('捕获到的错误列表:', this.requestErrors);
        // 这里可以统一处理错误，比如给用户提示部分请求失败
      }
    }
  );
}

关键细节说明 #

1. 错误隔离处理：每个requestData都通过自身的pipe(catchError(...))处理错误，返回of(null)或EMPTY，让concat认为这个Observable已正常完成，进而执行下一个请求。
2. 错误收集方案：用数组存储每个失败请求的详情，最后在concat完成时统一处理，方便后续排查或给用户反馈。
3. EMPTY vs of(null)：
   • 用EMPTY时，该请求不会向subscribe传递任何值，后续无需判断是否为null；
   • 用of(null)时，subscribe会收到null，可通过判断过滤失败响应。

进阶优化：过滤失败请求结果 #

如果不想在subscribe里处理null，可以用filter操作符提前过滤：

import { filter } from 'rxjs/operators';

// ...

concat(...)
.pipe(
  filter(response => response !== null)
)
.subscribe(response => {
  // 这里只会收到成功的响应，无需额外判断
  console.log('成功响应:', response);
});

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