Firebase如何仅获取服务端发生更新的增量数据

API 理解确认 #

你对提到的两个 API 的认知没有偏差，二者确实都会返回节点全量数据：

• get() 优先从服务端拉取当前节点的完整最新快照，仅离线状态下会返回本地缓存的全量数据
• addListenerForSingleValueEvent 若开启了本地持久化，会优先返回本地缓存的全量数据，无缓存时才从服务端拉取
  两类调用都不会主动判断服务端数据是否发生变更，触发即返回完整节点数据，不支持直接返回增量。

仅拉取变更数据的实现方案 #

方案1：使用 addValueEventListener 结合本地持久化（推荐适配实时同步场景） #

Firebase Realtime Database 原生支持增量同步能力，开启磁盘持久化后绑定值事件监听器即可实现需求：

1. 首次绑定监听器时会拉取一次节点全量数据，同步到本地缓存
2. 后续仅当服务端对应节点的数据发生变更时，才会推送增量数据到客户端，底层不会重复传输全量内容，可大幅节省带宽
3. onDataChange 回调返回的是合并后的全量快照，可直接使用

示例代码：

// 全局仅需初始化一次，建议在 Application 启动时调用
FirebaseDatabase.getInstance().setPersistenceEnabled(true)

// 绑定节点监听
getUserReference()?.addValueEventListener(object : ValueEventListener {
    override fun onDataChange(snapshot: DataSnapshot) {
        // 首次触发返回全量数据，后续仅服务端数据变更时触发
        // 业务逻辑处理
    }

    override fun onCancelled(error: DatabaseError) {
        // 异常处理逻辑
    }
})

不需要监听时调用 removeEventListener 注销即可，不会额外消耗资源。

方案2：自定义时间戳实现手动增量拉取（适配非实时按需拉取场景） #

如果不需要实时同步，仅希望主动触发时拉取上次拉取后的变更内容，可以在数据节点中新增 lastUpdated 毫秒级时间戳字段，每次写入数据时同步更新该字段：

1. 本地持久化存储上次拉取成功的时间戳 lastFetchTime，首次拉取时默认值为0
2. 查询时添加过滤条件，仅返回 lastUpdated 大于 lastFetchTime 的条目
3. 拉取成功后更新本地存储的 lastFetchTime 为当前时间戳

示例代码：

// 从本地存储读取上次拉取时间
val lastFetchTime = getLocalLastFetchTime()
getUserReference()?.orderByChild("lastUpdated")
    ?.startAfter(lastFetchTime)
    ?.get()
    ?.addOnSuccessListener { snapshot ->
        // snapshot 仅包含上次拉取之后新增/修改的数据
        // 业务逻辑处理
        // 更新本地存储的拉取时间
        updateLocalLastFetchTime(System.currentTimeMillis())
    }

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