文档章节

设计模式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
06/24
0
0
设计模式已经陨落了?

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

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

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

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

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

lxq_xsyu
2017/11/02
0
0
Ubuntu中vi卸载与安装/使用模式

Ubuntu中安装的vi是vim-common版本,与centos系统中vi使用方式不同,编辑使用不惯, 遂卸载重装,卸载命令:sudo apt-get remove vim-common 卸载完毕后重新安装;输入命令:sudo apt-get in...

唐十三郎
11/27
0
0

没有更多内容

加载失败,请刷新页面

加载更多

OSChina 周三乱弹 —— 有一天考拉麻麻拉肚子了

Osc乱弹歌单(2018)请戳(这里) 【今日歌曲】 @瘟神灬念 :分享周汇洋的单曲《Man Srae(曼斯拉之舞)》:美滋滋。。。。 手机党少年们想听歌,请使劲儿戳(这里) 我听了一下 赶紧关了, ...

小小编辑
22分钟前
4
0
oh-my-zsh 自定义

GitHub 地址 基于 oh-my-zsh 的自定义配置,增加了一些个人常用插件与皮肤。 采用的是 git submodule 来维护,包括 oh-my-zsh,之所以这么搞,主要是手头有多台 linux 需要维护, 每台机器、...

郁也风
今天
6
0
Docker安装踩坑:E_FAIL 0x80004005的解决

参考 菜鸟教程--Windows Docker 安装 http://www.runoob.com/docker/windows-docker-install.html 官方文档-Install Docker Toolbox on Windows https://docs.docker.com/toolbox/toolbox_in......

karma123
今天
5
0
js垃圾回收机制和引起内存泄漏的操作

JS的垃圾回收机制了解吗? Js具有自动垃圾回收机制。垃圾收集器会按照固定的时间间隔周期性的执行。 JS中最常见的垃圾回收方式是标记清除。 工作原理:是当变量进入环境时,将这个变量标记为“...

Jack088
昨天
18
0
大数据教程(10.1)倒排索引建立

前面博主介绍了sql中join功能的大数据实现,本节将继续为小伙伴们分享倒排索引的建立。 一、需求 在很多项目中,我们需要对我们的文档建立索引(如:论坛帖子);我们需要记录某个词在各个文...

em_aaron
昨天
27
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部