为什么在集合中添加新文档时删除了在 Firestore 实时侦听器中调用的事件？

Question

我正在尝试实时阅读消息，问题是当人 A 向人 B 发送消息时，人 B 实时侦听器调用了一个已添加的事件，这完全是我明白的，但为什么删除事件也叫什么？

 fun readMessagesRealTimeListener(documentID: String, date: Date, senderUser: ChatUser, reciverUser: ChatUser): LiveData<List<ChatMessage>> {
        if (mutableChatMessageList == null) {
            mutableChatMessageList = MutableLiveData()
            val chatMessageList = ArrayList<ChatMessage>()
            db = FirebaseFirestore.getInstance()
            readMessageListener = db.collection(Constants.CONVERSATION)
                    .document(documentID)
                    .collection("0")
                    .orderBy("data", Query.Direction.DESCENDING)
                    .limit(5)
                    .addSnapshotListener(EventListener<QuerySnapshot> { querySnapshot, e ->
                        if (e != null) {
                            Log.d(TAG, "error in real time listerner: " + e.code);
                        }
                        val source = if (querySnapshot != null && querySnapshot.metadata.hasPendingWrites())
                            "Local"
                        else
                            "Server"
                        Log.d(TAG, "source of $source")
                        chatMessageList.clear()
                        if (!querySnapshot?.isEmpty!!) {
                            for (changedSnapshot in querySnapshot.documentChanges) {
                                when (changedSnapshot.type) {
                                    DocumentChange.Type.ADDED -> Log.d(TAG, "New message: " + changedSnapshot.getDocument().getData())
                                    DocumentChange.Type.MODIFIED -> Log.d(TAG, "Modified message: " + changedSnapshot.getDocument().getData())
                                    DocumentChange.Type.REMOVED -> Log.d(TAG, "Removed message: " + changedSnapshot.getDocument().getData())//this log also called when new document added in firestore but why?
                                }

                                var chatMessage = changedSnapshot.document.toObject(ChatMessage::class.java)

                                Log.d(TAG, "message " + chatMessage.message)
                                chatMessageList.add(chatMessage)

                            }
                            mutableChatMessageList?.value = chatMessageList
                        } else {
                            Log.d(TAG, "no message found in real time")
                            mutableChatMessageList?.setValue(null)
                        }
                    })
        }

        return mutableChatMessageList!!
    }

Answer 1

快速猜测是您的集合中有超过 5 条消息。在这种情况下，此侦听器仅显示最新的 5 条消息：

readMessageListener = db.collection(Constants.CONVERSATION)
        .document(documentID)
        .collection("0")
        .orderBy("data", Query.Direction.DESCENDING)
        .limit(5)

因此，现在当您添加新消息时，该新消息将成为最新消息。并且之前的第一条消息从QuerySnapshot中删除。

最容易看出我们是否能快速拟定消息。假设你从这 5 个开始：

1
2
3
4
5

因此，您的侦听器会被这 5 条消息调用。现在我们添加一条新消息6。此新消息将添加到QuerySnapshot。但这将导致它有 6 条消息，而您只要求 5 条消息。因此，您会得到一个 ADDED 对应 6，以及一个 REMOVED 对应 `1。

1 REMOVED
2
3
4
5
6 ADDED

最终得到：

2
3
4
5
6