watchOS 8独立应用HealthKit后台交付功能运行数小时后失效问题咨询

核心问题排查 #

• 首先修复代码笔误：你当前HKObserverQuery初始化时传入的sampleType是stepsType，和你要监听的lowHeartRateType完全不匹配，这会导致监听对象错误，直接无法收到心率异常的回调。
• 锚点未持久化：当前HKQueryAnchor仅存储在内存变量中，watchOS会定期清理长时间后台运行的应用，应用被杀后锚点丢失，重启后无法继续之前的查询任务。
• 查询未重新注册：你仅在applicationDidFinishLaunching中注册了查询和后台交付，应用被系统杀掉后再次唤醒时，没有重新执行注册逻辑，导致后台交付失效。
• 后台超时未处理：watchOS给后台唤醒应用的运行时间仅10-30秒，未及时调用completionHandler会被系统标记为高耗电应用，后续会限制甚至停止唤醒。

修复方案 #

1. 锚点持久化 #

利用HKQueryAnchor支持NSSecureCoding的特性，将锚点归档存储到UserDefaults，避免应用被杀后数据丢失：

// 存锚点
func saveAnchor(_ anchor: HKQueryAnchor?) {
    guard let anchor = anchor else { return }
    do {
        let data = try NSKeyedArchiver.archivedData(withRootObject: anchor, requiringSecureCoding: true)
        UserDefaults.standard.set(data, forKey: "HealthKitAnchor")
    } catch {
        print("锚点存储失败: \(error)")
    }
}

// 读锚点
func loadAnchor() -> HKQueryAnchor? {
    guard let data = UserDefaults.standard.data(forKey: "HealthKitAnchor") else { return nil }
    do {
        return try NSKeyedUnarchiver.unarchivedObject(ofClass: HKQueryAnchor.self, from: data)
    } catch {
        print("锚点读取失败: \(error)")
        return nil
    }
}

2. 新增查询和后台交付的重新注册逻辑 #

在ExtensionDelegate中新增observerQuery成员变量存储当前监听对象，同时在applicationDidBecomeActive中也调用activateHeathKit方法，确保应用每次唤醒都能正常注册监听，添加状态判断避免重复注册：

class ExtensionDelegate: NSObject, WKExtensionDelegate {
    private let healthStore = HKHealthStore()
    private var observerQuery: HKObserverQuery?
    // 初始化时读取持久化的锚点
    private lazy var anchor: HKQueryAnchor? = loadAnchor()

    func applicationDidFinishLaunching() {
        print("application did finish launching")
        activateHeathKit()
    }

    func applicationDidBecomeActive() {
        // 应用从后台唤醒时重新注册监听
        activateHeathKit()
    }

    func activateHeathKit() {
        let types = Set([HKObjectType.categoryType(forIdentifier: .lowHeartRateEvent)!])
        healthStore.requestAuthorization(toShare: nil, read: types) { [weak self] success, _ in
            guard let self = self, success else { return }
            guard let lowHeartRateType = HKObjectType.categoryType(forIdentifier: .lowHeartRateEvent) else { return }
            
            // 先检查后台交付状态，避免重复调用
            self.healthStore.backgroundDeliveryStatus(for: lowHeartRateType) { status, error in
                guard status != .enabled else { return }
                self.healthStore.enableBackgroundDelivery(for: lowHeartRateType, frequency: .immediate) { success, _ in
                    print("enableBackgroundDelivery: \(success) for lowHeartRateEvent")
                }
            }
            
            // 先停止旧的查询避免重复注册
            if let existingQuery = self.observerQuery {
                self.healthStore.stop(existingQuery)
            }
            // 修复sampleType错误
            let query = HKObserverQuery(sampleType: lowHeartRateType, predicate: nil) { [weak self] _, completionHandler, error in
                guard let self = self else {
                    completionHandler()
                    return
                }
                self.updateLowHeartRate {
                    completionHandler()
                }
            }
            self.observerQuery = query
            self.healthStore.execute(query)
        }
    }
}

3. 优化锚点更新逻辑 #

修改updateLowHeartRate方法，将unowned self替换为weak self避免野指针崩溃，同时每次查询完成后持久化新锚点：

func updateLowHeartRate(completionHandler: @escaping () -> Void) {
    guard let lowHeartRateType = HKObjectType.categoryType(forIdentifier: .lowHeartRateEvent) else {
        completionHandler()
        return
    }

    let anchoredQuery = HKAnchoredObjectQuery(type: lowHeartRateType, predicate: nil, anchor: self.anchor, limit: Int(HKObjectQueryNoLimit)) { [weak self] query, newSamples, _, newAnchor, error -> Void in
        guard let self = self else {
            completionHandler()
            return
        }
        for item in newSamples ?? [] {
            let date = item.startDate
            let hour = Calendar.current.component(.hour, from: date)
            let minute = Calendar.current.component(.minute, from: date)

            let message = "Low heart rate from \(hour):\(String(format: "%02d", minute))"
            print(message)
        }
        // 持久化新锚点
        self.anchor = newAnchor
        self.saveAnchor(newAnchor)
        completionHandler()
    }
    healthStore.execute(anchoredQuery)
}

4. 适配后台运行限制 #

如果需要执行推送等耗时操作，调用WKExtension.shared().scheduleBackgroundRefresh申请额外后台时间，确保操作完成前应用不会被系统杀掉。

5. 权限检查 #

确认用户已经开启两项权限：

• Watch设置->隐私与安全性->健康->你的应用->允许读取低心率事件权限
• Watch设置->通用->后台刷新->你的应用->后台刷新开关开启

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