快捷導(dǎo)航

Python筆記之觀察者模式

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

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

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

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

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

主題的兩種通知方式：

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

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

觀察者模式中彼此交互的對象都是保持松耦合的。主題對觀察者唯一的了解就是觀察者實現(xiàn)的“通知”接口，除此之外它們之間都是互不影響且獨立存在的，可以根據(jù)需要對自身作出修改。
可以隨時添加或刪除觀察者。
這種模式下，可以在很少甚至不修改主題或觀察者的情況下進(jìn)行對象之間高效的數(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):
    """訂閱并進(jìn)行注冊"""
    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):
    """訂閱并進(jìn)行注冊"""
    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í)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: