Firestore Streams 订阅

Question

我目前正在用颤振设计一个聊天应用程序，为此我正在使用 Firestore。我想知道这些流是如何工作的，因为我想知道读取次数，以便我可以预测限制。假设当前有 315 条消息，并且所有消息都在当前聊天屏幕中。如果一个人输入一条新消息，它将是第 316 条消息，因此 Flutter Stream 会读取所有 316 条消息，或者只是获取新添加的消息并将其附加到 315 成员列表中。

我看到很多视频阅读博客，他们只是错过了这一点。我想清楚地理解这一点。

return StreamBuilder<QuerySnapshot>(
      stream: _firestoreDatabase.collection(id).orderBy('time').snapshots(),
      builder: (context, snapshot) {
        if (!snapshot.hasData) {
          return Column(
            mainAxisAlignment: MainAxisAlignment.center,
            children: <Widget>[
              Center(
                child: CircularProgressIndicator(
                  backgroundColor: Colors.lightBlueAccent,
                ),
              ),
            ],
          );
        } else {
          final messages = snapshot.data.documents.reversed;
          List<MessageBubble> messageBubbles = [];
          for (var message in messages) {
            final messageText = message.data['amount'];
            final messageSender = message.data['team'];
            final timeDisp = message.data['timedisp'];
            final currentUser = teamName;

            bool isManager;
            if (messageSender.toString() == 'Manager') {
              isManager = true;
            } else {
              isManager = false;
            }

            final messageBubble = MessageBubble(
              sender: messageSender,
              text: messageText.toString(),
              isMe: currentUser == messageSender,
              timeDisp: timeDisp,
              isManager: isManager,
            );
            messageBubbles.add(messageBubble);
          }

    return Expanded(
            child: ListView(
              reverse: true,
              padding: EdgeInsets.symmetric(vertical: 10, horizontal: 10),
              children: messageBubbles,
            ),
          );
        }
      },
    );

Answer 1

您从 Firestore 流中获取文档的方式取决于您在可能是 StreamBuilder 小部件上执行的查询。

如果您愿意，您可以让聊天的新成员获取当前聊天数据库中可用的所有 Firestore 文档，或者通过添加时间戳参数然后查询快照来获取最新的文档，例如这个：

Firebase.instance().collection("Chats").where("sentTimestamp",isGreaterThanOrEqualTo: new DateTime.now())

您可以通过以下问题了解有关按日期获取和比较的更多信息： How to fetch records by comparing with date in flutter cloud firestore plugin?

Answer 2

当您从它的流中执行查询时，它最初会读取所有匹配的文档。只要流处于活动状态，文档就会缓存在内存中。如果新文档与查询匹配，则只会读取新文档，而其他所有内容都将从内存中重用。它不会再次读取所有以前缓存的文档。