RxJS 中 Subject 有什么特点？

Question

Subject 其实是观察者模式的实现，所以当观察者订阅 Subject 对象时，Subject 对象会把订阅者添加到观察者列表中，每当有 subject 对象接收到新值时，它就会遍历观察者列表，依次调用观察者内部的 next() 方法，把值一一送出。

在 RxJS（Reactive Extensions for JavaScript）中， Subject 是一个非常重要的概念。它是一个特殊的 Observable，可以作为多播（multicast）的数据源，同时还具有观察者（Observer）的行为。这使得 Subject 在某些场景下比普通的 Observable 更加灵活和强大。下面是 Subject 的一些关键特点：

1. 既是 Observable 也是 Observer

Subject 继承了 Observable 的所有功能，能够被订阅，同时也实现了 Observer 接口，能够通过 next() 、 error() 和 complete() 方法接收数据。

• 作为 Observable : 你可以通过调用 subject.subscribe() 来订阅它，从而接收到通过它发射的值。
• 作为 Observer : 你可以通过调用 subject.next(value) 来向它发送数据，这些数据会被所有订阅者接收到。

2. 多播（Multicast）

普通的 Observable 是单播的（unicast），每个订阅者都会接收到独立的数据流，而 Subject 是多播的，这意味着它可以将相同的数据发送给所有订阅者。

const subject = new Rx.Subject();

subject.subscribe({
  next: (v) => console.log(`Observer A: ${v}`)
});

subject.subscribe({
  next: (v) => console.log(`Observer B: ${v}`)
});

subject.next(1); 
subject.next(2);

// 输出:
// Observer A: 1
// Observer B: 1
// Observer A: 2
// Observer B: 2

在这个例子中，两个订阅者同时接收到 Subject 发出的相同的数据。

3. 没有初始值

Subject 没有初始值。当一个订阅者订阅它时，只能接收到在订阅之后发射的值。因此，如果你想让订阅者一开始就接收到一些值，可以考虑使用 BehaviorSubject 或 ReplaySubject 。

4. 热 Observable（Hot Observable）

Subject 通常被用作热 Observable，意味着它一旦开始发射值，新的订阅者只能接收到从订阅时开始的数据，而不会从头开始接收。这个特性使 Subject 非常适合用在事件流、共享资源等场景中。

5. 多种类型的 Subject

除了普通的 Subject ，RxJS 还提供了几种变体，分别适用于不同场景：

• BehaviorSubject : 有一个初始值，并且总是向订阅者发出最后发射的值。
• ReplaySubject : 可以缓存多个值，并在新的订阅者订阅时重放这些值。
• AsyncSubject : 只发射最后一个值，并在完成时发送给所有订阅者。

6. 适用场景

• 事件处理 : 使用 Subject 处理用户交互事件，如按钮点击、输入变化等。
• 跨组件通信 : 在 Angular 等框架中， Subject 常用于服务中，充当组件之间的事件总线。
• 共享资源 : 当多个订阅者需要共享同一个 Observable 数据流时， Subject 可以用于将数据流广播给多个订阅者。

7. 缺点

Subject 的多播特性虽然强大，但也带来了更多的责任。例如，如果某个订阅者忘记取消订阅，可能会导致内存泄漏。此外，由于 Subject 是热 Observable，在某些情况下可能需要更仔细地处理订阅和取消订阅的时机，以避免丢失数据。

总结

Subject 是 RxJS 中强大的工具，既可以作为数据流的生产者，也可以作为消费者，用于处理复杂的数据流场景。它的多播特性和多种变体使得它能够适应不同的需求，但也需要开发者仔细管理订阅和取消订阅，以避免潜在的问题。

Subject 既是 Observable 对象，又是 Observer 对象，当有新消息时，Subject 会对内部的 observers 列表进行组播 (multicast)。Subject 之所以具有 Observable 中的所有方法，是因为 Subject 类继承了 Observable 类，在 Subject 类中有五个重要的方法：

• next - 每当 Subject 对象接收到新值的时候，next 方法会被调用
• error - 运行中出现异常，error 方法会被调用
• complete - Subject 订阅的 Observable 对象结束后，complete 方法会被调用
• subscribe - 添加观察者
• unsubscribe - 取消订阅 (设置终止标识符、清空观察者列表)

详细的内容可以参考 - RxJS - Subject