RxJS中subscribe提供Subject的作用是什么？为何要使用该用法？

1. 该写法的本质含义 #

RxJS中的Subject是特殊的双身份类型，同时实现了Observer接口和Observable接口：

• 作为Observable，它支持被多个观察者订阅，可注册多个下游消费逻辑
• 作为Observer，它自带next、error、complete三个标准方法，完全符合subscribe方法的入参要求（subscribe第一个参数就是接收实现了上述三个方法的Observer对象）
  所以把Subject实例直接传入subscribe，本质就是将Subject作为上游Observable的观察者，接收上游发出的所有事件通知。

2. 该写法的核心作用 #

这个写法的核心价值是实现冷Observable的多播能力。
普通冷Observable（比如示例中from创建的对象）是单播的，每新增一个观察者调用subscribe，上游都会独立执行一次生产逻辑。如果上游是HTTP请求、大规模计算这类高开销逻辑，多次执行会造成严重的资源浪费。
通过Subject做中间中转可以解决这个问题：

• 上游Observable只需要订阅一次Subject，仅执行一次生产逻辑
• 所有下游观察者统一订阅这个Subject，上游产生的每一个值都会被Subject广播给所有已注册的下游观察者

可以对比两种写法的执行差异：

// 不用Subject的写法：上游会执行2次数组遍历
const observable = from([1,2,3]);
observable.subscribe(v => console.log(`observerA: ${v}`))
observable.subscribe(v => console.log(`observerB: ${v}`))

// 用Subject中转的写法：上游仅执行1次数组遍历，结果和上面一致
const subject = new Subject<number>();
subject.subscribe(v => console.log(`observerA: ${v}`))
subject.subscribe(v => console.log(`observerB: ${v}`))
from([1,2,3]).subscribe(subject)

当上游是接口请求类逻辑时，两种写法的差异会直接体现在请求次数上，收益非常明显。

3. 适用场景 #

• 上游Observable执行开销大，需要避免重复执行的场景，比如全局共享的HTTP请求、websocket消息流
• 需要将单播的冷数据源转换为多播的热数据源，供多个下游组件同时消费的场景
• 需要统一管理多个观察者的订阅关系的场景

你给出的示例代码就是标准的多播实现：

import { Subject, from } from 'rxjs';
 
const subject = new Subject<number>();
 
// 给Subject注册两个下游观察者
subject.subscribe({
  next: (v) => console.log(`observerA: ${v}`)
});
subject.subscribe({
  next: (v) => console.log(`observerB: ${v}`)
});
 
const observable = from([1, 2, 3]);
 
// 把Subject作为上游Observable的观察者传入subscribe，上游开始执行生产逻辑
observable.subscribe(subject); 

// 输出结果：上游每发出一个值，Subject就广播给所有下游观察者
// observerA: 1
// observerB: 1
// observerA: 2
// observerB: 2
// observerA: 3
// observerB: 3

内容的提问来源于stack exchange，提问作者Ibrahim Rashwan