在前端开发中，数据共享是一个非常重要且必备的特性。RxJS 中的 BehaviorSubject 提供了一种简单、可靠的方式来实现数据共享。本文将介绍RxJS 的 BehaviorSubject，它的基本概念、使用方法以及示例代码。
基本概念
BehaviorSubject 是 RxJS 中的一个特殊类型，是 Subject 的一种，它能够记忆并发射最后一个值。也就是说，当有新的订阅时，BehaviorSubject 会将最新的值传递给它们。
在 BehaviorSubject 中，订阅者会立即获取到上一次发射的值。这意味着，如果有订阅者订阅了BehaviorSubject 并且它们在之前的订阅结束之后进行了新的订阅，那么这些订阅者将会立即获得最后一次发射的值。
使用方法
我们可以通过创建 BehaviorSubject 实例来实现数据共享。在创建实例时，需要传入一个初始值。BehaviorSubject 会将这个初始值存储起来，并始终记住最后一次传递的值。
// www.javascriptcn.com code example
import { BehaviorSubject } from "rxjs";
// 创建实例
const behaviorSubject = new BehaviorSubject<string>("initial value");
behaviorSubject.subscribe((value) => {
console.log(value);
});
// 发射新值
behaviorSubject.next("Hello!");
// 输出的结果为：
// initial value
// Hello!我们可以使用 next 方法来发射新值。在上面的示例中，订阅者会在订阅时立即获取初始值，然后在调用 next 方法后获取新的值。
我们还可以手动订阅和取消订阅。需要注意的是，在取消订阅时，订阅者将不再收到值：
// www.javascriptcn.com code example
const subscription = behaviorSubject.subscribe((value) => {
console.log(value);
});
// 发射新值
behaviorSubject.next("Hello!");
// 取消订阅
subscription.unsubscribe();
// 发射新值
behaviorSubject.next("World!"); // 订阅者不会收到此值如果我们希望 BehaviorSubject 只共享一个值，我们可以使用 refCount 方法来实现：
// www.javascriptcn.com code example
import { BehaviorSubject } from "rxjs";
// 创建实例
const behaviorSubject = new BehaviorSubject<string>("initial value").refCount();
behaviorSubject.subscribe((value) => {
console.log("Subscriber 1:", value);
});
behaviorSubject.subscribe((value) => {
console.log("Subscriber 2:", value);
});
// 发射新值
behaviorSubject.next("Hello!");
// 输出的结果为：
// Subscriber 1: initial value
// Subscriber 2: initial value
// Subscriber 1: Hello!
// Subscriber 2: Hello!在这个示例中，我们创建了两个订阅者，并使用 refCount 方法将 BehaviorSubject 转换为 ConnectableObservable 类型。这意味着在第一个订阅者订阅时，BehaviorSubject 开始发射值。当所有订阅者取消订阅时，发射将自动停止。
应用
BehaviorSubject 可以用于许多场景，例如用它来实现状态管理。在这个示例中，我们将创建一个状态数据，并使用 BehaviorSubject 来更新状态：
// www.javascriptcn.com code example
import { BehaviorSubject } from "rxjs";
class Store {
private readonly _state = new BehaviorSubject<number>(0);
state$ = this._state.asObservable();
increment() {
const current = this._state.value;
this._state.next(current + 1);
}
reset() {
this._state.next(0);
}
}
const store = new Store();
store.state$.subscribe((state) => {
console.log(state);
});
store.increment(); // 输出 1
store.increment(); // 输出 2
store.reset(); // 输出 0在这个示例中，我们使用 BehaviorSubject 存储状态，并在 increment 和 reset 方法中更新状态。我们还将 state$ 属性作为只读属性暴露给外部消费者，以便他们可以订阅和获取状态。
总结
BehaviorSubject 利用了 RxJS 的许多特性，如多订阅和数据共享，是一种非常便捷和可靠的方式来实现数据共享和状态管理。通过手动订阅和取消订阅，我们可以更好地控制订阅者，避免内存泄漏等问题。
Source: FunTeaLearn,Please indicate the source for reprints https://funteas.com/post/652d57497d4982a6ebeb3d74