RxJS 的 Observable 和 Subject 有什么区别？

在RxJS中，Observable和Subject都是可观察序列的基础构建块，但它们在功能和用法上有一些关键的区别：

Observable

1. 基本概念：Observable是RxJS提供的一种数据类型，它表示一个可随时间推送值的异步数据流。你可以订阅（subscribe）一个Observable，然后在值到来的时候通过提供的回调函数进行处理。
2. 单向数据流：Observable是单向数据流的，意味着它们可以发射（emit）数据、完成（complete）或者发出错误（error），但是外部是无法直接对Observable发射的数据流进行控制的。
3. 冷Observable：默认情况下，Observable是冷的（cold），这意味着每一个订阅者都会得到一个独立的数据流。这就是说，Observable在每次有新的订阅者订阅时，都会重新启动数据流。因此，每个订阅者都能看到完整的数据序列。

例子：如果你创建一个基于HTTP请求的Observable，每次调用.subscribe()时，都会发起一个新的HTTP请求。

Subject

1. 基本概念：Subject继承自Observable，因此它既是一个Observable也是一个Observer。这意味着Subject不仅可以像Observable那样发射值，还可以订阅其他Observable。
2. 双向数据流：与Observable不同，Subject可以是多播的（multicast），它可以同时作为数据源和消费者。你可以手动调用.next()方法来向所有的订阅者推送新的值，从而允许外部对Subject发射的数据流进行控制。
3. 热Observable：Subject是热的（hot），这意味着它会共享单个数据流给所有订阅者。不会像冷Observable那样对每个订阅者重新发射数据，而是当一个新的值被推送时，所有的订阅者都能收到这个新值。

例子：如果你有一个WebSocket连接的Subject，那么无论有多少订阅者，数据都是通过同一个WebSocket连接发送和接收的。

举例

为了更清楚地理解两者的差异，让我给出一个例子：

假设我们正在构建一个实时股票价格更新系统，对于股票价格的更新，我们可能会使用Subject，因为我们希望所有的订阅者看到同样的价格变动，而不需要为每个订阅者重新获取数据。

而对于用户的个人交易请求，每个请求可能都是独立的，我们可能会为每个请求创建一个新的Observable，以确保每次操作都是独立的而且互不影响。

总结来说，Observable适用于单向、独立的数据流，而Subject更适合那些需要多播或由外部主动推送数据的场景。

在流编程中有两个主要接口：Observable和Observer。

Observable是针对消费者的，它可以被转换和订阅：

shell
observable.map(x => ...).filter(x => ...).subscribe(x => ...)

观察者是用于提供可观察源的接口：

shell
observer.next(newItem)

我们可以使用Observer创建新的****Observable：

shell
var observable = Observable.create(observer => { 
    observer.next('first'); 
    observer.next('second'); 
    ... 
});
observable.map(x => ...).filter(x => ...).subscribe(x => ...)

或者，我们可以使用一个同时实现Observable和Observer接口的****主题：

shell
var source = new Subject();
source.map(x => ...).filter(x => ...).subscribe(x => ...)
source.next('first')
source.next('second')

Observables 按设计是单播的，Subjects 按设计是多播的。

如果您查看下面的示例，您会发现每个订阅都会收到不同的值，因为可观察量按设计开发为单播。

shell
import {Observable} from 'rxjs';

let obs = new Observable<any>(observer=>{
   observer.next(Math.random());
})

obs.subscribe(res=>{
  console.log('subscription a :', res); //subscription a :0.2859800202682865
});

obs.subscribe(res=>{
  console.log('subscription b :', res); //subscription b :0.694302021731573
});

如果您希望两个订阅具有相同的值，这可能会很奇怪。

我们可以使用主题来解决这个问题。**主题与事件发射器类似，它不会为每个订阅调用。**考虑下面的例子。

shell
import {Subject} from 'rxjs';

let obs = new Subject();

obs.subscribe(res=>{
  console.log('subscription a :', res); // subscription a : 0.91767565496093
});

obs.subscribe(res=>{
  console.log('subscription b :', res);// subscription b : 0.91767565496093
});

obs.next(Math.random());

两个订阅都获得相同的输出值！

请参阅 rxjs 文档（那里有更多信息和示例）： http://reactivex.io/rxjs/manual/overview.html#subject

什么是主题？RxJS主题是一种特殊类型的Observable，它允许将值多播到许多观察者。普通 Observable 是单播的（每个订阅的观察者都拥有 Observable 的独立执行），而主题是多播的。

一个Subject就像一个Observable，但可以多播到许多观察者。主题就像 EventEmitters：它们维护许多侦听器的注册表。

和代码，Subject扩展Observable：https://github.com/ReactiveX/rxjs/blob/master/src/internal/Subject.ts#L22

shell
/**
 * @class Subject<T>
 */
export class Subject<T> extends Observable<T> implements SubscriptionLike {
//...
}

rxjs 中的 Observable 和Subject 有什么区别？,Observable 和 Subject 都是 RxJS 库中的重要概念，它们用于处理异步事件和基于推送模型的数据流，但它们之间有一些关键区别：

Observable

• 基础概念: Observable 是 RxJS 中的基础类。它代表一个可观察的序列，可以发出三种类型的事件：值、错误和完成通知。
• 单播性质: Observable 是单播的，这意味着对于每个订阅者，Observable 都会独立执行。如果你有多个订阅者，每个订阅者都会观察到独立的事件序列。
• 惰性运行: Observable 在默认情况下是惰性的，也就是说，它只有在有订阅者时才开始执行。这与函数调用类似，只有当你调用它时，它才会运行。
• 操作符: Observable 可以使用各种 RxJS 提供的操作符进行转换、合并、过滤等操作。

Subject

• 特殊的 Observable: Subject 是一种特殊类型的 Observable，它允许将值多播给多个观察者。这意味着当一个 Subject 发出一个事件时，所有的订阅者都会接收到相同的事件。
• 观察者身份: Subject 也实现了 Observer 接口，这使它可以作为数据源，你可以明确地调用 next(value)、error(e) 和 complete() 方法来发出事件，这是普通 Observable 无法做到的。
• 热数据流: 由于 Subject 是多播的，它通常代表“热”数据流。一旦值被发出，不论是否存在订阅者，该值可能会丢失。如果后来有新的订阅者，它们可能会错过之前发出的事件。
• 变种: Subject 有几个变种，包括 BehaviorSubject、ReplaySubject 和 AsyncSubject，它们具有不同的行为特性，比如能够缓存值。

对比总结

• 多播与单播: Observable 是单播，每个订阅者都有独立的执行上下文；而 Subject 是多播，多个观察者共享同一事件流。
• 主动与被动: Subject 可以主动发出事件，而 Observable 是被动的，它通过操作符或者创建函数来发出事件。
• 热与冷: Observable 通常用于表示冷数据流，而 Subject 表示热数据流。

在实际应用中，选择使用 Observable 还是 Subject 取决于你的特定需求，比如是否需要多播、是否需要主动控制事件的发出等。

Observable 和 Subject 都是 RxJS 库中的重要概念，它们用于处理异步事件和基于推送模型的数据流，但它们之间有一些关键区别：

Observable

• 基础概念: Observable 是 RxJS 中的基础类。它代表一个可观察的序列，可以发出三种类型的事件：值、错误和完成通知。
• 单播性质: Observable 是单播的，这意味着对于每个订阅者，Observable 都会独立执行。如果你有多个订阅者，每个订阅者都会观察到独立的事件序列。
• 惰性运行: Observable 在默认情况下是惰性的，也就是说，它只有在有订阅者时才开始执行。这与函数调用类似，只有当你调用它时，它才会运行。
• 操作符: Observable 可以使用各种 RxJS 提供的操作符进行转换、合并、过滤等操作。

Subject

• 特殊的 Observable: Subject 是一种特殊类型的 Observable，它允许将值多播给多个观察者。这意味着当一个 Subject 发出一个事件时，所有的订阅者都会接收到相同的事件。
• 观察者身份: Subject 也实现了 Observer 接口，这使它可以作为数据源，你可以明确地调用 next(value)、error(e) 和 complete() 方法来发出事件，这是普通 Observable 无法做到的。
• 热数据流: 由于 Subject 是多播的，它通常代表“热”数据流。一旦值被发出，不论是否存在订阅者，该值可能会丢失。如果后来有新的订阅者，它们可能会错过之前发出的事件。
• 变种: Subject 有几个变种，包括 BehaviorSubject、ReplaySubject 和 AsyncSubject，它们具有不同的行为特性，比如能够缓存值。

对比总结

• 多播与单播: Observable 是单播，每个订阅者都有独立的执行上下文；而 Subject 是多播，多个观察者共享同一事件流。
• 主动与被动: Subject 可以主动发出事件，而 Observable 是被动的，它通过操作符或者创建函数来发出事件。
• 热与冷: Observable 通常用于表示冷数据流，而 Subject 表示热数据流。

在实际应用中，选择使用 Observable 还是 Subject 取决于你的特定需求，比如是否需要多播、是否需要主动控制事件的发出等。