离线状态下Firebase Realtime Database内部Publisher行为探究

场景说明 #

我正在开发一款以Firebase Realtime Database中名为cards的列表作为唯一数据源的应用，设计逻辑为：应用订阅cards列表，当列表数据发生变化时，内部通过发布-订阅模式推送变更。

对应的Swift ViewModel实现示例：

class ViewModel: ObservableObject {
  @Published var cards: [Card] = []
  private var cancellables = Set<AnyCancellable>()

  init() {
    dataManager.cardPublisher
      .sink(receiveValue: { [weak self] (cards) in
         self?.cards = cards
      })
      .store(in: &cancellables)
    }
}

已知通过控制台更新云端数据库时，应用会收到推送值，并通过ViewModel更新内部状态。现在关注另一种场景：当应用处于离线状态时，自身发起的数据库更新请求成功执行后，订阅者是否会收到值的推送？

注：Firebase的离线功能会维护数据库的本地状态，离线时的写操作会被排队，待应用联网后同步到云端。

其中cardPublisher是基于Firebase数据库引用的observe(.value)实现，代码示例如下：

// 监听路径及其子节点的任何变化
cardsDbReference.observe(.value, with: { [weak self] snapshot in
    var cards: [Card] = []
    for case let childSnapshot as DataSnapshot in snapshot.children {
        guard let value = childSnapshot.value as? [String: Any] else {
            print("Error: Could not retrieve cards.")
            continue
        }

        do {
            let cardData = try JSONSerialization.data(withJSONObject: value, options: [])
            let decoder = JSONDecoder()
            let card = try decoder.decode(Card.self, from: cardData)
            cards.append(card)
        } catch {
            print("Decoding error: \(error.localizedDescription)")
        }
    }

    self?.cardPublisher.send(cards)
})

核心结论 #

会收到推送，原因如下：

• Firebase Realtime Database的离线机制会在本地设备维护一份完整的数据缓存副本
• 离线状态下执行写操作时，操作会先写入本地缓存，此时本地数据发生变化
• observe(.value)监听的是本地缓存与云端数据的合并状态，本地缓存更新后会立即触发.value事件
• cardPublisher会基于更新后的本地快照解析生成新的cards数组，并推送给所有订阅者（比如ViewModel）

额外说明 #

• 这种机制能保证离线操作后UI即时更新，无需等待联网同步，大幅提升离线场景下的用户体验
• 当应用恢复联网后，Firebase会自动将本地排队的操作同步到云端：
  • 如果云端数据与本地没有冲突，不会重复触发.value事件
  • 如果存在冲突（例如其他设备在离线期间修改了同一份数据），Firebase会按照预设的冲突规则处理后，触发新的.value事件，确保本地状态最终与云端一致

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