Angular 如何实现定时轮询调用API自动更新ShopManagerService的shopPreferences数据

实现ShopManagerService作为根单例服务，自动按2分钟间隔拉取最新店铺偏好配置，同步更新内部shopPreferences字段，完全兼容原有业务的读取逻辑，不需要组件手动触发拉取动作。

• 把ApiManagerService作为依赖注入到ShopManagerService中，彻底移除对组件主动调用setPreferences方法的依赖
• 用RxJS内置的定时流实现自动刷新，替代原生setInterval，解决请求重叠、订阅泄漏的常见问题
• 保留类里所有原有方法的实现逻辑，现有业务代码不需要做任何修改就能适配新的自动刷新能力

import { Injectable } from '@angular/core';
import { timer, switchMap } from 'rxjs';

@Injectable({ providedIn: 'root' })
export class ShopManagerService {
  // 原有私有字段保留不变
  private shopPreferences: ShopPreferences = null;
  // 固定店铺ID，可根据实际场景从本地存储、路由参数读取
  private readonly SHOP_ID = '替换为实际的店铺ID值';
  // 2分钟刷新间隔，单位毫秒
  private readonly REFRESH_INTERVAL = 120 * 1000;

  constructor(private apiManager: ApiManagerService) {
    // 服务实例初始化时自动启动定时刷新流程
    this.initAutoRefreshFlow();
  }

  // 原有set方法保留，兼容现有代码调用
  setPreferences(shopPreferences: ShopPreferences) {
    this.shopPreferences = shopPreferences;
  }

  // 原有业务getter方法完全不变，适配所有现有调用逻辑
  isDeliverySlotsActive(){
    if(this.shopPreferences == null || this.shopPreferences.delivery_slots == null) return;
    return this.shopPreferences.delivery_slots;
  }

  getCurrencySymbol(){
    if(this.shopPreferences == null || this.shopPreferences.currency_display_symbol == null) return;
    return this.shopPreferences.currency_display_symbol;
  }

  // 自动刷新核心逻辑
  private initAutoRefreshFlow() {
    // timer第一个参数为0表示实例初始化后立即发起第一次请求
    timer(0, this.REFRESH_INTERVAL)
      .pipe(
        // switchMap保证同一时间只有一个进行中的API请求，自动取消超时未返回的旧请求
        switchMap(() => this.apiManager.fetchShopPreferences(this.SHOP_ID))
      )
      .subscribe({
        next: (newPreferences) => {
          // 拉取成功后直接更新内部字段，所有原有读取逻辑自动拿到最新值
          this.setPreferences(newPreferences);
        },
        error: (err) => {
          // 拉取失败仅打印告警日志，不中断后续定时重试
          console.warn('店铺偏好配置拉取异常，将按间隔自动重试', err);
        }
      })
  }
}

注：原有ApiManagerService的逻辑不需要做任何修改，保留原实现即可正常对接上面的刷新流程。

• 无侵入接入：因为两个服务都是根作用域单例，只要应用里任意位置第一次注入ShopManagerService，自动刷新流程就会启动，不需要在根组件单独写初始化逻辑
• 无请求堆积：相比原生setInterval固定间隔强制触发请求的逻辑，switchMap会在每次发起新请求前自动取消上一次还未返回的请求，避免网络延迟时多个并发请求给服务端造成额外压力
• 容错性强：单次请求失败不会终止定时器，下一个间隔节点会自动重试拉取，保证数据最终能和服务端保持同步

内容的提问来源于stack exchange，提问作者Manuel Brás