在 iOS 中使用 NSInvocation 构建灵活且强大的事件总线（支持同步返回）

2023-10-26 02:15:30

引言

在现代 iOS 应用程序开发中，事件总线模式已成为一种流行的技术，用于解耦应用程序的各个组件并简化通信。传统事件总线通常采用单向数据传递模型，这意味着发布者向订阅者发送数据，而订阅者无法同步返回结果。然而，在某些情况下，同步返回结果至关重要，特别是当应用程序需要在执行下一步骤之前等待处理的数据时。

基于 NSInvocation 的事件总线

NSInvocation 提供了一种强大的机制，可以用来创建支持同步返回结果的事件总线。它允许我们封装函数调用并以参数的形式传递数据，从而实现类似于“performSelector”的功能，但具有更少的限制。

设计和实现

我们的事件总线的设计包括以下组件：

事件总线类： 充当中央中介者，处理事件发布和订阅。
事件类： 封装单个事件，包括事件名称、方法调用信息和任何关联数据。
订阅者类： 实现事件处理逻辑。

事件发布

要发布事件，发布者创建一个事件对象，指定事件名称和方法调用信息，然后将该事件发布到事件总线上。事件总线负责将事件路由到适当的订阅者。

同步返回

要同步返回结果，发布者可以在事件对象中设置一个可选的“result”属性。当订阅者处理事件时，它可以检查“result”属性并立即获取结果。

示例代码

以下是使用 NSInvocation 构建事件总线的示例代码：

class EventBus {

    private var subscriptions = [String: [Subscription]]()

    func publish(event: Event) {
        guard let subscriptions = subscriptions[event.name] else { return }
        for subscription in subscriptions {
            subscription.invoke(event: event)
        }
    }

    func subscribe(name: String, object: AnyObject, selector: Selector) {
        let subscription = Subscription(object: object, selector: selector)
        subscriptions[name, default: []].append(subscription)
    }
}

class Event {

    let name: String
    let invocation: NSInvocation

    init(name: String, invocation: NSInvocation) {
        self.name = name
        self.invocation = invocation
    }

    var result: Any? {
        get { return invocation.returnValue }
        set { invocation.setReturnValue(newValue) }
    }
}

class Subscription {

    weak var object: AnyObject?
    let selector: Selector

    init(object: AnyObject, selector: Selector) {
        self.object = object
        self.selector = selector
    }

    func invoke(event: Event) {
        object?.perform(selector, with: event)
    }
}