在 RxJS 中，我们可以使用多播操作符来让多个 Observable 订阅同一个源 Observable，从而实现多个订阅者共享同一份数据流。
多播操作符的介绍
多播操作符通常会用到 Subject 类型。Subject 是一种特殊类型的 Observable，它可以像观察者一样收到数据，同时又可以像 Observable 一样将数据发送给订阅者。
share 操作符
share 操作符是多播操作符中最简单的一种，它的作用是让多个订阅者共享同一份数据流，这样可以避免重复的订阅和重复的数据请求，提升程序性能。
示例代码：
-- -------------------- ---- ------- ------ - -- - ---- ------- ------ - ---- ------ ----- - ---- ----------------- ----- ------- - ---------- -------------- ------ -- ----------------- ----------- ------------- -- ----- ------- - ---------------------- ---------------------- -- ------------------------- -- ----------- ---------------------- -- ------------------------- -- -----------
输出结果为：
Side effect! Subscription 1: Data Subscription 2: Data
可以看到，当我们使用 share 操作符将源 Observable 转换成共享 Observable 时，tap 操作符只会执行一次，多个订阅者共享同一份数据流。
multicast 操作符
multicast 操作符是比 share 操作符更加灵活的一种多播操作符，它可以自定义如何将数据流共享给订阅者。
multicast 操作符接受一个 Subject 类型的参数，用于控制数据流的共享方式。
示例代码：
-- -------------------- ---- ------- ------ - --- ------- - ---- ------- ------ - ---- ------ --------- - ---- ----------------- ----- ------- - ---------- -------------- ------ -- ----------------- ----------- ------------- -- ----- -------- - --- ---------- ----- ------------ - ---------------------------------- --------------------------- -- ------------------------- -- ----------- --------------------------- -- ------------------------- -- ----------- ----------------------- -- ----------
输出结果为：
Side effect! Subscription 1: Data Subscription 2: Data
可以看到，当我们使用 multicast 操作符将源 Observable 转换成共享 Observable 时，我们可以通过 Subject 参数自定义数据流的共享方式。在上面的示例中，我们手动调用 connect 方法开始数据流的共享。
refCount 操作符
refCount 操作符是 multicast 操作符的补充，它可以让共享 Observable 自动开始和停止数据流的共享。
示例代码：
-- -------------------- ---- ------- ------ - -- - ---- ------- ------ - ---- ------ ---------- -------- - ---- ----------------- ----- ------- - ---------- -------------- ------ -- ----------------- ----------- ------------- -- ----- ------------ - -------------------------- ----------- ------------ --------------------------- -- ------------------------- -- ----------- --------------------------- -- ------------------------- -- -----------
输出结果为：
Side effect! Subscription 1: Data Side effect! Subscription 2: Data
可以看到，当我们使用 multicast 操作符将源 Observable 转换成共享 Observable 后，再使用 refCount 操作符自动开始和停止数据流的共享后，多个订阅者共享同一份数据流。在上面的示例中，当第一个订阅者订阅数据流时，数据流开始共享；当最后一个订阅者取消订阅时，数据流停止共享。
总结
多播操作符是 RxJS 中一种重要的数据流管理工具，它可以让多个 Observable 订阅同一个源 Observable，实现多个订阅者之间共享同一份数据流。在实际开发中，我们可以根据业务需求选择不同的多播操作符，增强程序的性能和可读性。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/64d20cbfb5eee0b52596cb01