zoukankan      html  css  js  c++  java
  • python 设计模式之观察者模式

    观察者模式是一个软件设计模式,一个主题对象博包涵一系列依赖他的观察者,自动通知观察者的主题对象的改变,通常会调用每个观察者的一个方法。这个设计模式非常适用于分布式事件处理系统。

    典型的在观察者模式下:

    1.发布者类应该包涵如下方法:

    • 注册能够接收通知的对象
    • 从主对象到注册对象,通知任何变化
    • 未注册对象不能够接收任何通知信息

    2.订购者类应该包涵如下:

    •        发布者会调用一个订购者提供的方法,将任何改变告知注册对象。

     3.当一个事件会触发了状态的改变,发表者会调用通知方法

    总结:订阅者可以在发布对象中注册或者不注册,如此无论什么事件发生,都会触发发布者通过调用通知方法,去通知订购者。这个通知只会在事件发生的时候,去通知已经注册的订购者。

    一个简单的python实现:

     让我们实现一个不同用户在TechForum 上发布技术邮件的例子,当任何用户发布一个新的邮件,其他用户就会接收到新邮件通知。从对象的角度去看,我们应该有一个 TechForum对象,我们需要有另外一些需要用户对象在TechForum上注册,当新邮件通知的时候,应该发送邮件标题。

    一个简单的例子分析会联想到中介机构和雇主的关系。这就是招聘者和应聘者关系的延伸。通过一个工作中介会发布不同种类的工作信息,应聘者会去寻找相关的工作信息,招聘者也会寻找在中介注册过的应聘者。

    代码如下:

     1 classPublisher:
     2     def__init__(self):
     3         pass
     4 
     5     defregister(self):
     6         pass
     7 
     8     defunregister(self):
     9         pass
    10 
    11     defnotifyAll(self):
    12         pass
    13 
    14 classTechForum(Publisher):
    15     def__init__(self):
    16         self._listOfUsers = []
    17         self.postname = None
    18     defregister(self, userObj):
    19         if userObj notin self._listOfUsers:
    20                 self._listOfUsers.append(userObj)
    21 
    22     defunregister(self, userObj):
    23         self._listOfUsers.remove(userObj)
    24 
    25     defnotifyAll(self):
    26         for objects in self._listOfUsers:
    27             objects.notify(self.postname)
    28 
    29     defwriteNewPost(self , postname):
    30         self.postname = postname
    31         self.notifyAll()
    32 
    33 
    34 classSubscriber:
    35     def__init__(self):
    36         pass
    37 
    38     defnotify(self):
    39         pass
    40 
    41 
    42 classUser1(Subscriber):
    43     defnotify(self, postname):
    44         print"User1 notified of a new post %s" % postname
    45 
    46 
    47 classUser2(Subscriber):
    48     defnotify(self, postname):
    49         print"User2 notified of a new post %s" % postname
    50 
    51 
    52 classSisterSites(Subscriber):
    53     def__init__(self):
    54         self._sisterWebsites = ["Site1" , "Site2", "Site3"]
    55 
    56     defnotify(self, postname):
    57         for site in self._sisterWebsites:
    58                 print"Send nofication to site:%s " % site
    59 
    60 
    61 
    62 if __name__ == "__main__":
    63     techForum = TechForum()
    64 
    65     user1 = User1()
    66     user2 = User2()
    67     sites = SisterSites()
    68 
    69     techForum.register(user1)
    70     techForum.register(user2)
    71     techForum.register(sites)
    72 
    73 
    74     techForum.writeNewPost("Observe Pattern in Python")
    75 
    76     techForum.unregister(user2)
    77 
    78     techForum.writeNewPost("MVC Pattern in Python")
    View Code
  • 相关阅读:
    第19章_枚举:
    第14章_类型信息:
    第13章_字符串:
    纯css背景图自适应
    事务隔离机制_悲观锁_乐观锁
    hibernate 缓存
    list 和 iterate
    hibernate 性能优化之 1+N 问题
    QBC(Query By Criteria) QBE (Query By Example)
    HQL(Hibernate Query Language)
  • 原文地址:https://www.cnblogs.com/lizhitai/p/4459126.html
Copyright © 2011-2022 走看看