如何在NotificationServiceExtension中存储远程通知数据到Core Data及关联数据问题

看起来你遇到的问题是跨进程（主App和NotificationServiceExtension）写入Core Data的关联数据后，主App后台查询时无法即时获取关联对象，只有重启后才可见。这个问题通常和Core Data的上下文同步、跨进程数据更新通知以及关联对象的懒加载机制有关，下面是几个针对性的解决方案：

1. 确保主App监听Core Data的跨进程存储变更通知 #

Core Data从iOS 10开始支持NSPersistentStoreRemoteChange通知，当其他进程（比如你的Extension）修改了共享的持久化存储时，这个通知会发送给主App。你需要在主App的Core Data管理类中监听这个通知，然后刷新上下文以获取最新数据：

// 在主App的CoreDataStorage初始化方法中添加监听
func setupRemoteChangeListening() {
    guard let coordinator = persistentStoreCoordinator else { return }
    NotificationCenter.default.addObserver(
        self,
        selector: #selector(handleRemoteStoreChange(_:)),
        name: .NSPersistentStoreRemoteChange,
        object: coordinator
    )
}

@objc private func handleRemoteStoreChange(_ notification: Notification) {
    // 必须在上下文对应的队列上执行刷新操作
    mainQueueCtxt?.perform { [weak self] in
        guard let self = self, let context = self.mainQueueCtxt else { return }
        do {
            // iOS 13+ 可以用fetchChanges()自动合并远程变更
            try context.fetchChanges()
        } catch {
            // 兼容低版本，手动刷新所有对象
            context.refreshAllObjects()
            print("Failed to fetch remote changes: \(error)")
        }
    }
}

记得在App启动时调用setupRemoteChangeListening()开启监听。

2. 确认Extension的Core Data配置正确触发远程通知 #

虽然NSPersistentStoreRemoteChange是默认启用的，但可以显式在Extension的持久化存储配置中开启，避免因配置缺失导致通知不触发：

// 在Extension的persistentStoreCoordinator配置中添加选项
let options: [AnyHashable: Any] = [
    NSMigratePersistentStoresAutomaticallyOption: true,
    NSInferMappingModelAutomaticallyOption: true,
    NSPersistentStoreRemoteChangeNotificationOption: true // 显式开启远程变更通知
]

同时要确保Extension的上下文保存逻辑正确，所有关联对象都已正确插入并完成保存操作。

3. 查询时预加载关联数据，避免懒加载故障 #

Core Data默认对关联对象使用懒加载（Faulting），如果上下文未同步最新数据，访问关联属性时可能无法触发正确加载。你可以在查询MessageInfo时，通过relationshipKeyPathsForPrefetching预加载需要的关联对象：

func fetchMessagesFromCoreDataWithPredicate(resultPredicate: NSPredicate, sortDescriptorKey: String, isAscending: Bool, fetchLimit: Bool, managedContext: NSManagedObjectContext) -> [MessageInfo] {
    let fetchRequest = NSFetchRequest<MessageInfo>(entityName: "MessageInfo")
    fetchRequest.predicate = resultPredicate
    fetchRequest.sortDescriptors = [NSSortDescriptor(key: sortDescriptorKey, ascending: isAscending)]
    
    // 预加载toRoster以及toRoster下的toMessageInfo关联数据
    fetchRequest.relationshipKeyPathsForPrefetching = ["toRoster", "toRoster.toMessageInfo"]
    
    if fetchLimit {
        fetchRequest.fetchLimit = 1
    }
    
    do {
        return try managedContext.fetch(fetchRequest)
    } catch {
        print("Fetch error: \(error)")
        return []
    }
}

这样查询到的MessageInfo对象会直接包含完整的关联数据，无需再触发懒加载。

4. 手动刷新查询到的对象 #

如果预加载不适用，你也可以在获取对象后，手动刷新对象及其关联对象，强制从持久化存储中读取最新数据：

let messageInfoAry = self.fetchMessagesFromCoreDataWithPredicate(...)
if messageInfoAry.count > 0 {
    let msgInfo = messageInfoAry[0]
    let managedContext = self.getManageObjectContext()
    
    // 刷新当前对象
    managedContext.refresh(msgInfo, mergeChanges: true)
    
    // 刷新关联的rosterInfo
    if let rosterInfo = msgInfo.toRoster {
        managedContext.refresh(rosterInfo, mergeChanges: true)
        let setArray = rosterInfo.toMessageInfo
        // 现在setArray应该能获取到最新数据了
    }
}

5. 检查Core Data上下文的合并策略 #

确保主App和Extension的Core Data上下文都设置了合适的合并策略，避免冲突导致数据无法同步：

// 在上下文初始化时设置合并策略
lazy var mainQueueCtxt: NSManagedObjectContext? = {
    let context = NSManagedObjectContext(concurrencyType: .mainQueueConcurrencyType)
    context.persistentStoreCoordinator = self.persistentStoreCoordinator
    // 当有冲突时，用新数据覆盖旧数据
    context.mergePolicy = NSMergeByPropertyObjectTrumpMergePolicy
    return context
}()

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