Flutter中如何减少Firestore读取：优先读缓存无数据再读服务器

核心逻辑 #

• 对get()方法显式传入GetOptions(source: Source.cache)优先读取本地缓存
• 捕获缓存读取失败的异常、或判断缓存无有效数据时，再降级发起服务器请求GetOptions(source: Source.server)
• 优化原有异步遍历逻辑，避免异步回调混乱、UI频繁重绘

封装优先读缓存的文档获取方法 #

先封装通用的文档读取方法，统一处理缓存优先的降级逻辑：

Future<DocumentSnapshot?> getLikedUserDoc(String likedId) async {
  try {
    // 第一步：优先读取本地缓存
    final cacheDoc = await FirebaseFirestore.instance
        .collection('Users')
        .doc(likedId)
        .get(const GetOptions(source: Source.cache));
    if (cacheDoc.exists) return cacheDoc;
    
    // 缓存无数据，第二步：读取服务器数据
    final serverDoc = await FirebaseFirestore.instance
        .collection('Users')
        .doc(likedId)
        .get(const GetOptions(source: Source.server));
    return serverDoc.exists ? serverDoc : null;
  } catch (e) {
    // 缓存读取失败（如无缓存记录、缓存损坏），降级走服务器请求
    try {
      final serverDoc = await FirebaseFirestore.instance
          .collection('Users')
          .doc(likedId)
          .get(const GetOptions(source: Source.server));
      return serverDoc.exists ? serverDoc : null;
    } catch (serverErr) {
      // 服务器也读取失败可按需做错误提示，此处直接返回空
      return null;
    }
  }
}

改造后的_getLikes方法 #

// 定义为类变量，页面销毁时需要取消监听避免内存泄漏
StreamSubscription? _likesSubscription;

_getLikes() {
  User? _user = _firebaseAuth.currentUser;
  if (_user == null) return; // 用户未登录直接返回避免空异常

  // 先取消之前的监听避免重复订阅
  _likesSubscription?.cancel();
  _likesSubscription = FirebaseFirestore.instance
      .collection('Users')
      .doc(_user.uid)
      .collection("Likes")
      .where('liked', isEqualTo: true)
      .snapshots()
      .listen((_querySnapshot) async {
    liked.clear(); // 每次数据更新先清空原有列表避免数据重复
    if (_querySnapshot.docs.isNotEmpty) {
      // 改用for in循环等待所有异步操作完成，避免频繁触发setState
      for (var _likedDocumentSnapshot in _querySnapshot.docs) {
        final likedId = _likedDocumentSnapshot.data()['likedId'];
        if (likedId == null) continue;
        final _usersDocumentSnapshot = await getLikedUserDoc(likedId);
        if (_usersDocumentSnapshot != null && _usersDocumentSnapshot.exists) {
          User _tempUser = User.fromDocument(_usersDocumentSnapshot);
          liked.add(_tempUser);
        }
      }
      // 所有数据处理完成后统一刷新UI
      if (mounted) setState(() {});
    } else {
      // 点赞列表为空时也同步刷新UI
      if (mounted) setState(() {});
    }
  });
}

// 页面销毁时取消监听
@override
void dispose() {
  _likesSubscription?.cancel();
  super.dispose();
}

注意事项 #

• Firestore默认开启离线持久化，如果你手动关闭过该配置，需要先开启才能正常读取缓存：初始化Firestore时设置persistenceEnabled: true即可
• 缓存的数据仅包含之前成功从服务器拉取过的数据，如果是首次打开应用无任何历史缓存，会直接走服务器请求逻辑
• 如果需要对snapshots()返回的监听流也做缓存优先配置，可以传入参数：snapshots(getOptions: const GetOptions(source: Source.cacheAndServer))，会优先返回缓存数据，再同步服务器最新数据自动更新UI

内容的提问来源于stack exchange，提问作者Вадим