快捷導(dǎo)航

Python筆記之觀察者模式

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

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

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

觀察者模式中的三個(gè)角色：

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

主題的兩種通知方式：

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

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

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

其他注意點(diǎn)：

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

簡(jiǎn)單示例：

from abc import ABCMeta, abstractmethod


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

  def set_content(self, content):
    """有新消息時(shí)，發(fā)布新的消息"""
    self.latest_content = content
    self.publish()

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

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

  def publish(self):
    """發(fā)布消息并通知訂閱的用戶"""
    for subscriber in self.subscribers:
      subscriber.notify()


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


class SubscriberA(Subscriber):
  """觀察者A：發(fā)布/訂閱關(guān)系中的訂閱者，當(dāng)訂閱的發(fā)布者有新的變化或動(dòng)態(tài)的時(shí)候能及時(shí)收到通知"""
  def __init__(self):
    self.my_publisher = None

  def subscribe(self, publisher):
    """訂閱并進(jìn)行注冊(cè)"""
    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ā)布者有新的變化或動(dòng)態(tài)的時(shí)候能及時(shí)收到通知"""
  def __init__(self):
    self.my_publisher = None

  def subscribe(self, publisher):
    """訂閱并進(jìn)行注冊(cè)"""
    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!')

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

您可能感興趣的文章: