Firebase Firestore：如何订阅最近一小时创建的文档？

核心逻辑 #

通过Firestore的实时监听+动态时间范围查询，确保订阅结果始终只包含当前时间往前1小时内创建的文档。当无新文档生成时，旧文档会随着时间超出1小时范围自动从监听结果中移除。

具体实现步骤 #

1. 构建动态时间查询 #

每次查询都计算当前时间减去1小时的时间戳，以此作为文档筛选的起始条件：

// Kotlin 示例代码
val oneHourAgo = System.currentTimeMillis() - 3600000 // 3600000毫秒 = 1小时
val query = firestore.collection("目标集合名")
    .whereGreaterThan("created-timestamp", oneHourAgo)
    .orderBy("created-timestamp") // 可选：按创建时间排序，方便后续处理

2. 启动实时监听 #

使用addSnapshotListener订阅查询结果，Firestore会自动推送符合条件的文档变更：

var listenerRegistration = query.addSnapshotListener { snapshot, error ->
    if (error != null) {
        // 处理监听异常，比如打印日志或提示用户
        return@addSnapshotListener
    }
    snapshot?.documents?.let { recentDocs ->
        // 这里拿到的就是当前最近1小时内的所有文档
        // 执行UI更新或业务逻辑处理
    }
}

3. 动态更新查询条件 #

由于初始查询的oneHourAgo是固定值，时间推移后会导致筛选范围失效，因此需要定期更新查询条件：

val refreshTimer = Timer()
refreshTimer.scheduleAtFixedRate(object : TimerTask() {
    override fun run() {
        // 先取消旧的监听
        listenerRegistration.remove()
        // 重新计算1小时前的时间戳
        val newOneHourAgo = System.currentTimeMillis() - 3600000
        // 创建新的查询
        val newQuery = firestore.collection("目标集合名")
            .whereGreaterThan("created-timestamp", newOneHourAgo)
            .orderBy("created-timestamp")
        // 启动新的监听
        listenerRegistration = newQuery.addSnapshotListener { snapshot, error ->
            // 复用之前的结果处理逻辑
        }
    }
}, 0, 60000) // 每隔60秒刷新一次查询，可根据需求调整间隔

4. 关键优化点 #

• 索引配置：如果同时使用whereGreaterThan和orderBy，Firebase控制台会提示创建对应的复合索引，按照提示完成配置即可，否则查询会失败。
• 减少不必要请求：如果实时性要求不高，可将刷新间隔调整为5-10分钟，降低Firestore的请求频次和资源消耗。
• 内存泄漏防护：在页面销毁时，务必取消监听和定时器：

override fun onDestroy() {
    super.onDestroy()
    listenerRegistration.remove()
    refreshTimer.cancel()
}

方案优势 #

• 依托Firestore原生实时监听能力，无需手动轮询全量文档，仅获取符合条件的变更数据，性能更优。
• 动态更新查询条件，确保筛选范围始终匹配“最近1小时”，自动移除超时文档，完全符合需求。
• 实现逻辑简洁，代码可维护性高，仅需处理查询和监听的生命周期即可。

内容的提问来源于stack exchange，提问作者Konstantin Konopko