如何阅读通知观察者_如何管理多个通知和观察者_阻止观察者收到通知 - 腾讯云开发者社区

通知观察者（Notification Observer）基础概念

通知观察者是一种设计模式，用于实现对象间的松耦合通信。在这种模式中，一个或多个观察者对象订阅另一个对象（称为主题或被观察者）的状态变化。当主题的状态发生变化时，它会通知所有已注册的观察者，从而触发相应的操作。

优势

松耦合：观察者和主题之间不需要直接依赖，只需要通过接口进行交互。
可扩展性：可以轻松添加新的观察者，而不需要修改主题的代码。
灵活性：观察者可以在运行时动态地注册或注销。

类型

同步通知：主题在状态变化后立即通知观察者。
异步通知：主题将通知放入队列中，观察者在稍后的时间点处理这些通知。
推模式：主题主动将状态变化推送给观察者。
拉模式：观察者主动从主题获取最新的状态。

应用场景

GUI事件处理：如按钮点击、窗口关闭等事件。
消息系统：如聊天应用中的消息推送。
数据更新：如数据库记录变更后的通知。
系统监控：如服务器状态变化时的报警通知。

如何阅读通知观察者

阅读通知观察者的关键在于理解其工作原理和实现细节。以下是一个简单的示例代码，展示了如何实现一个基本的通知观察者模式：

class Subject:
    def __init__(self):
        self._observers = []
        self._state = None

    def add_observer(self, observer):
        if observer not in self._observers:
            self._observers.append(observer)

    def remove_observer(self, observer):
        self._observers.remove(observer)

    def notify_observers(self):
        for observer in self._observers:
            observer.update(self._state)

    def set_state(self, state):
        self._state = state
        self.notify_observers()

class Observer:
    def update(self, state):
        raise NotImplementedError

class ConcreteObserver(Observer):
    def __init__(self, name):
        self.name = name

    def update(self, state):
        print(f"{self.name} received new state: {state}")

# 示例使用
subject = Subject()
observer1 = ConcreteObserver("Observer 1")
observer2 = ConcreteObserver("Observer 2")

subject.add_observer(observer1)
subject.add_observer(observer2)

subject.set_state("State 1")
subject.set_state("State 2")

subject.remove_observer(observer1)

subject.set_state("State 3")