观察者模式

内容：定义对象间的一种一对多的依赖关系,当一个对象的状态发生改变时，所有依赖于它的对象都得到 通知并被自动更新。观察者模式又称“发布-订阅”模式

角色：

• 抽象主题 (Subject) 上具体主题(ConcreteSubject)——发布者
• 抽象观察者 (Observer)
• 具体观察者(ConcreteObserver）—订阅者

适用场景： 当一个抽象模型有两方面，其中一个方面依赖于另一个方面。将这两者封装在独立对象中以使它们可以各自独立地改变 和复用。 当对一个对象的改变需要同时改变其它对象，而不知道具体有多少对象有待改变。 当一个对象必须通知其它对象，而它又不能假定其它对象是谁。换言之，你不希望这些对象是紧密耦合的。

优点： 目标和观察者之间的抽象耦合最小 支持广播通信

观察者模式（Observer Pattern）是一种行为型设计模式，它定义了对象之间的一对多依赖关系，使得当一个对象改变状态时，它的所有依赖对象都会收到通知并自动更新。

观察者模式涉及以下几个角色：

1. 主题（Subject）：也称为被观察者或可观察对象，它维护一组观察者对象，并提供方法用于添加、删除和通知观察者。
2. 观察者（Observer）：定义了接收主题通知并进行相应更新的方法。
3. 具体主题（Concrete Subject）：实现了主题接口，维护了一组观察者对象，并在状态变化时发送通知给观察者。
4. 具体观察者（Concrete Observer）：实现了观察者接口，定义了接收通知并进行相应更新的具体行为。

当主题的状态发生变化时，它会通知所有注册的观察者，观察者接收到通知后进行相应的更新操作。

from abc import abstractmethod, ABCMeta


class Observer(metaclass=ABCMeta):

    def update(self, notices):
        pass


# 具体主题
class Notices:
    def __init__(self):
        self.observers = []

    def attach(self, observer):
        self.observers.append(observer)

    def detach(self, observer):
        self.observers.remove(observer)

    def notify(self):
        for observer in self.observers:
            observer.update(self)


# 观察者接口
class StaffNotice(Notices):

    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, notices):
        self.company_info = notices.company_info


notice = StaffNotice("初始化公司信息")
s1 = Staff()
s2 = Staff()
notice.attach(s1)
notice.attach(s2)
notice.company_info = "公司今年业绩很好"
print(s1.company_info)
print(s2.company_info)
notice.detach(s2)
notice.company_info = "公司明年业绩也很好"
print(s1.company_info)
print(s2.company_info)


# 主题接口
class Subject:
    def attach(self, observer):
        pass

    def detach(self, observer):
        pass

    def notify(self):
        pass


# 具体主题
class ConcreteSubject(Subject):
    def __init__(self):
        self.observers = []

    def attach(self, observer):
        self.observers.append(observer)

    def detach(self, observer):
        self.observers.remove(observer)

    def notify(self):
        for observer in self.observers:
            observer.update()


# 观察者接口
class Observer:
    def update(self):
        pass


# 具体观察者A
class ConcreteObserverA(Observer):
    def update(self):
        print("ConcreteObserverA 收到通知并进行更新")


# 具体观察者B
class ConcreteObserverB(Observer):
    def update(self):
        print("ConcreteObserverB 收到通知并进行更新")


# 客户端代码
subject = ConcreteSubject()
observerA = ConcreteObserverA()
observerB = ConcreteObserverB()

subject.attach(observerA)
subject.attach(observerB)

subject.notify()