Flutter GetX结合Firebase流与分页：后续批次无实时更新问题

1. 初始流会覆盖后续加载的帖子：你用viewPost.bindStream(getPosts())绑定了初始7条帖子的流，每次初始批次的帖子有实时更新时，流会发射新的列表，直接替换viewPost的全部内容，导致之前加载的后续批次帖子被清空。
2. 后续批次未做实时更新的正确处理：滚动加载时，你只是一次性将当前快照的帖子添加到列表，但没有监听这些帖子的后续更新，即使订阅了snapshots()，也只是重复添加相同帖子，而非更新列表中已有的条目。
3. 重复触发分页请求：滚动监听中每次触底都会创建新的流订阅，可能导致重复加载相同帖子。

以下是调整后的代码，解决实时更新和分页的问题：

import 'package:get/get.dart';
import 'package:cloud_firestore/cloud_firestore.dart';

class PostController extends GetxController {
  ScrollController scrollController = ScrollController();
  CollectionReference get _posts => FirebaseFirestore.instance.collection(FirebaseConstants.postsCollection);
  
  RxList<PostModel> viewPost = RxList<PostModel>([]);
  // 跟踪已加载的帖子ID，避免重复添加
  final Set<String> _loadedPostIds = {};
  // 标记是否正在加载下一页，防止重复触发
  bool _isLoading = false;

  @override
  void onInit() {
    super.onInit();
    // 加载初始批次并监听实时更新
    _loadPostBatch(null);
    scrollController.addListener(_handleScroll);
  }

  void _loadPostBatch(PostModel? lastPost) async {
    _isLoading = true;
    
    Query query = _posts
        .orderBy('createdAt', descending: true)
        .limit(lastPost == null ? 7 : 2);

    // 使用startAfterDocument替代startAfter，避免相同createdAt导致的分页错误
    if (lastPost != null) {
      final lastDoc = await _posts.doc(lastPost.id).get();
      query = query.startAfterDocument(lastDoc);
    }

    // 监听当前批次的实时更新
    query.snapshots().listen((snapshot) {
      for (var doc in snapshot.docs) {
        final post = PostModel.fromMap(doc.data() as Map<String, dynamic>);
        
        if (_loadedPostIds.contains(post.id)) {
          // 帖子已存在，更新列表中的对应条目
          final index = viewPost.indexWhere((p) => p.id == post.id);
          if (index != -1) {
            viewPost[index] = post;
          }
        } else {
          // 新帖子，添加到列表并记录ID
          viewPost.add(post);
          _loadedPostIds.add(post.id);
        }
      }
      _isLoading = false;
    });
  }

  void _handleScroll() {
    // 仅当未加载且滚动到底时触发下一页
    if (!_isLoading && scrollController.position.pixels >= scrollController.position.maxScrollExtent * 0.95) {
      final lastPost = viewPost.lastOrNull;
      if (lastPost != null) {
        _loadPostBatch(lastPost);
      }
    }
  }

  @override
  void onClose() {
    scrollController.dispose();
    super.onClose();
  }
}

• 避免列表被覆盖：不再使用bindStream替换整个列表，而是手动更新或添加条目，确保后续加载的帖子不会被初始批次的更新清空。
• 全批次实时监听：每个分页批次都通过snapshots()持续监听更新，无论是初始还是后续加载的帖子，都能实时同步修改。
• 去重与更新逻辑：通过帖子ID跟踪已加载内容，更新时直接替换列表中对应的条目，避免重复添加。
• 防重复加载：用_isLoading标记控制分页触发时机，避免多次触底导致的重复订阅和重复加载。

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