如何为Firebase GeoFire Swift实现实时更新（添加addSnapshotListener）

要实现地理查询的实时数据同步，核心是将一次性的getDocuments调用替换为addSnapshotListener，同时处理多查询的结果合并、去重及监听生命周期管理。以下是完整修改方案：

修改后代码 #

import FirebaseFirestore
import CoreLocation

// 保存监听句柄，用于后续取消监听
var geoQueryListeners = [ListenerRegistration]()
// 实时更新的匹配文档集合
var matchingCities = [QueryDocumentSnapshot]()

// 地理查询参数
let londonCenter = CLLocationCoordinate2D(latitude: 51.5074, longitude: 0.1278)
let searchRadiusInMeters: Double = 50 * 1000

// 生成地理查询边界及对应的Firestore查询
let queryBounds = GFUtils.queryBounds(forLocation: londonCenter, withRadius: searchRadiusInMeters)
let firestoreQueries = queryBounds.map { bound -> Query in
    return db.collection("cities")
        .order(by: "geohash")
        .start(at: [bound.startValue])
        .end(at: [bound.endValue])
}

// 处理单个查询的快照更新
func processGeoQuerySnapshot(snapshot: QuerySnapshot?, error: Error?) {
    guard let fetchedDocs = snapshot?.documents else {
        print("快照获取失败: \(error?.localizedDescription ?? "未知错误")")
        return
    }
    
    // 过滤出符合距离要求的文档
    let centerLocation = CLLocation(latitude: londonCenter.latitude, longitude: londonCenter.longitude)
    let validDocs = fetchedDocs.filter { doc in
        let lat = doc.data()["lat"] as? Double ?? 0
        let lng = doc.data()["lng"] as? Double ?? 0
        let docLocation = CLLocation(latitude: lat, longitude: lng)
        let distance = GFUtils.distance(from: centerLocation, to: docLocation)
        return distance <= searchRadiusInMeters
    }
    
    // 合并所有查询结果并去重（通过文档ID确保唯一性）
    let combinedDocs = matchingCities + validDocs
    let uniqueDocsDict = [String: QueryDocumentSnapshot](uniqueKeysWithValues: combinedDocs.map { ($0.documentID, $0) })
    matchingCities = Array(uniqueDocsDict.values)
    
    // 触发UI更新（根据实际场景实现）
    refreshCityListUI()
}

// 启动所有实时监听
func startRealTimeGeoQueries() {
    // 先清理旧监听，避免重复订阅
    stopRealTimeGeoQueries()
    
    for query in firestoreQueries {
        let listener = query.addSnapshotListener(listener: processGeoQuerySnapshot)
        geoQueryListeners.append(listener)
    }
}

// 停止所有监听，释放资源
func stopRealTimeGeoQueries() {
    geoQueryListeners.forEach { $0.remove() }
    geoQueryListeners.removeAll()
}

// 示例：更新UI的方法
func refreshCityListUI() {
    print("当前匹配城市数: \(matchingCities.count)")
    // 这里可以刷新TableView/CollectionView
    // cityTableView.reloadData()
}

// 使用示例：在页面显示时启动监听
// override func viewDidAppear(_ animated: Bool) {
//     super.viewDidAppear(animated)
//     startRealTimeGeoQueries()
// }

// 在页面消失时停止监听，防止内存泄漏
// override func viewDidDisappear(_ animated: Bool) {
//     super.viewDidDisappear(animated)
//     stopRealTimeGeoQueries()
// }

核心改动说明 #

• 实时监听替换：用addSnapshotListener替代getDocuments，Firestore数据变更时自动触发回调
• 监听生命周期管理：通过ListenerRegistration数组保存所有监听句柄，在页面销毁或不再需要时取消监听，避免内存泄漏
• 结果去重：由于多个地理查询边界可能返回同一文档，通过文档ID作为唯一键去重，保证结果准确性
• 全量更新逻辑：每次快照更新时重新计算匹配文档，避免数据重复或遗漏
• UI同步：在结果更新后调用UI刷新方法，确保前端实时反映数据变化

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