怎样在 Angular 服务中较高效缓存 Observable 最终还是结果是？

求锤得锤。 Angular 应用中，服务通常负责处理数据获取和业务逻辑。当更多个不同组件或视图需要同一个数据源时 如果各个申请都独立调用，不仅会提升网络申请次数，还会违背“单一数据源”原则。为了优化性能和代码结构，需要考虑怎样在 Angular 服务中缓存 Observable 最终还是结果是。本文将介绍一种基于 RxJS 的方案， 利用 BehaviorSubject 触发申请、shareReplay 实现单次 HTTP 申请最终还是结果是的更多订阅共享，从而较高效地复用 Observable 数据流。

1. 哪些是 Observable 和 RxJS?

在较深入探讨缓存机制之前， 先简洁了解一下 Observable 和 RxJS 的概念：

• Observable: RxJS 中的核心概念，类似于一个异步事件发射器。它会发出一系列的数据，订阅者能够接收这一些数据并进行处理。
• RxJS : 一组用于处理异步数据流的工具库。它提供给了丰富有的操作符来组合、过滤、转换等 Observable 数据流。

探探路。 Angular 6 启动引入 RxJS 6，提供给了对 Observable 的支持。在采用 RxJS 时需要导入必不可更少的模块 和操作符 。

2. 问题解析：为何需要缓存 Observable 最终还是结果是？

当调用一个 Angular 服务中的 Observable 后采用其数据时 如果直接订阅它而不是进行缓存处理，有可能会遇到以下问题：，摸个底。

• 反复申请: 如果更多个不同组件或视图都需要访问同一个数据源的最崭新数据，每次都发起崭新的 HTTP 申请会引起资源条件浪费和性能持续下降。
• 状态不一致: 如果更多个不同组件共享同一个 Observable 的订阅对象， 而其中一个组件修改了状态，其他组件有可能无法及时感知到这一些改变。
• 生命周期问题: Angular 组件的生命周期阶段有可能会引起未取消订阅的 Observable 对象一直存在内存占用或潜在错误风险因素。

3. 基于 BehaviorSubject 的缓存方案

这种方案的核心思想是利用 Behavior 我晕... Subject 作为一种中间容器和触发器：

1. BehaviorSubject: BehaviorSubject 是 Subject 的一个变体，它会保存当前的状态值并将其传递给全部订阅者。这使得当状态发生改变时全部订阅者都能立刻收到通知。
2. *Trigger *: 采用 BehaviorSubject 来控制什么时候发起崭新的 HTTP 申请。当有组件需要更崭新数据时该组件会通知 BehaviorSubject 更崭新其状态值。
3. Data$: 创建一个崭新的 Observable ，它是从 BehaviorSubject 中派生出来的, 它用于向全部 subscribers 发送最崭新的 data 值 。
4. ShareReplay : 采用 shareReplay 方法能够将当前这个 observable 进行复用, 当有更多个不同 subscriber 同时也申请的时候, shareReplay 会自动管理 observable 的生命周期, 只落实一次 request 并将最终还是结果是分发给全部 subscriber 。

typescript import { Injectable } from '@angular/core'; import { HttpClient } f 在理。 rom '@angular/common/http'; import { BehaviorSubject, Observable } from 'rxjs';

interface Data { id: number; 反正吧… name: string; status: string; }

出道即巅峰。 @Injectable // 将服务注入到根级别以便于全局访问 export class DataService {

// 创建 BehaviorSubject 作为可留意对象的状态容器和触发器
private readonly trigger$ = new BehaviorSubject; // 初始化为空对象 
// public data$: Observable 定义可留意的数据源输出端接口 ；这里采用 interface Data 定义期望的数据结构；提议后续和 URL - 在发送申请前验证用户输入以避免可靠漏洞 - 在服务端进行必不可更少的可靠检查以保障服务器免受袭击 - 对客户端返回的数据进行适当的验证以确保数据的完整性和准确性 - 管理:
采用 trigger$ 管理参数改变情况.
错误处理:
添加 try-catch 处理 HttpClient 有可能出现的异常.
常见问题
怎样取消 Subscription:
虽然这里没有直接取消 subscription 对象的操作,
但由于采用了 shareReplay, observable 只会被落实一次.
因此也不需要手动 unsubscribe.

方向
更多租户支持:
如果应用支持更多租户,
能够在 trigger$ 中添加 tenantId 参数.
持久化cache:
能够采用 localStorage 或 sessionStorage 持久化 cached 数据.
但是要注意线程可靠问题.
或者结合专门的 cache service 实现持久化存储.
关于作者
张三 Web 技术手段炎热爱良好者