Rxjs/reactor 限制运算符等效于 ajax 请求

【问题标题】：Rxjs/reactor limit operator equivalent for ajax requestsRxjs/reactor 限制运算符等效于 ajax 请求
【发布时间】：2018-11-28 09:29:08
【问题描述】：

我想要实现的是同时执行许多 ajax 请求（从 10 到 1000+），但活动请求的限制为 5（就请求的执行而言，就像 FIFO 队列）。

例如，我们有一个包含 100 个 http 地址的数组，我们想要获取前 5 个并为每个请求执行一个 GET 请求，如果这五个请求中的任何一个结束，那么另一个地址应该进入队列并执行其 GET 请求，直到所有100 个地址发出请求并完成。

在 reactor 库中，limitRequest 运算符符合我的描述

我的问题是如何使用 rxjs 实现类似的行为？

我尝试使用缓冲区运算符，但它每完成 5 个请求就会发出结果，我想要的是在请求完成后立即发出结果。

我创建了一个stackblitz

尝试对此进行实验

【问题讨论】：

标签： javascript ajax rxjs reactor

【解决方案1】：

您只需两个 mergeMaps 即可完成所有这些操作。 mergeMap 运算符接受第二个参数，即并发 Observable 的数量。第一个 mergeMap 将用于解包来自服务器的 URL 数组，第二个将保留 5 个并发请求：

根据您的 stackblitz 演示（顺便感谢您提供演示），您可以将所有这些放入单个 RxJS 链中。

from(axios.get("https://jsonplaceholder.typicode.com/photos")).pipe(
  mergeMap(response => response.data // Unwrap the array of URLs into single emissions
    .filter(x => x.albumId === 100)
    .map(x => x.url)
  ),
  mergeMap(url => of(url).pipe(delay(1000 * Math.random())), 5), // Mock additional requests with of() and delay()
).subscribe(console.log);

您更新的演示：https://stackblitz.com/edit/photo-dls-pb27pn?file=index.js

【讨论】：

哇，太好了，我最后也使用了 mergeMap，但是这个解决方案更具凝聚力