Flutter结合Firestore如何嵌套调用Stream拉取已关注用户的发布帖子

Firestore结构示意图 #

实现方案 #

你需要通过流转换将「关注列表查询流」和「帖子查询流」合并为一个流，不需要嵌套多层StreamBuilder，具体实现步骤如下：

前提准备

1. 首先在pubspec.yaml中添加rxdart依赖，用于流转换操作
2. 确保每个posts文档中都存储了发布者的userId字段，作为过滤条件
3. 在Firebase控制台为posts集合创建集合组查询索引，按Post Date字段降序排序（运行时如果触发索引缺失报错，控制台会直接给出索引创建链接，点击等待创建完成即可）

核心逻辑代码

import 'package:rxdart/rxdart.dart';

// 构造组合流：先拉取关注列表，再查询对应关注人的帖子
Stream<List<Post>> getFollowingPosts(String currentUserId) {
  return FirebaseFirestore.instance
      .collection("users")
      .doc(currentUserId)
      .collection("followings")
      .snapshots()
      .switchMap((followingsSnapshot) {
    // 提取所有已关注用户的ID
    List<String> followingIds = followingsSnapshot.docs.map((doc) => doc.id).toList();
    if (followingIds.isEmpty) {
      // 未关注任何人时直接返回空列表
      return Stream.value([]);
    }
    // 集合组查询所有关注用户的posts
    return FirebaseFirestore.instance
        .collectionGroup("posts")
        .where("userId", whereIn: followingIds)
        .orderBy('Post Date', descending: true)
        .snapshots()
        .map((postsSnapshot) => postsSnapshot.docs
            .map((doc) => Post.fromDocument(doc, postsSnapshot.docs.length))
            .toList());
  });
}

UI层替换代码

将你原来的StreamBuilder替换为调用上述组合流的实现即可：

Container(
  height: 225.0,
  child: StreamBuilder<List<Post>>(
    stream: getFollowingPosts(currentUserId), // 传入当前登录用户的ID
    builder: (context, snapshot) {
      if (!snapshot.hasData) {
        return ShimmerPlaceHolder().homePosts(true);
      }
      final posts = snapshot.data!;
      if (posts.isEmpty) {
        return Container(
          height: 100.0,
          width: 200.0,
          child: Column(
            children: [
              SizedBox(height: 30.0),
              Text(
                "还没有关注的人发布动态哦",
                style: TextStyle(
                    fontSize: AppTheme.AppLightTheme.fontLarge,
                    fontFamily: 'AirbnbCereal'),
              ),
              Image.asset(
                'assets/images/home_picture.png',
                height: 100.0,
                width: 100.0,
              ),
            ],
          ),
        );
      }
      return Container(
        margin: EdgeInsets.symmetric(vertical: 20.0),
        height: 200,
        child: ListView.builder(
          scrollDirection: Axis.horizontal,
          itemCount: posts.length,
          itemBuilder: (BuildContext context, int index) {
            Post postModel = posts[index];
            return Container(
              width: MediaQuery.of(context).size.width * 0.35,
              child: Card(
                color: AppTheme.AppLightTheme.unSelectColor,
                // 保留你原来的卡片渲染逻辑
              ),
            );
          },
        ),
      );
    },
  ),
)

注意事项 #

• Firestore的whereIn查询最多支持10个匹配条件，如果你的关注人数超过10人，需要将关注ID拆分为每组最多10个的子列表，分别发起查询后合并结果
• 该实现是实时同步的，关注列表更新或者关注用户发布新帖子时，UI会自动刷新

内容的提问来源于stack exchange，提问作者P A T Himaranga