文档章节

设计模式02观察者模式

AllenOR灵感
 AllenOR灵感
发布于 2017/09/10 01:17
字数 477
阅读 1
收藏 0

代码

# -.- coding:utf-8 -.-
# __author__ == 'zhengtong'
from __future__ import print_function


def exception_wrapper(func):
    def wrapper(self, *args, **kwargs):
        try:
            result = func(self, *args, **kwargs)
            if result is not None:
                return result
        except Exception:
            import sys, traceback
            ex_type, ex, tb = sys.exc_info()
            traceback.print_exception(ex_type, ex, tb)
            return False
        return True
    return wrapper


class Producer(object):

    def __init__(self):
        self.topic = {}

    @exception_wrapper
    def create_topic(self, topic):
        if topic not in self.topic:
            self.topic[topic] = []

    @exception_wrapper
    def publish(self, topic, data):
        self.create_topic(topic)
        if not self.topic[topic]:
            return '当前主题没有任何观察者/订阅者/消费者'
        self.notify_observers(topic, data)

    @exception_wrapper
    def subscribe(self, topic, *observers):
        self.create_topic(topic)
        for observer in observers:
            if observer not in self.topic[topic]:
                self.topic[topic].append(observer)

    @exception_wrapper
    def unsubscribe(self, topic, *observers):
        l = self.topic[topic]
        for observer in observers:
            l.pop(l.index(observer))

    @exception_wrapper
    def notify_observers(self, topic, data):
        for observer in self.topic[topic]:
            observer.get_message(data)


class SendMailObserver(object):

    def get_message(self, data):
        print('send mail to: ', data)


class WriteMailObserver(object):

    def get_message(self, data):
        print('write mail to: ', data)


class ProcessMailObserver(object):

    def get_message(self, data):
        print('ProcessMail mail: ', data)

if __name__ == '__main__':
    # 启动Producer服务
    producer = Producer()

    # 创建主题
    producer.create_topic('sss')
    producer.create_topic('bbb')

    # 注册观察者/订阅者/消费者
    send_mail_observer = SendMailObserver()
    write_mail_observer = WriteMailObserver()
    Process_mail_observer = ProcessMailObserver()
    producer.subscribe('send_mail', *[send_mail_observer,
                                      write_mail_observer,
                                      Process_mail_observer])

    # 查看每个队列有多少的consumer
    print('producer.topic: ', producer.topic)

    # 发布消息
    producer.publish('send_mail', '330356463@qq.com')

    # 移除观察者/订阅者/消费者
    producer.unsubscribe('send_mail', write_mail_observer)

    # 查看每个队列有多少的consumer
    print(producer.topic)

    # 查看现在总共有几个频道
    print(producer.topic.keys())


# 显示结果
producer.topic:  {'bbb': [], 'sss': [], 'send_mail': [<__main__.SendMailObserver object at 0x03492F50>, <__main__.WriteMailObserver object at 0x03492F70>, <__main__.ProcessMailObserver object at 0x03492F90>]}
send mail to:  330356463@qq.com
write mail to:  330356463@qq.com
ProcessMail mail:  330356463@qq.com
{'bbb': [], 'sss': [], 'send_mail': [<__main__.SendMailObserver object at 0x03492F50>, <__main__.ProcessMailObserver object at 0x03492F90>]}
['bbb', 'sss', 'send_mail']

 
 

模式总结

观察者模式强调的是松耦合,通过程序之间的强约定弱依赖实现通用场景的<发布/订阅>模型。

核心理念

当数据发生变化时执行回调函数(provide a callback for notification of events/changes to data).

模式类型

行为模式

设计原则
  1. 为了交互对象之间的松耦合设计而努力。

参考

本文转载自:http://www.jianshu.com/p/3ebf68fc0960

AllenOR灵感
粉丝 11
博文 2635
码字总数 83001
作品 0
程序员
私信 提问
【设计模式笔记】(十六)- 代理模式

一、简述 代理模式(Proxy Pattern),为其他对象提供一个代理,并由代理对象控制原有对象的引用;也称为委托模式。 其实代理模式无论是在日常开发还是设计模式中,基本随处可见,中介者模式中...

MrTrying
2018/06/24
0
0
设计模式已经陨落了?

你现在是坐在一个程序员旁边吗?如果是的话,那么在你读下面的段落之前,有一个简单的实验。让他们到一边去,问问他们两个问题并记录下答案。首先问他们“什么是设计模式?”然后再问“说出你...

oschina
2014/03/11
9.5K
69
《PHP设计模式大全》系列分享专栏

《PHP设计模式大全》已整理成PDF文档,点击可直接下载至本地查阅 https://www.webfalse.com/read/201739.html 文章 php设计模式介绍之编程惯用法第1/3页 php设计模式介绍之值对象模式第1/5页...

kaixin_code
2018/11/06
184
0
设计模式梳理(一)

设计模式梳理(一) 总体来说设计模式分为三大类: @案例源码地址:https://gitlab.com/lxqxsyu/DisgnPattern 创建型模式 简单工厂模式 工厂类是整个模式的关键。它包含必要的判断逻辑,能够...

lxq_xsyu
2017/11/02
0
0
JavaScript 的一些设计模式

设计模式的定义:在面向对象软件设计过程中针对特定问题的简洁而优雅的解决方案 设计模式是前人解决某个特定场景下对而总结出来的一些解决方案。可能刚开始接触编程还没有什么经验的时候,会...

格西南
08/20
0
0

没有更多内容

加载失败,请刷新页面

加载更多

QML学习之浅谈Window

转载地址:http://blog.csdn.net/kanchuan1905/article/details/53762788 在Qt Quick的世界里,Window对象用于创建一个与操作系统相关的顶层窗口,包含了如Text, Rectangle, Image等元素。W...

shzwork
27分钟前
5
0
centos 查看删除旧内核

1、查看系统中安装的内核 $ yum list installed | grep kernel 2、删除系统中旧内核 $ yum install yum-utils$ package-cleanup --oldkernels --count=2...

编程老陆
今天
10
0
ES6

ES6:不改变原理的基础上,让API变得更简单 一、let:代替var用于声明变量 1、var的缺点: (1)声明提前 (2)没有块级作用域 2、let的优点: (1)组织了申明提前 (2)让let所在的块({}),...

wytao1995
今天
3
0
kubernetes 环境搭建 —— minikube

创建集群 minikube start 搭建好 k8s 集群后,可以查看集群的状态以及部署应用。主要用到的是 k8s 的 api,这通常需借助于 kutectl 命令行工具 基本操作 kubectl versionkubectl cluster-i...

lemos
今天
11
0
关于js混淆与反混淆还原操作

使用js的混淆加密,其目的是为了保护我们的前端代码逻辑,对应一些搞技术吃饭的公司来说,为了防止被竞争对手抓取或使用自己的代码,就会考虑如何加密,或者混淆js来达到代码保护。 1、为什么...

开源oschina
今天
12
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部