观察者模式与发布订阅模式：异曲同工，却各有千秋

2023-10-07 17:32:38

观察者模式与发布订阅模式：深入理解

导言

如果你是一个热衷于技术博文的创作者，你很可能会遇到这样的疑问：观察者模式和发布订阅模式之间有什么区别？乍看之下，这两者似乎很相似，因为它们都涉及一个对象（发布者）向另一个对象（订阅者）发送消息。然而，深入探究之后，你将会发现这两个模式之间存在一些关键差异。

观察者模式

观察者模式是一种事件驱动的模式。这意味着，当发布者的状态发生变化时，它会发出通知，而订阅者会监听这些通知并相应做出反应。举个例子，当用户点击按钮时，发布者会发出一个通知，而订阅者会相应地更新用户界面。

观察者模式的关键特点包括：

发布者和订阅者之间紧密耦合。这意味着，当发布者发生变化时，订阅者也必须相应地进行更改。
观察者模式非常适合于处理一组预定义的事件。

发布订阅模式

另一方面，发布订阅模式是一种消息驱动的模式。这意味着，发布者将消息发送到一个集中位置（称为消息队列），而订阅者从消息队列中接收这些消息并做出相应反应。

发布订阅模式的重要特征包括：

发布者和订阅者之间松散耦合。这意味着，发布者和订阅者可以独立于彼此进行更改，而不会相互影响。
发布订阅模式非常适合于处理各种各样的消息。

适用场景

选择观察者模式还是发布订阅模式取决于具体的应用场景：

当你需要处理一组预定义的事件时，观察者模式是一个很好的选择。
当你需要处理各种各样的消息时，发布订阅模式更合适。

代码示例

为了更好地理解这两个模式，让我们通过一个代码示例来演示它们：

观察者模式：

class Subject:
    def __init__(self):
        self._observers = []

    def attach(self, observer):
        self._observers.append(observer)

    def detach(self, observer):
        self._observers.remove(observer)

    def notify(self):
        for observer in self._observers:
            observer.update(self)

class Observer:
    def __init__(self, subject):
        self._subject = subject
        self._subject.attach(self)

    def update(self, subject):
        # 根据观察者需要实现的更新逻辑
        pass

发布订阅模式：

class Publisher:
    def __init__(self):
        self._subscribers = []

    def subscribe(self, subscriber):
        self._subscribers.append(subscriber)

    def unsubscribe(self, subscriber):
        self._subscribers.remove(subscriber)

    def publish(self, message):
        for subscriber in self._subscribers:
            subscriber.receive(message)

class Subscriber:
    def __init__(self, publisher):
        self._publisher = publisher
        self._publisher.subscribe(self)

    def receive(self, message):
        # 根据订阅者需要实现的接收逻辑
        pass