RxJS 是一种反应式编程库，它强调以数据流为中心的编程模型。在 RxJS 中，运用操作符来处理数据流是非常普遍的，因为它们可以实现丰富的流操作和处理；其中一部分操作符有时候容易被混淆，比如 exhaustMap 和 concatMap。要想更好地应用 RxJS，我们需要了解 exhaustMap 和 concatMap 的不同之处，以及它们的使用技巧。
exhaustMap
exhaustMap 操作符在处理一个高阶 (Nested) Observable 前，确保在此前其他的 Observables (非高阶) 中没有正在处理的，如果有则忽略此 Observable。该操作符将高阶 Observable 的值映射到一个新的 Observable。在高阶 Observable 中的每个值上，它都将订阅内部 Observable 以发出值并合并结果。仅当前一个 Observable 完成，才会订阅下一个可订阅的源。
在实际开发过程中，我们可以使用 exhaustMap 来防止重复调用。比如，在 Web 应用中，按钮点击事件通常会频繁触发多次，我们可能需要通过 HTTP 请求来获取与该按钮关联的数据，而 exhaustMap 是一个很好的解决方案，因为在前一个请求返回之前不会触发新的请求。
下面是一个简单的示例：
-- -------------------- ---- ------- ------ - ---------- -------- - ---- ------- ------ - ----------- ---- - ---- ----------------- ----- --- - --------------------------------- ----- ------- - -------------- --------- ----- --------- - --------------- ------- ------ ------------- -- --------------- ------- - - - ------------------------展开代码
在上面的示例中，我们创建了一个点击按钮事件的 Observable，然后将点击事件映射为每秒发出值的 interval Observable，该示例通过 exhaustMap 操作符来防止重复请求。由于 exhaustMap 忽略内部 Observable 中的值，直到前一个 Observable 完成后才会订阅下一个 Observable，因此我们可以确保在前一个 Observable 完成之前不会触发新的点击事件，而前一个 Observable 可能是一个 Ajax 请求。
concatMap
concatMap 操作符和 exhaustMap 很相似，但和后者不同的是，它会顺序发出值，而不是忽略除第一个外的所有其他值；此外，concatMap 可以同时处理多个高阶 Observable 中的值。
concatMap 会在订阅后立即开始处理，所以它可以有多个内部 Observable 在同时处理。当一个内部 Observable 完成后，concatMap 将才会订阅下一个内部 Observable，以此类推。由于它处理多个 Observable，因此可以使多个请求同时进行，但顺序发出值仍然是有序的。
以下是一个简单的例子：
-- -------------------- ---- ------- ------ - ---------- -------- - ---- ------- ------ - ---------- ---- - ---- ----------------- ----- --- - --------------------------------- ----- ------- - -------------- --------- ----- --------- - --------------- ------- ------ ------------ -- --------------- ------- - - - ------------------------展开代码
在上面的示例中，我们创建了一个点击事件的 Observable，并将其映射为一个生成每秒发出值的 interval Observable。通过使用 concatMap 操作符，我们确保内部 Observable 的值会按顺序发出。
总结
exhaustMap 和 concatMap 都是 RxJS 操作符，都可以用来处理高阶 Observable，但它们的不同之处在于，exhaustMap 保证只处理当前内部 Observable，直到一个 Observable 完成后才能开始下一个，而 concatMap 会同时处理多个内部 Observable，但顺序发出值仍然是有序的。
在实际开发中，根据不同的需求，选择合适的操作符是很重要的。如果你需要防止重复调用，使用 exhaustMap 可以防止重复请求；但如果你需要按顺序发出值，使用 concatMap 适合并行处理多个请求。
现在，我们已经了解了 exhaustMap 和 concatMap 操作符的不同之处及其使用技巧，希望这篇文章能对你有所帮助。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/6655da97d3423812e4a82182
