Python版设计模式之监听者模式

监听模式

又名观察者模式、发布/订阅模式、源-监听器（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")