Python中觀察者模式如何實(shí)現(xiàn)

這篇文章給大家分享的是有關(guān)Python中觀察者模式如何實(shí)現(xiàn)的內(nèi)容。小編覺得挺實(shí)用的，因此分享給大家做個(gè)參考，一起跟隨小編過來看看吧。

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

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

• 主題：即觀察者觀察的對(duì)象，一般是需要有注冊(cè)和注銷方法，用來添加觀察者和刪除觀察者。

• 觀察者基類：這個(gè)類主要是需要定義一個(gè)接口，以便主題發(fā)生變化時(shí)可以得到對(duì)應(yīng)的通知信息。

• 觀察者：這個(gè)類需要具體實(shí)現(xiàn)基類中的“通知”接口，以便和主題的變化保持同步。
  

主題的兩種通知方式：

• 拉模型：這個(gè)方式重心在觀察者上，當(dāng)主題發(fā)生變化時(shí)，會(huì)廣播所有的觀察者，然后由觀察者來獲取相應(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ù)雜。

• 一般情況是由主題來觸發(fā)“通知”方法的，但是在特殊情況下也可以由觀察者來觸發(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):
  """觀察者的抽象類：需要定義一個(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!')

感謝各位的閱讀！關(guān)于“Python中觀察者模式如何實(shí)現(xiàn)”這篇文章就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，讓大家可以學(xué)到更多知識(shí)，如果覺得文章不錯(cuò)，可以把它分享出去讓更多的人看到吧！