NSPersistentCloudKitContainer导入时通知多次触发问题排查

核心原因有两个： #

• CloudKit导入是分批次执行的
  NSPersistentCloudKitContainer不会一次性同步所有云端数据，当云端数据量较大、或者网络条件限制时，系统会自动把导入任务拆分成多个小批次。每完成一个批次的导入，就会发送一次.import类型的结束通知，这就导致你看到多次打印。

• 视图重复订阅通知
  如果你的MainView会被多次初始化（比如TabView切换、导航栈重复入栈时视图重建），每次创建视图都会通过.onReceive新增一个通知订阅。多个订阅同时生效时，每次事件触发就会执行多次处理代码。

对应的解决办法： #

1. 处理批次导入的问题

如果需要等待全部导入完成再执行逻辑，而不是单个批次，可以通过跟踪活跃导入事件实现：

• 维护一个计数器，当收到.import类型的开始事件时计数器+1，收到结束事件时计数器-1；
• 当计数器归0时，再触发你需要的全局完成逻辑。

2. 避免重复订阅

把通知订阅逻辑移到全局单例类中，或者在视图中确保只订阅一次：

方案一：全局同步管理器（推荐）

import SwiftUI
import CoreData
import Combine

class SyncManager: ObservableObject {
    static let shared = SyncManager()
    
    private var cancellables = Set<AnyCancellable>()
    
    private init() {
        setupCloudKitListener()
    }
    
    private func setupCloudKitListener() {
        NotificationCenter.default.publisher(for: NSPersistentCloudKitContainer.eventChangedNotification)
            .receive(on: DispatchQueue.main)
            .sink { notification in
                guard let cloudEvent = notification.userInfo?[NSPersistentCloudKitContainer.eventNotificationUserInfoKey] as? NSPersistentCloudKitContainer.Event else {
                    return
                }
                
                if cloudEvent.succeeded && cloudEvent.endDate != nil && cloudEvent.type == .import {
                    print("Import is finished!")
                }
            }
            .store(in: &cancellables)
    }
}

// 在视图中使用
struct MainView: View {
    @StateObject private var syncManager = SyncManager.shared
    
    var body: some View {
        Text("Example")
    }
}

方案二：视图内单次订阅

import SwiftUI
import CoreData
import Combine

struct MainView: View {
    @State private var isSubscribed = false
    private var cancellables = Set<AnyCancellable>()
    
    var body: some View {
        Text("Example")
            .onAppear {
                guard !isSubscribed else { return }
                
                NotificationCenter.default.publisher(for: NSPersistentCloudKitContainer.eventChangedNotification)
                    .receive(on: DispatchQueue.main)
                    .sink { notification in
                        guard let cloudEvent = notification.userInfo?[NSPersistentCloudKitContainer.eventNotificationUserInfoKey] as? NSPersistentCloudKitContainer.Event else {
                            return
                        }
                        
                        if cloudEvent.succeeded && cloudEvent.endDate != nil && cloudEvent.type == .import {
                            print("Import is finished!")
                        }
                    }
                    .store(in: &cancellables)
                
                isSubscribed = true
            }
    }
}

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