Android中FirebaseFirestore SnapshotListener无法获取最新数据问题

1. 数据集合未清空：每次SnapshotListener回调时，未清空routesProposalsIds、routesIds等存储数据的列表，旧数据持续累加，导致界面始终显示历史内容。
2. 缓存优先的监听逻辑：Firestore默认优先返回缓存数据，手动删除控制台文档后，本地缓存未及时同步，监听器仍读取旧缓存数据。
3. 嵌套查询的异步隐患：循环中嵌套get()请求获取Route数据，数据更新顺序不可控，且未处理Route文档已被删除的场景。

1. 每次回调前清空数据集合 #

处理新快照数据前，先清空所有存储列表，确保界面仅展示最新数据：

db.collection("RoutesProposals").whereEqualTo("idGuide", currentFirebaseUser.getUid())
    .addSnapshotListener((value, error) -> {
        if(error != null) {
            Log.w("error", "Listen failed.", error);
            return;
        }
        // 清空所有数据列表，避免旧数据残留
        routesProposalsIds.clear();
        routesIds.clear();
        datesOfRoutes.clear();
        routesNames.clear();

        if (value != null && !value.isEmpty()) {
            noRoutesAssigned.setVisibility(View.GONE);
            list.setVisibility(View.VISIBLE);
            for (QueryDocumentSnapshot snapshot : value) {
                RouteProposal routeProposalAux = snapshot.toObject(RouteProposal.class);
                routesProposalsIds.add(snapshot.getId());
                routesIds.add(routeProposalAux.getRouteId());
                showNumberOfParticipantsSlashTotal(routeProposalAux.getParticipantsIds().size(), Integer.valueOf(routeProposalAux.getMaxParticipants()));
                showMainImageOfRoutes();
                datesOfRoutes.add(routeProposalAux.getWhichDay());
                db.collection("Routes").document(routeProposalAux.getRouteId()).get().addOnCompleteListener(task -> {
                    if (task.isSuccessful()) {
                        DocumentSnapshot document = task.getResult();
                        if (document.exists()) {
                            Route routeAux = document.toObject(Route.class);
                            routesNames.add(routeAux.getName());
                        }
                        listAdapterRoutesGuide.notifyDataSetChanged();
                    }
                });
            }
        } else {
            list.setVisibility(View.GONE);
            noRoutesAssigned.setVisibility(View.VISIBLE);
            listAdapterRoutesGuide.notifyDataSetChanged();
        }
    });

2. 强制监听器优先从服务器同步数据 #

通过配置ListenOptions监听元数据变化，或强制查询从服务器获取数据，避免依赖缓存：

// 配置监听选项，包含元数据变化
ListenOptions options = new ListenOptions();
options.setIncludeMetadataChanges(true);

db.collection("RoutesProposals").whereEqualTo("idGuide", currentFirebaseUser.getUid())
    .addSnapshotListener(options, (value, error) -> {
        if(error != null) {
            Log.w("error", "Listen failed.", error);
            return;
        }
        // 忽略缓存数据，只处理服务器同步的最新数据
        if (value != null && value.getMetadata().isFromCache()) {
            return;
        }
        // 清空数据列表
        routesProposalsIds.clear();
        routesIds.clear();
        datesOfRoutes.clear();
        routesNames.clear();

        if (value != null && !value.isEmpty()) {
            noRoutesAssigned.setVisibility(View.GONE);
            list.setVisibility(View.VISIBLE);
            for (QueryDocumentSnapshot snapshot : value) {
                // 原有数据处理逻辑
            }
            listAdapterRoutesGuide.notifyDataSetChanged();
        } else {
            list.setVisibility(View.GONE);
            noRoutesAssigned.setVisibility(View.VISIBLE);
            listAdapterRoutesGuide.notifyDataSetChanged();
        }
    });

也可以先强制从服务器拉取一次最新数据，再添加监听器：

db.collection("RoutesProposals").whereEqualTo("idGuide", currentFirebaseUser.getUid())
    .get(Source.SERVER)
    .addOnSuccessListener(queryDocumentSnapshots -> {
        db.collection("RoutesProposals").whereEqualTo("idGuide", currentFirebaseUser.getUid())
            .addSnapshotListener((value, error) -> {
                // 监听器逻辑
            });
    });

3. 优化嵌套查询，使用批量获取 #

避免循环嵌套get()请求，改用getAll()批量获取Route文档，提升性能和一致性：

if (value != null && !value.isEmpty()) {
    List<DocumentReference> routeRefs = new ArrayList<>();
    // 先收集所有Route文档引用
    for (QueryDocumentSnapshot snapshot : value) {
        RouteProposal routeProposalAux = snapshot.toObject(RouteProposal.class);
        routeRefs.add(db.collection("Routes").document(routeProposalAux.getRouteId()));
        // 其他数据存储逻辑
    }
    // 批量获取Route文档
    db.getAll(routeRefs).addOnSuccessListener(documents -> {
        routesNames.clear();
        for (DocumentSnapshot doc : documents) {
            if (doc.exists()) {
                Route routeAux = doc.toObject(Route.class);
                routesNames.add(routeAux.getName());
            }
        }
        listAdapterRoutesGuide.notifyDataSetChanged();
    });
}

• 确保设备网络正常，Firestore需网络同步服务器数据到本地缓存。
• 检查Firestore安全规则，确认应用拥有RoutesProposals集合的读取和监听权限。
• 若问题仍存在，可尝试重启应用彻底清除本地缓存。

内容的提问来源于stack exchange，提问作者Julio Escudero Cuesta