iOS Live Activity开发指南

// 建议在应用启动时就开启监听
func application(_ application: UIApplication, didFinishLaunchingWithOptions launchOptions: [UIApplication.LaunchOptionsKey: Any]?) -> Bool {
    observeActivityTokenAndState()
    return true
}

func observeActivityTokenAndState() {
    Task {
        var oldToken: String = ""
        if #available(iOS 17.2, *) {
            for await tokenData in Activity<MyActivityAttributes>.pushToStartTokenUpdates {
                let token = tokenData.map { String(format: "%02x", $0) }.joined()
                if oldToken != token {
                    oldToken = token
                    // 调用阿里云SDK注册启动令牌
                    CloudPushSDK.registerLiveActivityStartToken(
                        tokenData,
                        forActivityAttributes: "MyActivityAttributes"
                    ) { result in
                        print("启动令牌上报结果：\(result.success) - 模型：MyActivityAttributes")
                    }
                }
            }
        }
    }
}

class LiveActivityMonitor {
    private var taskHandle: Task<Void, Never>?
    private var monitoredActivities = Set<String>()
    
    func startMonitoring() {
        taskHandle = Task {
            if #available(iOS 16.2, *) {
                // 监听所有活动更新
                for await activity in Activity<HelloAttributes>.activityUpdates {
                    print("检测到活动：\(activity.id)")
                    
                    // 避免重复监听同一个activity
                    guard !monitoredActivities.contains(activity.id) else { continue }
                    monitoredActivities.insert(activity.id)
                    
                    // 监听推送令牌变化
                    Task {
                        var oldPushToken = ""
                        for await tokenData in activity.pushTokenUpdates {
                            let token = tokenData.map { String(format: "%02x", $0) }.joined()
                            if oldPushToken != token {
                                oldPushToken = token
                                // 上报推送令牌到阿里云
                                CloudPushSDK.registerLiveActivityPushToken(
                                    tokenData,
                                    forActivityId: activity.id
                                ) { result in
                                    print("推送令牌更新结果：\(result.success) - 活动ID：\(activity.id)")
                                }
                            }
                        }
                    }
                    
                    // 监听活动状态变化
                    Task {
                        for await state in activity.activityStateUpdates {
                            // 同步状态到阿里云
                            CloudPushSDK.syncLiveActivityState(
                                "\(state)",
                                forActivityId: activity.id
                            ) { result in
                                print("状态同步结果：\(result.success) - 状态：\(state) - 活动ID：\(activity.id)")
                            }
                            
                            // 如果活动结束，从监听列表中移除
                            if state == .ended {
                                monitoredActivities.remove(activity.id)
                            }
                        }
                    }
                }
            }
        }
    }
    
    func stopMonitoring() {
        taskHandle?.cancel()
        monitoredActivities.removeAll()
    }
}