快捷導(dǎo)航

Python筆記之觀察者模式

更新時間：2019年11月20日 08:38:27 作者：谷雨yun

這篇文章主要為大家詳細(xì)介紹了Python筆記之觀察者模式，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價值，感興趣的小伙伴們可以參考一下

觀察者模式中的主題對象一般存在著一個其他服務(wù)依賴的核心服務(wù)，并且維護著其他依賴此核心服務(wù)的對象列表（即觀察者或監(jiān)視者列表），當(dāng)主題對象發(fā)生變化時，觀察者應(yīng)該改變自己的狀態(tài)或者進行某些操作

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

主題：即觀察者觀察的對象，一般是需要有注冊和注銷方法，用來添加觀察者和刪除觀察者。
觀察者基類：這個類主要是需要定義一個接口，以便主題發(fā)生變化時可以得到對應(yīng)的通知信息。
觀察者：這個類需要具體實現(xiàn)基類中的“通知”接口，以便和主題的變化保持同步。

主題的兩種通知方式：

拉模型：這個方式重心在觀察者上，當(dāng)主題發(fā)生變化時，會廣播所有的觀察者，然后由觀察者來獲取相應(yīng)的數(shù)據(jù)。
推模型：這個方式重心在主題上，當(dāng)主題發(fā)生變化時，主題將根據(jù)觀察者的需要將自身的變化推送給需要的觀察者。

觀察者模式的優(yōu)點：

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

其他注意點：

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

簡單示例：

from abc import ABCMeta, abstractmethod


class Publisher:
  """被觀察者：發(fā)布/訂閱關(guān)系中的發(fā)布對象"""
  def __init__(self):
    self.subscribers = []
    self.latest_content = None

  def set_content(self, content):
    """有新消息時，發(fā)布新的消息"""
    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):
    """發(fā)布消息并通知訂閱的用戶"""
    for subscriber in self.subscribers:
      subscriber.notify()


class Subscriber(metaclass=ABCMeta):
  """觀察者的抽象類：需要定義一個通知接口，用于發(fā)布對象通知訂閱的用戶"""
  @abstractmethod
  def notify(self):
    pass


class SubscriberA(Subscriber):
  """觀察者A：發(fā)布/訂閱關(guān)系中的訂閱者，當(dāng)訂閱的發(fā)布者有新的變化或動態(tài)的時候能及時收到通知"""
  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：發(fā)布/訂閱關(guān)系中的訂閱者，當(dāng)訂閱的發(fā)布者有新的變化或動態(tài)的時候能及時收到通知"""
  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!')

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: