共计 1630 个字符，预计需要花费 5 分钟才能阅读完成。
监听模式
又名观察者模式、发布 / 订阅模式、源 - 监听器（Source/Listener）模式，模式的核心是：设计时要区分谁是被观察者，谁是观察者。被观察者至少有三个方法，添加观察者、删除观察者、监听目标变化并通知观察者；观察者这至少包含一个方法，当接收到被观察者的通知时，做出相应的处理（即在被观察者的监听中调用）。
模式框架
”’
观察者模式
”’
class Observable(object):
”’
被监听的对象，实现类需要具体增加被监听的资源
”’
def __init__(self):
self.__observers = []
@property
def observers(self):
return self.__observers
def has_observer(self):
return False if not self.__observers else True
def add_observer(self, observer):
self.__observers.append(observer)
def remove_observer(self, observer):
self.__observers.remove(observer)
def listener(self, obj=None):
for observer in self.__observers:
observer.update(self, obj)
class Observer(object):
”’
观察者，当观察的对象发生变化时，依据变化情况增加处理逻辑
”’
def update(self, observable, obj):
pass
UML 图
示例
”’
基于观察者模式，实现一个简单的消息队列，当队列中有消息时，将消息发送给监听者
”’
class MyQueue(Observable):
def __init__(self):
super().__init__()
self.__resource = []
def has_message(self):
return True if self.__resource else False
def queue_size(self):
return len(self.__resource)
def add_resource(self, res):
self.__resource.append(res)
print(“ 新消息进入，推送 …”)
self.listener(obj=res)
class MySubOdd(Observer):
def update(self, observable, obj):
if isinstance(observable, MyQueue) and int(obj) % 2 != 0:
print(“I’m MySubOdd, Get Message {} from MyQueue.”.format(obj))
class MySubEven(Observer):
def update(self, observable, obj):
if isinstance(observable, MyQueue) and int(obj) % 2 == 0:
print(“I’m MySubEven, Get Message {} from MyQueue.”.format(obj))
if __name__ == “__main__”:
my_queue = MyQueue() # 初始化一个队列
my_sub_odd = MySubOdd() # 初始化奇数监听者
my_sub_even = MySubEven() # 初始化偶数监听者
# 将两个监听者加入监听队列
my_queue.add_observer(my_sub_odd)
my_queue.add_observer(my_sub_even)
# 添加资源进队列
my_queue.add_resource(“1”)
my_queue.add_resource(“3”)
my_queue.add_resource(“2”)
my_queue.add_resource(“4”)
