RxJS 是一个强大的响应式编程库，它提供了许多实用的工具和操作符来完成各种任务。其中一个最强大的工具就是 Subject。Subject 既是观察者（Observer），又是可观察对象（Observable），可以从任意位置接收值，也可以推送和订阅值。在这篇文章中，我们将深入了解 RxJS 中的 Subject 是什么、为什么需要它，以及如何使用它。
什么是 Subject？
Subject 是 RxJS 中的一个特殊的 Observable，它可以多播一个值或一个事件序列给多个观察者。与普通的 Observable 不同，Subject 具备以下特性：
- Subject 是可观察对象和观察者的双重身份，可以接收值并发布给观察者。
- Subject 是多播的，即可以将值发送给多个观察者。
- Subject 是热的，即无论观察者是否订阅，Subject 仍然会发送值。
为什么需要 Subject？
在有些场景中，我们需要让多个观察者监听同一个可观察对象，并且这些观察者需要同时接收到值的更新，这时就需要使用 Subject。例如，我们可以使用 Subject 来创建一个跨组件的事件总线，使得不同组件之间可以相互通信。
如何使用 Subject？
Subject 的创建
在 RxJS 中，可以使用 new Subject() 函数来创建一个 Subject。例如，下面的代码创建了一个名为 mySubject 的 Subject：
import { Subject } from 'rxjs';
const mySubject = new Subject();Subject 的使用
1. 发送值
可以使用 next() 方法来向 Subject 发送值，例如：
mySubject.next('Hello');
mySubject.next('World');2. 订阅值
可以使用 subscribe() 方法来订阅 Subject 发送的值，例如：
mySubject.subscribe(value => console.log(value));
此时，subscribe() 方法返回的是一个 Subscription 对象，可以使用 unsubscribe() 方法来取消订阅。
3. 多播值
Subject 可以多播值到多个观察者，例如：
mySubject.subscribe(value => console.log(`Subscriber 1: ${value}`));
mySubject.subscribe(value => console.log(`Subscriber 2: ${value}`));
mySubject.next('Hello');运行上述代码，会得到如下输出：
Subscriber 1: Hello Subscriber 2: Hello
4. 外部控制
有时候，我们需要在外部控制 Subject 的行为，比如可以使用 complete() 方法来结束 Subject 的发送行为，例如：
mySubject.subscribe({
next: value => console.log(value),
complete: () => console.log('Complete')
});
mySubject.next('Hello');
mySubject.complete();运行上述代码，会得到如下输出：
Hello Complete
5. Subject 的类型
在 RxJS 中，还有其他类型的 Subject，例如：
- BehaviorSubject：当有新的观察者订阅时，会将最新的值发送给它，因此它具有初始值。
- ReplaySubject：可以缓存一定数量的值，当有新的观察者订阅时，可以将缓存的值发送给它。
这些类型的 Subject，可以根据实际需求进行选择。
总结
在本文中，我们深入了解了 RxJS 中的 Subject 是什么、为什么需要它，以及如何使用它。Subject 是一个强大的工具，可以让多个观察者同时接收到同一个可观察对象的值更新。通过 Subject，我们可以轻松地创建跨组件的事件总线，实现组件之间的通信。
来源：JavaScript中文网 ，转载请注明来源 本文地址：https://www.javascriptcn.com/post/6531eae57d4982a6eb3f6e4f