如何将Realm对象作为@Published属性实现实时值同步？

一、Combine订阅无响应的核心原因 #

你犯了一个新手常见错误：订阅的是Realm对象自身的publisher，而非Service中@Published属性的Combine发布者。

你的ViewModel代码里，Service.shared.user.publisher 调用的是Realm User 对象的内置publisher，而非@Published var user: User?对应的Combine发布者。正确做法是通过$前缀访问@Published属性的发布者，即Service.shared.$user。

修复后的ViewModel代码 #

class ViewModel: ObservableObject {
    
    private var cancellables = Set<AnyCancellable>()
    
    @Published var user: User?

    init() {
        setupBindings()
    }
    
    func setupBindings() {
        // 改用$user访问@Published的Combine发布者
        Service.shared.$user
            .receive(on: DispatchQueue.main)
            .sink { [weak self] user in
                print("收到用户对象更新: \(user?._id ?? "nil")")
                self?.user = user
            }
            .store(in: &cancellables)
     }
}

二、处理Realm对象内部属性变化 #

Realm对象是"live"的，但如果ViewModel需要感知User内部属性（如userName）的变化（比如更新计算属性），仅订阅$user不够——它只在对象引用变化时触发。此时可以在收到User对象后，订阅Realm的对象通知：

func setupBindings() {
    Service.shared.$user
        .receive(on: DispatchQueue.main)
        .sink { [weak self] newUser in
            self?.user = newUser
            // 取消之前的对象订阅
            self?.cancellables.removeAll(where: { $0 is AnyCancellable })
            // 订阅新User对象的内部变化
            newUser?.observe { change in
                switch change {
                case .change(let properties):
                    print("用户属性变化: \(properties.map { $0.name })")
                    self?.objectWillChange.send() // 通知View更新
                case .error(let error):
                    print("Realm监听错误: \(error)")
                case .deleted:
                    self?.user = nil
                }
            }
            .store(in: &self!.cancellables)
        }
        .store(in: &cancellables)
}

三、全局用户数据管理优化方案 #

你的单例方案可以运行，但有几个可优化的点：

1. 避免硬编码单例，改用依赖注入 #

单例不利于单元测试，建议通过初始化参数将Service注入ViewModel：

class ViewModel: ObservableObject {
    private let service: Service
    // ...
    
    init(service: Service = .shared) { // 提供默认值保持便捷性
        self.service = service
        setupBindings()
    }
    
    func setupBindings() {
        service.$user
            .receive(on: DispatchQueue.main)
            .sink { [weak self] user in
                self?.user = user
            }
            .store(in: &cancellables)
    }
}

2. 封装用户状态逻辑 #

在Service中封装更多用户相关逻辑，比如更新用户名、登出：

extension Service {
    @MainActor
    func updateUserName(_ name: String) throws {
        guard let user = user, let realm = RealmService.shared.realm else { return }
        try realm.write {
            user.userName = name
        }
    }
    
    @MainActor
    func logout() {
        guard let user = user, let realm = RealmService.shared.realm else { return }
        do {
            try realm.write {
                realm.delete(user)
            }
            self.user = nil
        } catch {
            print("登出失败: \(error)")
        }
    }
}

3. 自动初始化用户 #

在App启动时自动加载用户，比如在App结构体的init中调用：

@main
struct YourApp: App {
    init() {
        // 从@AppStorage或其他地方获取用户ID
        let userId = UserDefaults.standard.string(forKey: "currentUserId") ?? UUID().uuidString
        Task { @MainActor in
            Service.shared.loadOrGenerateOwnUser(userId: userId)
        }
    }
    
    var body: some Scene {
        WindowGroup {
            ContentView()
        }
    }
}

4. 完善错误处理 #

不要仅用print处理错误，建议通过Combine发布错误事件，让ViewModel或View感知并提示用户：

class Service: NSObject, ObservableObject {
    static var shared: Service = Service()
    
    @Published var user: User?
    @Published var error: Error? // 新增错误发布者
    
    @MainActor
    func loadOrGenerateOwnUser(userId: String) {
        guard let realm = RealmService.shared.realm else {
            error = NSError(domain: "Realm", code: -1, userInfo: [NSLocalizedDescriptionKey: "Realm未初始化"])
            return
        }
        
        if let user = realm.objects(User.self).where( { $0._id == userId } ).first {
            self.user = user
        } else {
            let user = User(_id: userId)
            do {
                try realm.write {
                    realm.add(user)
                }
                self.user = user
            } catch {
                self.error = error
            }
        }
    }
}

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