Firestore过滤主集合后获取子集合数据在StreamBuilder中报错求助

问题场景 #

需求为：当ChatRoom集合的users字段包含当前用户名（Constant.myname）时，访问其chats子集合，并在列表中展示每个ChatRoom的最新一条消息。尝试通过外层StreamBuilder监听带where(arrayContains)条件的ChatRoom流，内层嵌套StreamBuilder获取对应ChatRoom的最新消息，但运行报错。

原尝试代码 #

Stream<QuerySnapshot> _usersStream = FirebaseFirestore.instance
    .collection("ChatRoom")
    .where("users", arrayContains: Constant.myname)
    .snapshots();

@override
Widget ChatMessageList() {
  return StreamBuilder(
    // stream: chatMessageStream,
    stream: _usersStream,
    builder: (context, AsyncSnapshot<QuerySnapshot> snapshot) {
      if (snapshot.data == null) {
        return Center(
            child: CircularProgressIndicator(
          color: Colors.orange.shade600,
        ));
      } else {
        return Container(
          padding: EdgeInsets.only(top: 15),
          height: MediaQuery.of(context).size.height / 1.2,
          child: ListView.builder(
              itemCount: snapshot.data!.docs.length,
              itemBuilder: (ctx, index) {
                QuerySnapshot<Object?>? snap = snapshot.data; // Snapshot
                List<DocumentSnapshot> items =
                    snap!.docs; // List of Documents
                DocumentSnapshot item = items[index];
                String v = item['chatroomid'];
                return SingleChildScrollView(
                  child: StreamBuilder(
                      stream: FirebaseFirestore.instance
                          .collection("ChatRoom/$v/chats")
                          .orderBy("time", descending: true)
                          .limit(1)
                          .snapshots(),
                      builder: (context, snapshot2) {
                        if (snapshot2.hasData) {
                          QuerySnapshot<Object?>? snap2 =
                              snapshot2.data; // Snapshot
                          List<DocumentSnapshot?>? items2 =
                              snap2?.docs; // List of Documents
                          DocumentSnapshot? item2 = items2?[0];
                          print(item2?['message']);
                          return MessageTile(
                            username: item['chatroomid']
                                .toString()
                                .replaceAll("_", "")
                                .replaceAll(Constant.myname, ""),
                            chatroomid: item['chatroomid'],
                          );
                        } else {
                          return CircularProgressIndicator();
                        }
                      }),
                );
              }),
        );
      }
    });
}

错误原因分析 #

1. 状态判断不完整：仅判断snapshot.data == null，未处理snapshot.hasError和snapshot.connectionState的其他状态（如waiting），易引发异常。
2. 子Stream重复创建：ListView item重建时会重复创建内层Firestore流，造成资源浪费和不必要的状态异常。
3. 空数据未处理：当chats子集合为空时，items2?[0]返回null，直接访问item2?['message']可能触发空指针问题，且MessageTile未处理空消息场景。
4. 冗余滚动组件：外层已是ListView，内层嵌套SingleChildScrollView会导致滚动冲突，无实际必要。

修复后的代码 #

Stream<QuerySnapshot> _usersStream = FirebaseFirestore.instance
    .collection("ChatRoom")
    .where("users", arrayContains: Constant.myname)
    .snapshots();

@override
Widget ChatMessageList() {
  return StreamBuilder<QuerySnapshot>(
    stream: _usersStream,
    builder: (context, AsyncSnapshot<QuerySnapshot> snapshot) {
      // 处理加载状态
      if (snapshot.connectionState == ConnectionState.waiting) {
        return Center(
          child: CircularProgressIndicator(color: Colors.orange.shade600),
        );
      }

      // 处理错误状态
      if (snapshot.hasError) {
        return Center(child: Text("加载失败: ${snapshot.error}"));
      }

      // 处理无数据状态
      if (!snapshot.hasData || snapshot.data!.docs.isEmpty) {
        return Center(child: Text("暂无聊天记录"));
      }

      return Container(
        padding: const EdgeInsets.only(top: 15),
        height: MediaQuery.of(context).size.height / 1.2,
        child: ListView.builder(
          itemCount: snapshot.data!.docs.length,
          itemBuilder: (ctx, index) {
            final chatRoomDoc = snapshot.data!.docs[index];
            final chatRoomId = chatRoomDoc['chatroomid'] as String;

            return _buildChatRoomLatestMessage(chatRoomDoc, chatRoomId);
          },
        ),
      );
    },
  );
}

Widget _buildChatRoomLatestMessage(DocumentSnapshot chatRoomDoc, String chatRoomId) {
  final latestChatStream = FirebaseFirestore.instance
      .collection("ChatRoom/$chatRoomId/chats")
      .orderBy("time", descending: true)
      .limit(1)
      .snapshots();

  return StreamBuilder<QuerySnapshot>(
    stream: latestChatStream,
    builder: (context, AsyncSnapshot<QuerySnapshot> snapshot) {
      if (snapshot.connectionState == ConnectionState.waiting) {
        return const ListTile(
          leading: CircularProgressIndicator(size: 20),
          title: Text("加载中..."),
        );
      }

      if (snapshot.hasError) {
        return ListTile(title: Text("加载消息失败"));
      }

      String latestMessage = "";
      if (snapshot.hasData && snapshot.data!.docs.isNotEmpty) {
        final latestDoc = snapshot.data!.docs.first;
        latestMessage = latestDoc['message'] as String? ?? "无消息";
      } else {
        latestMessage = "暂无消息";
      }

      final chatRoomIdStr = chatRoomDoc['chatroomid'] as String;
      final otherUsername = chatRoomIdStr
          .replaceAll("_", "")
          .replaceAll(Constant.myname, "");

      return MessageTile(
        username: otherUsername,
        chatroomid: chatRoomId,
        latestMessage: latestMessage, // 假设MessageTile支持传入最新消息字段
      );
    },
  );
}

关键优化点 #

• 完善状态处理：覆盖waiting、error、empty等所有状态，避免异常触发。
• 拆分代码结构：将内层StreamBuilder封装为独立方法，提升可读性与可维护性。
• 空数据安全处理：判断chats子集合是否为空，避免空指针访问。
• 移除冗余组件：删除内层SingleChildScrollView，解决滚动冲突问题。
• 类型安全优化：明确指定StreamBuilder泛型，消除类型转换警告。

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