1. 程式人生 > 程式設計 >Python筆記之觀察者模式

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,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!')

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支援我們。