如何避免LiveData注册Observer后触发首次回调？

Firebase Realtime Database的ChildEventListener在首次注册监听时，会自动遍历当前节点下的所有子节点，并逐个调用onChildAdded方法，而非仅监听后续新增的节点。这就是你打开Activity时，即便没有新消息，getUpdatedMessage的LiveData仍会触发，重复添加已有消息的原因。

下面提供两种可行的解决思路，你可以根据自己的MessageEntity结构选择：

方法一：通过时间戳过滤新消息 #

假设你的MessageEntity包含timestamp字段（记录消息发送的毫秒时间戳）：

1. 修改ViewModel #

记录首次加载后最新消息的时间戳，用于后续过滤：

class RoomViewModel(private val repository: ChatRepository) : ViewModel() {
    private var lastMessageTimestamp: Long = 0

    fun getAllMessage(roomUid: String): LiveData<MutableList<MessageEntity>> {
        val _messageList = MutableLiveData<MutableList<MessageEntity>>()
        viewModelScope.launch {
            val messages = repository.getAllMessages(roomUid)
            _messageList.postValue(messages)
            // 记录最后一条消息的时间戳，无消息则设为0
            lastMessageTimestamp = messages.maxOfOrNull { it.timestamp } ?: 0
        }
        return _messageList
    }

    // 新增参数，传入时间戳过滤新消息
    fun getUpdatedMessage(roomUid: String) = repository.getUpdatedMessage(roomUid, lastMessageTimestamp).asLiveData()
}

2. 修改DataSourceImpl #

仅监听时间戳大于首次加载最大值的消息：

override fun getUpdatedMessage(chatRoomUid: String, lastTimestamp: Long): Flow<MessageEntity> = callbackFlow {
    val reference = databaseReference.child("chat").child("messageList").child(chatRoomUid)
    // 构建查询：只获取时间戳大于lastTimestamp的消息
    val query = reference.orderByChild("timestamp").startAt(lastTimestamp + 1)

    val subscription = query.addChildEventListener(object : ChildEventListener {
        override fun onChildAdded(snapshot: DataSnapshot, previousChildName: String?) {
            val message = snapshot.getValue(MessageEntity::class.java)!!
            trySend(message)
        }

        // 其他方法保持不变
        override fun onChildChanged(snapshot: DataSnapshot, previousChildName: String?) {}
        override fun onChildRemoved(snapshot: DataSnapshot) {}
        override fun onChildMoved(snapshot: DataSnapshot, previousChildName: String?) {}
        override fun onCancelled(error: DatabaseError) {}
    })

    awaitClose { reference.removeEventListener(subscription) }
}

3. 修改Activity #

等待所有历史消息加载完成后，再注册新消息监听：

viewModel.getAllMessage(room!!.chatRoomUid).observe(this, Observer { messages ->
    adapter.changeMessages(messages)
    adapter.notifyDataSetChanged()
    // 历史消息加载完成后，再监听新消息
    viewModel.getUpdatedMessage(room!!.chatRoomUid).observe(this, Observer { newMessage ->
        adapter.updateMessage(newMessage)
        adapter.notifyDataSetChanged()
    })
})

方法二：通过节点Key过滤新消息 #

如果你的消息节点使用Firebase自动生成的Key（push()方法生成），可以通过Key来过滤：

1. 修改ViewModel #

记录首次加载后最后一条消息的Key：

class RoomViewModel(private val repository: ChatRepository) : ViewModel() {
    private var lastMessageKey: String? = null

    fun getAllMessage(roomUid: String): LiveData<MutableList<MessageEntity>> {
        val _messageList = MutableLiveData<MutableList<MessageEntity>>()
        viewModelScope.launch {
            val messages = repository.getAllMessages(roomUid)
            _messageList.postValue(messages)
            // 记录最后一条消息的Key（需确保MessageEntity有key字段存储节点Key）
            lastMessageKey = messages.lastOrNull()?.key
        }
        return _messageList
    }

    // 新增参数，传入Key过滤新消息
    fun getUpdatedMessage(roomUid: String) = repository.getUpdatedMessage(roomUid, lastMessageKey).asLiveData()
}

2. 修改DataSourceImpl #

仅监听Key大于最后一条历史消息Key的新消息：

override fun getUpdatedMessage(chatRoomUid: String, lastKey: String?): Flow<MessageEntity> = callbackFlow {
    val reference = databaseReference.child("chat").child("messageList").child(chatRoomUid)
    val query = lastKey?.let {
        // 只获取Key大于lastKey的消息
        reference.orderByKey().startAt(it)
    } ?: reference

    val subscription = query.addChildEventListener(object : ChildEventListener {
        override fun onChildAdded(snapshot: DataSnapshot, previousChildName: String?) {
            // 排除已加载的最后一条消息（startAt会包含lastKey本身）
            if (snapshot.key != lastKey) {
                val message = snapshot.getValue(MessageEntity::class.java)!!
                message.key = snapshot.key // 将节点Key存入实体
                trySend(message)
            }
        }

        // 其他方法保持不变
        override fun onChildChanged(snapshot: DataSnapshot, previousChildName: String?) {}
        override fun onChildRemoved(snapshot: DataSnapshot) {}
        override fun onChildMoved(snapshot: DataSnapshot, previousChildName: String?) {}
        override fun onCancelled(error: DatabaseError) {}
    })

    awaitClose { reference.removeEventListener(subscription) }
}

3. 修改Activity #

同样等待历史消息加载完成后再监听新消息：

viewModel.getAllMessage(room!!.chatRoomUid).observe(this, Observer { messages ->
    adapter.changeMessages(messages)
    adapter.notifyDataSetChanged()
    viewModel.getUpdatedMessage(room!!.chatRoomUid).observe(this, Observer { newMessage ->
        adapter.updateMessage(newMessage)
        adapter.notifyDataSetChanged()
    })
})

• 避免在getAllMessage中每次调用都创建新的MutableLiveData，可将其改为ViewModel的成员变量，确保数据只加载一次。
• 可以考虑将历史消息加载和新消息监听合并为一个Flow，先发射所有历史消息，再持续发射新增消息，简化监听逻辑。

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