RxJS中forkJoin与mergeMap用法是否合规？并行请求实现咨询

需求：尽可能并行发起所有请求，以下是简化代码：

const arr = [
  'https://jsonplaceholder.typicode.com/users/1',
  'https://jsonplaceholder.typicode.com/users/2',
  'https://jsonplaceholder.typicode.com/users/3',
];

let observables = [];
for (let url of arr) {
  observables.push(this.http.get(url));
}

const obs$ = this.http.get('http://localhost:3000/users').pipe(
  map((data: any) => {
    //an array of urls like https://jsonplaceholder.typicode.com/users/5
    let urls = data.data;
    let observables = [];
    for (let url of urls) {
      observables.push(this.http.get(url));
    }
    return observables;
  }),
  mergeMap((data) => forkJoin([...data]))
);

forkJoin([...observables, obs$]).subscribe({
  next: (data) => console.log(data, 'from fork'),
  error:(err)=>console.log(err)
});

现有两个核心疑问：

• 当前实现是否符合「尽可能并行发起所有请求」的需求？
• mergeMap((data) => forkJoin([...data]))仅用于取出嵌套Observable，是否可替换为concatMap或switchMap且效果一致？

1. 当前实现是否符合需求？ #

不符合。原因是obs$的执行逻辑是先请求http://localhost:3000/users获取URL列表，再并行请求这些URL；而外层forkJoin只是把observables里的请求和obs$整体作为并行项。这导致：

• observables中的3个请求会和obs$的第一个请求（/users）同时发起
• 但obs$内部的URL对应的请求，必须等/users请求完成后才会启动，无法和observables里的请求完全并行

如果要实现所有请求（包括obs$内部的）尽可能并行，需要先获取obs$中的URL列表，再将原arr的URL与新列表合并，统一生成请求后用forkJoin并行发起。

2. 能否替换为concatMap或switchMap且效果一致？ #

可以替换，当前场景下三者效果完全相同，原因如下：

• mergeMap：会立即订阅内部的forkJoin流，无需等待外层流的其他操作
• concatMap：会等待外层流的前一个任务完成后再订阅内部流，但这里外层流只有/users这一个HTTP请求，只会发射一次值，所以和mergeMap行为一致
• switchMap：如果外层流有新的发射值，会取消之前的内部订阅，但同样，/users请求只会发射一次结果，不会触发取消逻辑，因此也和mergeMap效果一致

不过从语义匹配的角度，mergeMap更贴合「并行处理内部流」的意图，但仅针对当前场景，三者最终的执行结果没有差异。

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