python实现观察者模式

　　有时，我们希望在一个对象的状态改变时更新另外一组对象。在MVC模式中有这样一个非

常常见的例子，假设在两个视图（例如，一个饼图和一个电子表格）中使用同一个模型的数据，

无论何时更改了模型，都需要更新两个视图。这就是观察者设计模式要处理的问题（请参考

［Eckel08，第213页］）。

　　观察者模式描述单个对象（发布者，又称为主持者或可观察者）与一个或多个对象（订阅者，

又称为观察者）之间的发布 — 订阅关系。在MVC例子中，发布者是模型，订阅者是视图。然而，

MVC并非是仅有的发布 — 订阅例子。信息聚合订阅（比如，RSS或Atom）是另一种例子。许多读

者通常会使用一个信息聚合阅读器订阅信息流，每当增加一条新信息时，他们就能自动地获取到

更新。

　　观察者模式背后的思想等同于MVC和关注点分离原则背后的思想，即降低发布者与订阅者

之间的耦合度，从而易于在运行时添加/删除订阅者。此外，发布者不关心它的订阅者是谁。它

只是将通知发送给所有订阅者（请参考［GOF95，第327页］）。

#  observers存储观察者

#   add()方法注册一个新的观察者

#   remove()方法注销一个已有的观察者

#   notify() 方法则在变化发生时通知所有观察者。

class Publisher:

    def __init__(self):

        self.observers = []

    def add(self, observer):

        if observer not in self.observers:

            self.observers.append(observer)

        else:

             print('Failed to add: {}'.format(observer))

    def remove(self, observer):

        try:

             self.observers.remove(observer)

        except ValueError:

            print('Failed to remove: {}'.format(observer))

    def notify(self):

            [o.notify(self) for o in self.observers]

#   __str__() 方法返回关于发布者名称和 _data 值的信息。

#   第一个使用 @property 修饰器来提供 _data 变量的读访问方式。这样，我们就能使用 object.data 来替代 object.data() 。

#   第二个 data() 更有意思。它使用了 @setter 修饰器，该修饰器会在每次使用赋值操作符（ = ） 为 _data 变量赋新值时被调用。

class DefaultFormatter(Publisher):

    def __init__(self, name):

        Publisher.__init__(self)

        self.name = name

        self._data = 0

    def __str__(self):

        return "{}: '{}' has data = {}".format(type(self).__name__, self.name,self._data)

    @property

    def data(self):

        return self._data

    @data.setter

    def data(self, new_value):

        try:

            self._data = int(new_value)

        except ValueError as e:

            print('Error: {}'.format(e))

        else:

            print("修改了")

            self.notify()

#   下一步是添加观察者。 HexFormatter 和 BinaryFormatter 的功能非常相似。唯一的不同

#   在于如何格式化从发布者那获取到的数据值，即分别以十六进制和二进制进行格式化。

class HexFormatter:

    def notify(self, publisher):

        print("{}: '{}' has now hex data = {}".format(type(self).__name__,

        publisher.name, hex(publisher.data)))

class BinaryFormatter:

    def notify(self, publisher):

        print("{}: '{}' has now bin data = {}".format(type(self).__name__,

        publisher.name, bin(publisher.data)))

def main():

    df = DefaultFormatter('test1')

    hf = HexFormatter()

    bf = BinaryFormatter()

    #添加观察者

    df.add(hf)

    df.add(bf)

    #每次修改发布者的值，observers里面的观察者会调用notify()方法

    df.data = 1

    df.data = 10

    #当把某个观察者踢出observers，当修改发布者的data值就不会通知这个观察者

    df.remove(hf)

    df.data = 6

if __name__ == '__main__':

    main()