关于RxJS Subject的学习笔记

关于RxJS Subject的学习笔记，我会从以下几个方面进行详细讲解：

1. Subject的介绍和作用
2. Subject的使用方式和示例
3. Subject的一些应用场景和注意事项

1. Subject的介绍和作用

RxJS Subject是一种特殊的Observable，允许像事件一样多播到多个观察者。Subject既是观察者也是可观察对象。简单来说，Subject可以把一个数据流像一个广播一样分发给多个订阅者，订阅者可以同时接收到Subject发送的数据流。

Subject的使用方式和Observable基本相同，可以通过Subject的next方法向订阅者发送新值，也可以通过complete方法标记Subject已经完成，而任何订阅之后的observer都将会自动取消，从而释放资源。

2. Subject的使用方式和示例

下面我们来看一下Subject的使用方式和示例:

import { Subject } from 'rxjs';

// 创建Subject对象
const subject = new Subject();

// 订阅Subject
subject.subscribe({
  next: (v) => console.log(`observerA: ${v}`)
});

// next方法发送数据流
subject.next(1);
subject.next(2);

// 订阅Subject，接收到2以后停止订阅
subject.subscribe({
  next: (v) => console.log(`observerB: ${v}`)
});

subject.next(3);
subject.complete();

输出结果如下：

observerA: 1
observerA: 2
observerA: 3
observerB: 3

可以看到，Subject的订阅者可以同时接收到Subject发送的数据流，并且在9行时，observerB不会接收到1和2的数据流。

再看一个Subject的多播示例：

import { Subject } from 'rxjs';
import { interval } from 'rxjs';
import { take } from 'rxjs/operators';

const subject = new Subject();
const observable = interval(1000).pipe(take(5));

observable.subscribe(subject);

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

setTimeout(() => {
  subject.subscribe({
    next: (v) => console.log(`observer B: ${v}`)
  });
}, 3000);

在这个示例中，我们定义了一个interval的可观察对象，它每隔一秒钟产生一个新的值，上限为5，然后我们把这个可观察对象传给一个Subject对象来创建一个数据流广播，在3秒后订阅一个新的观察者B，可以看到观察者A和观察者B都能接收到Subject的数据流。

3. Subject的一些应用场景和注意事项

除了上述示例中的使用方式，Subject还有更多的用法，比如在HTTP请求中，我们可以使用Subject来缓存请求结果，避免多次重复请求。

但是需要注意的是，Subject并不是完全无状态的，而是有自己的状态的，如果订阅Subject时，Subject已经发出了一些数据，那么订阅者只能获取到以后发出的数据，不能读取Subject发出的历史数据。同时，如果Subject已经完成，订阅者将无法接收到Subject的任何数据流。

另外，在多个组件中使用同一个Subject时要特别小心，在任意组件中使用complete取消订阅，都将导致Subject无法再分发数据流。因此，在完全不需要Subject时，必须手动complete Subject来保证内存得到释放。

以上就是关于RxJS Subject的学习笔记的完整攻略。