在发布-订阅系统中处理事件有哪些不同的方法？

Question

在每个订阅者等待多种类型事件的发布-订阅系统中，是否有比简单交换机更好的处理解决方案？

假设我们有 2 个发布者，Pub1 和 Pub2； Pub1 发送两种类型的事件 Pub1-eventA 和 Pub1-eventB，Pub2 也是如此，分别发送 Pub2-eventA 和 Pub2-eventB

另一方面，我们有一个客户端 Sub1，它订阅 Pub1 和 Pub2 的事件；

您将如何在 Sub1 侦听器中处理这些事件？

这里有一些可能性：

一个侦听器，一个大开关（难以维护）：

Listener{

  HandleEvent(event){

    if(event.type == Pub1-eventA)
       Action1.execute();
    if(event.type == Pub1-eventB)
       Action2.execute();
    if(event.type == Pub2-eventA)
       Action3.execute();
    if(event.type == Pub2-eventB)
       Action4.execute();

  }

}

一个侦听器和一个关联映射：

Map<event-type, Action> ActionMap

Listener{

      Action = ActionMap[event-type]

      Action.execute();
}

每种事件类型一个侦听器：

ListenerPub1-eventA{ check(event-type); Action1.execute(); }
ListenerPub1-eventB{ check(event-type); Action2.execute(); }
ListenerPub2-eventA{ check(event-type); Action3.execute(); }
ListenerPub2-eventB{ check(event-type); Action4.execute(); }

Answer 1

在“一个侦听器，一个大开关”和“一个侦听器和关联映射”中，每个事件仍将以单个隔离方法结束，但您必须在代码中维护事件的分派。

发布-订阅消息系统最重要的贡献是解耦发布者和订阅者。因此消息路由应该由中间件负责。如果您的中间件不具备消息路由功能，那么我建议每种事件类型使用一个侦听器，以便：

1. 您不必自己维护消息路由/调度
2. 每个侦听器将承担单一职责
3. 如果出现任何扩展在这种情况下，您可以为任何消息类型添加更多侦听器，而无需触及不相关的侦听器。

我能想到的就是这些。

我希望这有帮助。