Python筆記：觀察者模式

觀察者模式中的主題對象一般存在著一個其他服務依賴的核心服務，並且維護著其他依賴此核心服務的對象列表（即觀察者或監視者列表），當主題對象發生變化時，觀察者應該改變自己的狀態或者進行某些操作

觀察者模式中的三個角色：

• 主題：即觀察者觀察的對象，一般是需要有註冊和註銷方法，用來添加觀察者和刪除觀察者。
• 觀察者基類：這個類主要是需要定義一個介面，以便主題發生變化時可以得到對應的通知信息。
• 觀察者：這個類需要具體實現基類中的“通知”介面，以便和主題的變化保持同步。

主題的兩種通知方式：

• 拉模型：這個方式重心在觀察者上，當主題發生變化時，會廣播所有的觀察者，然後由觀察者來獲取相應的數據。
• 推模型：這個方式重心在主題上，當主題發生變化時，主題將根據觀察者的需要將自身的變化推送給需要的觀察者。

觀察者模式的優點：

• 觀察者模式中彼此交互的對象都是保持松耦合的。主題對觀察者唯一的瞭解就是觀察者實現的“通知”介面，除此之外它們之間都是互不影響且獨立存在的，可以根據需要對自身作出修改。
• 可以隨時添加或刪除觀察者。
• 這種模式下，可以在很少甚至不修改主題或觀察者的情況下進行對象之間高效的數據發送。

其他註意點：

• 觀察者模式中是可以有多個主題和多個觀察者之間的對應關係的，但是一定要弄清楚它們之間的關係以及變化，不然就會變得非常複雜。
• 一般情況是由主題來觸發“通知”方法的，但是在特殊情況下也可以由觀察者來觸發“通知”方法。

簡單示例：

from abc import ABCMeta, abstractmethod


class Publisher:
    """被觀察者：發佈/訂閱關係中的發佈對象"""
    def __init__(self):
        self.subscribers = []
        self.latest_content = None

    def set_content(self, content):
        """有新消息時，發佈新的消息"""
        self.latest_content = content
        self.publish()

    def get_latest_content(self):
        """獲取最新的消息"""
        return self.latest_content

    def register(self, subscriber):
        """註冊一個新的訂閱者"""
        self.subscribers.append(subscriber)

    def publish(self):
        """發佈消息並通知訂閱的用戶"""
        for subscriber in self.subscribers:
            subscriber.notify()


class Subscriber(metaclass=ABCMeta):
    """觀察者的抽象類：需要定義一個通知介面，用於發佈對象通知訂閱的用戶"""
    @abstractmethod
    def notify(self):
        pass


class SubscriberA(Subscriber):
    """觀察者A：發佈/訂閱關係中的訂閱者，當訂閱的發佈者有新的變化或動態的時候能及時收到通知"""
    def __init__(self):
        self.my_publisher = None

    def subscribe(self, publisher):
        """訂閱併進行註冊"""
        self.my_publisher = publisher
        self.my_publisher.register(self)

    def notify(self):
        """獲取最新消息"""
        latest_content = self.my_publisher.get_latest_content()
        print(self, latest_content)


class SubscriberB(Subscriber):
    """觀察者B：發佈/訂閱關係中的訂閱者，當訂閱的發佈者有新的變化或動態的時候能及時收到通知"""
    def __init__(self):
        self.my_publisher = None

    def subscribe(self, publisher):
        """訂閱併進行註冊"""
        self.my_publisher = publisher
        self.my_publisher.register(self)

    def notify(self):
        """獲取最新消息"""
        latest_content = self.my_publisher.get_latest_content()
        print(self, latest_content)


if __name__ == '__main__':
    new_publisher = Publisher()
    subscriber_a = SubscriberA()
    subscriber_a.subscribe(new_publisher)
    subscriber_b = SubscriberB()
    subscriber_b.subscribe(new_publisher)
    new_publisher.set_content('This is a new message!')