Android聊天应用开发：Firestore addSnapshotListener返回全量数据、去重崩溃问题排查

现存问题根因 #

• 对快照返回机制的误解：Firestore实时监听器第一次触发时，会将当前查询匹配的所有文档统一标记为ADDED类型返回，并非从0开始的增量变更。没有对首次触发做过滤处理，就会出现拿到全量文档、重复插入列表的问题。
• 排序逻辑前后不一致：分页加载时消息按time字段降序排列（最新消息在列表头部），但实时监听器单独设置为按time升序查询，两套排序规则冲突，很容易导致消息顺序错乱、插入位置错误。
• 异常场景保护缺失：从文档中读取name/message/userId等字段时直接调用toString()，只要某条文档存在字段缺失，就会直接触发空指针崩溃；同时没有做messageId的存在性去重，首次全量触发时会把已加载的历史消息重复插入列表，进一步引发列表越界、adapter刷新异常。
• 监听器初始化路径缺陷：原代码仅在第一页拉取消息数达到10条时才初始化实时监听器，历史消息不足10条的小会话会完全失去实时同步能力。

修复方案 #

1. 统一全局排序规则 #

不管是分页查询还是实时监听，全程保持按time字段降序排列，和“新消息插入列表头部”的布局需求匹配，不要中途切换排序方向。

2. 增加首次快照过滤标记 #

给监听器加布尔类型的首次触发标记，第一次拿到全量快照时直接跳过文档变更处理（这部分内容已经通过分页加载到列表中），从第二次触发开始才处理真正的增量变更。

3. 补全异常防护与变更分支处理 #

• 读取文档字段时先做非空判断，避免空指针崩溃
• 增加messageId去重逻辑，避免重复插入相同消息
• 按DocumentChange的类型分别处理：
  • ADDED：校验ID不重复后插入到列表对应位置
  • MODIFIED：替换列表中同ID的原有消息
  • REMOVED：从列表中移除同ID的消息

参考修复后的实时监听代码 #

// 类成员变量，标记是否是监听器首次触发
private boolean isFirstSnapshot = true;
// 用来记录当前列表中所有消息ID，做快速去重
private Set<String> existMessageIds = new HashSet<>();

private void addOnChangeListener(String id, String myId) {
    db.collection("ChatUsers")
            .document(myId)
            .collection(id)
            .orderBy("time", Query.Direction.DESCENDING) // 和分页逻辑保持一致的降序
            .addSnapshotListener(new EventListener<QuerySnapshot>() {
                @Override
                public void onEvent(@Nullable QuerySnapshot value, @Nullable FirebaseFirestoreException error) {
                    if (error != null || value == null) return;
                    
                    // 首次触发直接跳过，因为全量内容已经通过分页加载完成
                    if (isFirstSnapshot) {
                        isFirstSnapshot = false;
                        // 把已加载的消息ID存入去重集合
                        for (MessageItem item : messageItems) {
                            existMessageIds.add(item.getMessageId());
                        }
                        return;
                    }

                    // 处理后续增量变更
                    for (DocumentChange dc : value.getDocumentChanges()) {
                        DocumentSnapshot doc = dc.getDocument();
                        String messageId = doc.getId();
                        // 去重判断
                        if (existMessageIds.contains(messageId)) {
                            // 已存在的消息如果是修改类型，更新对应位置
                            if (dc.getType() == DocumentChange.Type.MODIFIED) {
                                int existIndex = -1;
                                for (int i = 0; i < messageItems.size(); i++) {
                                    if (messageItems.get(i).getMessageId().equals(messageId)) {
                                        existIndex = i;
                                        break;
                                    }
                                }
                                if (existIndex != -1) {
                                    String name = doc.getString("name");
                                    String message = doc.getString("message");
                                    String userId = doc.getString("userId");
                                    Long time = doc.getLong("time");
                                    if (name != null && message != null && userId != null && time != null) {
                                        messageItems.set(existIndex, new MessageItem(message, messageId, name, userId, time));
                                        adapter.notifyItemChanged(existIndex);
                                    }
                                }
                            }
                            continue;
                        }

                        // 新增类型的消息才插入
                        if (dc.getType() == DocumentChange.Type.ADDED) {
                            // 空值校验
                            String name = doc.getString("name");
                            String message = doc.getString("message");
                            String userId = doc.getString("userId");
                            Long time = doc.getLong("time");
                            if (name == null || message == null || userId == null || time == null) continue;
                            
                            MessageItem newItem = new MessageItem(message, messageId, name, userId, time);
                            // 按降序逻辑，新消息插入列表头部
                            messageItems.add(0, newItem);
                            existMessageIds.add(messageId);
                            adapter.notifyItemInserted(0);
                        }

                        // 处理删除类型的消息
                        if (dc.getType() == DocumentChange.Type.REMOVED) {
                            int existIndex = -1;
                            for (int i = 0; i < messageItems.size(); i++) {
                                if (messageItems.get(i).getMessageId().equals(messageId)) {
                                    existIndex = i;
                                    break;
                                }
                            }
                            if (existIndex != -1) {
                                messageItems.remove(existIndex);
                                existMessageIds.remove(messageId);
                                adapter.notifyItemRemoved(existIndex);
                            }
                        }
                    }
                }
            });
}

注意：实时监听器的初始化逻辑不能放在分页的单分支判断里，要在页面创建、分页加载流程完成后（不管第一页是否满10条）都执行初始化，避免小会话收不到实时消息。

内容的提问来源于stack exchange，提问作者Mohamed El Fwakhry