快捷導(dǎo)航

Python設(shè)計(jì)模式之觀察者模式實(shí)例

更新時(shí)間：2014年04月26日 11:23:09 作者：

這篇文章主要介紹了設(shè)計(jì)模式中的觀察者模式Python實(shí)例,需要的朋友可以參考下

關(guān)于設(shè)計(jì)模式中的觀察者模式，定義如下（維基百科）：

觀察者模式（有時(shí)又被稱為發(fā)布/訂閱模式）是軟體設(shè)計(jì)模式的一種。在此種模式中，一個(gè)目標(biāo)物件管理所有相依於它的觀察者物件，並且在它本身的狀態(tài)改變時(shí)主動(dòng)發(fā)出通知。這通常透過呼叫各觀察者所提供的方法來實(shí)現(xiàn)。此種模式通常被用來實(shí)作事件處理系統(tǒng)。
簡(jiǎn)單來說，一個(gè)被觀察者有很多觀察者，被觀察者的狀態(tài)的改變會(huì)引起所有觀察者的響應(yīng)操作。

那么我們用Python2.7來實(shí)現(xiàn)觀察者模式。

Python中的集合set

集合（set），類似于列表（list），但是它沒有重復(fù)的元素，它的doc內(nèi)容如下：

復(fù)制代碼代碼如下:

>>> print set.__doc__
set() -> new empty set object
set(iterable) -> new set object

Build an unordered collection of unique elements.

下面是在ipython中進(jìn)行的幾個(gè)簡(jiǎn)單的集合操作。

復(fù)制代碼代碼如下:

In [1]: myset = set()

In [2]: myset.add(1)

In [3]: myset.add(2)

In [4]: myset.add('s')

In [5]: print myset
set([1, 2, 's'])

In [6]: myset.add('s')

In [7]: print myset
set([1, 2, 's'])

In [8]: myset.remove(3)
---------------------------------------------------------------------------
KeyError Traceback (most recent call last)
<ipython-input-8-a93073f8a2af> in <module>()
----> 1 myset.remove(3)

KeyError: 3

In [9]: myset.remove(1)

In [10]: print myset
set([2, 's'])

通過內(nèi)置的set()可以產(chǎn)生一個(gè)空的集合對(duì)象，也可以在set中傳入一些參數(shù)，例如一個(gè)列表：

復(fù)制代碼代碼如下:

>>> print set([1,2,3,3])
set([1, 2, 3])

最常用的方法就是add和remove了，更多內(nèi)容可以參考http://docs.python.org/2/library/stdtypes.html#set。

一個(gè)簡(jiǎn)單的觀察者模式的實(shí)現(xiàn)

復(fù)制代碼代碼如下:

class Observer(object):
    def __init__(self, s):
        self.s = s
    def update(self):
        print self.s

if __name__ == '__main__':
    foo01 = Observer("hi, i am foo01")
    foo02 = Observer("hi, i am foo02")
    observers = set()
    observers.add(foo01)
    observers.add(foo01)
    observers.add(foo02)
    print observers
    for ob in observers:
        ob.update()

下面是運(yùn)行結(jié)果：

復(fù)制代碼代碼如下:

set([<__main__.Observer object at 0xb74627cc>, <__main__.Observer object at 0xb74627ec>])
hi, i am foo01
hi, i am foo02

運(yùn)行結(jié)果中第一行是集合observers的內(nèi)容，其包含了兩個(gè)Observer實(shí)例，這些實(shí)例所處的內(nèi)存地址在每次運(yùn)行時(shí)可能有不同。而

復(fù)制代碼代碼如下:

for ob in observers:
    ob.update()

就可以看成多個(gè)觀察者產(chǎn)生響應(yīng)。

當(dāng)然，這種實(shí)現(xiàn)并不好——被觀察者也應(yīng)該是一個(gè)實(shí)例。

更加完善的觀察者模式實(shí)現(xiàn)

復(fù)制代碼代碼如下:

class ObserverInterface(object):
    def __init__(self):
        pass
    def update(self):
        pass

class SubjectInterface(object):
    def __init__(self):
        self.observers = set()
    def addObserver(self, ob):
        self.observers.add(ob)
    def delObserver(self, ob):
        self.observers.remove(ob)
    def notifyObservers(self):
        for ob in self.observers:
            ob.update()

class Observer01(ObserverInterface):
    def __init__(self, s):
        self.s = s
    def update(self):
        print self.s

class Observer02(ObserverInterface):
    def __init__(self, num1, num2):
        self.num1 = num1
        self.num2 = num2
    def update(self):
        print self.num1 + self.num2

class Subject01(SubjectInterface):
def __init__(self):
SubjectInterface.__init__(self)

if __name__ == '__main__':
    ob01 = Observer01("hi, i am ob01")
    ob02 = Observer02("hello,","i am ob02")
    observers = set()
    sb01 = Subject01()
    sb01.addObserver(ob01)
    sb01.addObserver(ob02)
    sb01.notifyObservers()

運(yùn)行結(jié)果如下：

復(fù)制代碼代碼如下: