Flutter 对接 Firebase 替代链式 StreamBuilder 的状态管理方案咨询

1. 基于现有RxDart改造的链式流方案 #

你当前的技术栈不需要引入额外依赖，直接调整流的组合逻辑即可实现条件拉取：
用switchMap操作符替代combineLatest2，把users_last_active的查询改为依赖users流的输出结果，同时加入条件判断：

Stream<List<Profile>> get profileStream => database.usersStream()
  .switchMap((List<User> users) {
    // 自定义触发次级列表拉取的条件逻辑
    if (!needLoadLastActive) {
      return Stream.value(users.map((u) => Profile.fromUser(u)).toList());
    }
    // 仅拉取当前用户列表对应的lastActive记录，避免全量拉取
    final List<String> targetUserIds = users.map((e) => e.uid).toList();
    return database
        .lastActiveStream(filterUserIds: targetUserIds)
        .map((lastActiveList) => _profileCombiner(users, lastActiveList));
  });

该方案改动成本最低，完全兼容现有BLoC架构，同时从查询层面减少了无效数据拉取。

2. Firestore原生冗余字段方案（推荐） #

这是Firestore官方推荐的跨集合字段同步方案，彻底消除客户端流合并的开销：

• 在users集合中新增冗余的lastActive字段
• 编写Cloud Functions触发器，监听users_last_active集合的写入/更新事件，同步更新对应用户在users集合中的lastActive值
• 客户端直接监听users单集合流即可，不需要做任何客户端侧的数据合并
  该方案的性能最优，唯一需要额外实现的是后端云函数的同步逻辑，适合大部分生产场景。

3. 组件级细粒度监听方案 #

如果你的业务场景是仅需要展示在可视区域内的用户的lastActive字段，可以采用列表项单独监听的方案：

• 列表层仅拉取users集合的基础字段，不处理lastActive相关逻辑
• 每个用户列表项组件挂载时，单独监听对应用户的users_last_active单条文档流，更新组件内的状态
  该方案适合用户列表量级极大、单屏展示用户数少的场景，完全避免了不必要的次级数据拉取。

内容的提问来源于stack exchange，提问作者Be Kind