观察者模式定义了对象间的一种一对多的依赖关系，当一个对象(主题)的状态发生改变时，则所有依赖于它的对象(观察者)都会得到通知并被自动更新。

2.6.2 观察者模式与发布订阅模式

观察者模式解决了被观察者对象和观察者对象的紧耦合问题，也即，如果不使用观察者模式，通常的实现是将状态耦合在观察者对象的内部。

发布订阅模式是对观察者模式的推广，在主题和观察者之间引入了一个中间层。有了中间层以后，主题的状态一旦变更，消息被直接发送给中间层，而非观察者。在实际开发中，通常使用消息队列来做发布订阅模式中的中间层。

2.6.3 适用场景

当对象的行为依赖于目标对象的状态时,就应当使用观察者模式，以微信公众号为例：微信用户关注了某公众号，当公众号推文时，系统会自动通知所有用户去阅读。观察者模式的具体实现可参考下小节的源码实现。

2.6.4 源码实现

# __author__ = 薯条老师，微信公众号：薯条编程

"""
观察者模式定义了对象间的一种一对多的依赖关系。
观察者的四种角色：
(1) Subject：抽象主题类 ，用来提供添加。删除，通知观察者的抽象接口
(2) Concrete Subject：具体的主题子类，用来实现抽象主题中的抽象接口
(3) Observer：抽象观察者类 ，用来定义一个抽象的行为
(4) Concrete Observer：具体的观察者子类，实现抽象观察者的抽象接口，当主题状态变更时，
会自动调用该接口
"""

import abc
"""
(1) 定义一个名为公众号的抽象主题类,该抽象基类包含三个抽象接口：
add_user:添加已关注的用户
notify: 状态变更时，通知所有已关注的用户阅读  
"""

class OfficialAccount(abc.ABC):
    @abc.abstractmethod
    def add_user(self, user):
        pass
        
        
    @abc.abstractmethod
    def notify(self):
        pass

                
"""
(2) 定义一个名为微信公众号的主题子类
"""
class WechatOfficialAccount(OfficialAccount):
    def __init__(self):
        self.__users = []
        self.__message = None
        
        
    def add_user(self, user):
        self.__users.append(user)
        
        
    def notify(self):
        if self.__message is not None:
            [user.read(self.__message) for user in self.__users]
            
            
    def push(self, message):
        self.__message = message
        self.notify()
        self.__message = None
        
        
"""
(3) 定义一个抽象观察者类User,该抽象基类包含一个抽象接口：
read: 阅读推文
"""
class User(abc.ABC):
    @abc.abstractmethod
    def read(self, message):
        pass
        
        
"""
(4) 定义一个具体观察者子类WechatUser
"""
class WechatUser(User):
    def __init__(self, name):
        self.__name = name
        
        
    def read(self, message):
        print("{} received message:{}".format(self.__name, message))
        
        
if __name__ == "__main__":
    wechatOfficialAccount = WechatOfficialAccount()
    kitty = WechatUser("kitty")
    lisa = WechatUser("Lisa")
    wechatOfficialAccount.add_user(kitty)
    wechatOfficialAccount.add_user(lisa)
    wechatOfficialAccount.push("欢迎来到单身狗俱乐部")

扫码免费领取Python学习资料：