【Python设计模式】观察者模式

内容： 定义对象间的一种一对多的依赖关系，当一个对象的状态发生改变时， 所有依赖于它的对象都得到通知并被自动更新。观察者模式又称为“发布-订阅”模式角色： - 抽象主题（Subject) - 具体主题（ConcreteSubject） ————发布者 - 抽象观察者（Observer） - 具体观察者（ConcreteObserver） ————订阅者适用场景： - 当一个抽象模型有两个方面，其中一个方面依赖另一个方面。 将这两者封装在独立对象中以使它们可以各自独立地改变和复用。 - 当对一个对象的改变需要同时改变其它对象，而不知道具体有多少对象有待改变。 - 当一个对象必须通知其它对象，而它又不能假定其它对象是谁。换言之， 你不希望这些对象是紧密耦合的优点： - 目标和观察者之间的抽象耦合最不 - 支持广播通信

示例

from abc import ABCMeta, abstractmethod# ----------------------------------------------# 抽象观察者# ----------------------------------------------class Observer(metaclass=ABCMeta): @abstractmethod def update(self, _notice): pass# ----------------------------------------------# 抽象发布者# ----------------------------------------------class Notice: def __init__(self): self.observer = [] def attach(self, obs): """ 订阅 :param obs: 具体订阅者 """ self.observer.append(obs) def detach(self, obs): """ 取消订阅 :param obs: 具体订阅者 """ self.observer.remove(obs) def notify(self): """ 通知 """ for obs in self.observer: obs.update(self)# ----------------------------------------------# 具体发布者# ----------------------------------------------class StaffNotice(Notice): def __init__(self, company_info=None): super().__init__() self.__company_info = company_info @property def company_info(self): return self.__company_info @company_info.setter def company_info(self, info): self.__company_info = info self.notify() # 自动推送# ----------------------------------------------# 具体订阅者# ----------------------------------------------class Staff(Observer): def __init__(self): self.company_info = None def update(self, _notice): """ 更新 :param _notice: 发布者对象 """ self.company_info = _notice.company_info# ----------------------------------------------# client# ----------------------------------------------notice = StaffNotice("初始公司信息！")s1 = Staff()s2 = Staff()# 订阅print('----------------消息订阅----------------------')notice.attach(s1)notice.attach(s2)# 状态改变，自动通知notice.company_info = '公司今年业绩很好，给大家发奖金'print(s1.company_info)print(s2.company_info)# 取消订阅print('----------------取消订阅----------------------')notice.detach(s1)notice.company_info = '公司今年业绩不好，取消奖金发放'print(s1.company_info)print(s2.company_info)

运行结果