多API解析数据存入Core Data的缓存方案及并行写入崩溃问题

问题背景 #

我们的应用从服务器获取大量原始数据并存储到Core Data中，需对这些原始数据执行大量操作以向用户展示预期结果，因此会将原始数据存入Core Data实体。当前处理流程如下：

API Response
   persistentContainer.newBackgroundContext() //in the same background queue
   context.perform {
       create NSManagedObject
       context.save()
   }

目前各类对象的多个API并行执行，且同一对象的多个API也会并行处理。在此场景下存在两个疑问：

1. 若同一对象的3个API响应并行到达，创建3个后台上下文操作同一实体，是否会导致崩溃？
2. 有没有更优的处理方式？

补充：已在New Relic上发现崩溃，堆栈追踪始终指向某个保存操作的context.save()。

问题1：是否会导致崩溃？ #

会。核心原因有两点：

• 线程安全冲突：Core Data上下文并非线程安全，尽管每个上下文在独立队列执行，但多个上下文并行对同一实体执行写入操作（如重复创建、属性修改）时，保存阶段会触发数据竞争，未处理的异常会直接导致崩溃。
• 唯一性约束冲突：如果实体设置了唯一约束（如对象ID），多个上下文同时创建同ID的对象，保存时会触发约束校验错误，若未捕获该错误，就会引发save()环节的崩溃，这正是你在New Relic中看到的问题场景。

问题2：更优处理方式 #

1. 串行化写入操作，复用单一后台上下文 #

不为每个API响应新建上下文，而是将所有Core Data写入操作统一派发到全局串行队列，或复用一个绑定串行队列的后台上下文，确保同一实体的写入操作按顺序执行，从根源避免并行冲突。

示例代码：

// 全局串行写入队列
private let coreDataWriteQueue = DispatchQueue(label: "com.yourapp.coredata.write")
// 复用的后台上下文
private lazy var writeContext: NSManagedObjectContext = {
    let context = persistentContainer.newBackgroundContext()
    // 设置合并策略，提前处理冲突
    context.mergePolicy = NSMergeByPropertyObjectTrumpMergePolicy
    return context
}()

// API响应处理逻辑
func handleAPIResponse(data: [String: Any]) {
    coreDataWriteQueue.async {
        self.writeContext.perform {
            // 执行对象创建/更新操作
            self.upsertObject(with: data["id"] as! String, data: data)
            
            // 捕获保存错误，避免崩溃
            do {
                try self.writeContext.save()
            } catch {
                // 记录错误日志，便于排查
                print("Core Data保存失败: \(error.localizedDescription)")
            }
        }
    }
}

2. 实现Upsert逻辑，避免重复对象 #

在创建对象前先查询是否存在同ID的实体，存在则更新属性，不存在再创建，从根源避免唯一性约束冲突：

private func upsertObject(with id: String, data: [String: Any]) {
    let fetchRequest: NSFetchRequest<YourEntity> = YourEntity.fetchRequest()
    fetchRequest.predicate = NSPredicate(format: "id == %@", id)
    
    do {
        let existingObjects = try writeContext.fetch(fetchRequest)
        if let existing = existingObjects.first {
            // 更新现有对象属性
            existing.name = data["name"] as? String
            existing.updateTime = Date()
            // ...其他属性更新
        } else {
            // 创建新对象
            let newObject = YourEntity(context: writeContext)
            newObject.id = id
            newObject.name = data["name"] as? String
            // ...其他属性赋值
        }
    } catch {
        print("查询实体失败: \(error.localizedDescription)")
    }
}

3. 配置合适的合并策略 #

为上下文设置合并策略，当出现数据冲突时自动处理，而非抛出异常：

• NSMergeByPropertyObjectTrumpMergePolicy：当前上下文对象的属性覆盖存储区的属性（适合本地修改优先）
• NSMergeByPropertyStoreTrumpMergePolicy：存储区的属性覆盖当前上下文的属性（适合服务器数据优先）
• NSOverwriteMergePolicy：直接用当前上下文的数据覆盖存储区数据
• NSRollbackMergePolicy：回滚当前上下文的修改，保留存储区数据

4. 捕获所有保存错误 #

必须用do-catch包裹context.save()，捕获并处理所有可能的错误，绝对不能让异常向上传播导致崩溃，同时记录详细错误日志便于后续排查。

5. 批量处理API响应 #

若多个API返回同一类型的实体数据，可以先收集多份响应数据，再批量执行Core Data写入操作，减少保存次数，降低冲突概率。

内容的提问来源于stack exchange，提问作者Shakti Pratap Singh