python设计模式观察者模式

题目&＃xff1a;现在你有一个数字&＃xff0c;默认格式化程序是以十进制格式展示此数值&＃xff0c;但需要提供一个功能&＃xff0c;这个程序要支持添加/注册更多的格式化程序&＃xff08;比如&＃xff1a;添加一个十六进制格式化程序和一个二进制格式化程序&＃xff09;。每次数值更新时&＃xff0c;已注册的程序就会收到通知&＃xff0c;并显示更新后的值。

我们看下需求&＃xff1a;

NumberFormatter 有一个 number 属性
当 number 值修改时&＃xff0c;相关的格式化方式展示结果要改变
此系统必须可扩展已适应其他格式化方式的使用。

一个错误的实现可能是这样的&＃xff1a;

class NumberFormatter(object):def __init__(self, number):self.number &＃61; numberdef show_data(self):self.default_formatter()self.hex_formatter()self.binary_formatter()def default_formatter(self):passdef hex_formatter(self):passdef binary_formatter(self):pass

我们可以这么使用&＃xff1a;

number &＃61; NumberFormatter(10) number.show_data()

但是这样会有一个问题&＃xff1a;这种针对实现的编程会导致我们在增加或者删除需要格式化方式时必须修改代码。比如我们现在不再需要十六进制数字格式的显示&＃xff0c;就需要把 hex_formatter 相关的代码删除或者注释掉。

要解决这个问题&＃xff0c;就可以用到我们这次要介绍的观察者模式了。

什么是观察者模式

认识观察者模式

我们先看看报纸和杂志的订阅是怎么回事&＃xff1a;

报社的业务就是出版报纸
向某家报社订阅报纸&＃xff0c;只要他们有新报纸&＃xff0c;就会给你送来&＃xff0c;只要你是他们的订户&＃xff0c;你就会一直受到新报纸。
当你不再想看的时候&＃xff0c;取消订阅&＃xff0c;他们就不会在送新报纸给你
只要报社还在运营&＃xff0c;就会一直有人向他们订阅报纸或取消订阅。

我们用图表示一下&＃xff0c;这里出版者 改称为主题(Subject)&＃xff0c;订阅者改称为观察者(Observer)&＃xff1a;

1. 开始的时候&＃xff0c;鸭子对象不是观察者

2. 鸭子对象过来告诉主题&＃xff0c;它想当一个观察者&＃xff08;鸭子其实想说的是&＃xff1a;我对你的数据改变感兴趣&＃xff0c;一有变化请通知我&＃xff09;

3. 鸭子对象已经是观察者了&＃xff08;鸭子静候通知&＃xff0c;一旦接到通知&＃xff0c;就会得到一个整数&＃xff09;。

4. 主题有了新的数据&＃xff08;现在鸭子和其他所有观察者都会受到通知&＃xff1a;主题已经改变&＃xff09;

5. 老鼠对象要求从观察者中把自己除名&＃xff08;老鼠已经观察次主题太久&＃xff0c;决定不再当观察者了&＃xff09;。

6. 老鼠离开了&＃xff08;主题知道老鼠的请求后&＃xff0c;把它从观察者中移除了&＃xff09;。

7. 主题有了一个新的整数&＃xff08;除了老鼠之外&＃xff0c;每个观察者都会收到通知&＃xff0c;如果老鼠又想当观察者了&＃xff0c;它还可以再回来&＃xff09;

定义观察者模式

当你试图勾勒观察者模式时&＃xff0c;可以利用报纸订阅服务&＃xff0c;以及出版这和订阅者比你这一切。在程序设计中&＃xff0c;观察者模式通常被定义为&＃xff1a;

观察者模式定义了对象之间的一对多依赖&＃xff0c;这样一来&＃xff0c;当一个对象改变状态是&＃xff0c;它的所有依赖者都会收到通知并自动更新。

我们和之前的例子做个对比&＃xff1a;

主题和观察者定义了一对多的关系。观察者依赖于此主题&＃xff0c;只要主题状态一有变化&＃xff0c;观察者就会被通知。根据通知的风格&＃xff0c;观察者可能因此新值而更新。

现在你可能有疑问&＃xff0c;这和一对多的关系有何关联&＃xff1f;

利用观察者模式&＃xff0c;主题是具有状态的对象&＃xff0c;并且可以控制这些状态。也就是说&＃xff0c;有一个具有状态的主题。另一方面&＃xff0c;观察者使用这些状态&＃xff0c;虽然这些状态不属于他们。有许多观察者&＃xff0c;依赖主题告诉他们状态何时改变了。这就产生了一个关系&＃xff1a;一个主题对多个观察者的关系。

观察者和主题之间的依赖关系是如何产生的&＃xff1f;

主题是真正拥有数据的人&＃xff0c;观察者是主题的依赖者&＃xff0c;在数据变化时更新&＃xff0c;这样比起让许多对象控制同一份数据来&＃xff0c;可以得到更干净的 OO 设计。

观察者模式的应用案例

观察者模式在实际应用中有许多的案例&＃xff0c;比如信息的聚合。无论格式为 RSS、Atom 还是其它&＃xff0c;思想多事一样的&＃xff1a;你追随某个信息源&＃xff0c;当它每次更新时&＃xff0c;你都会收到关于更新的通知。
事件驱动系统是一个可以使用观察者模式的例子。在这种系统中&＃xff0c;监听者被用于监听特定的事件。监听者的事件被创建出来时就会触发它们。这个事件可以使键入某个特定的键、移动鼠标或者其他。事件扮演发布者的角色&＃xff0c;监听者则扮演观察者的角色。

Python 实现

现在&＃xff0c;让我们回到文章开始的那个问题。

这里我们可以实现一个基类 Publisher&＃xff0c;包括添加、删除及通知观察者这些公用功能。DefaultFormatter 类继承自 Publisher&＃xff0c;并添加格式化程序特定的功能。

文章开头问题的类图

Publisher 的代码如下&＃xff1a;

import itertools&＃39;&＃39;&＃39; 观察者模式实现 &＃39;&＃39;&＃39;class Publisher:def __init__(self):self.observers &＃61; set()def add(self, observer, *observers):for observer in itertools.chain((observer, ), observers):self.observers.add(observer)observer.update(self)def remove(self, observer):try:self.observers.discard(observer)except ValueError:print(&＃39;Failed to remove: {}&＃39;.format(observer))def notify(self):[observer.update(self) for observer in self.observers]

现在&＃xff0c;打算使用观察者模式的模型或类都应该继承 Publisher 类。该类用 set 来保存观察者对象。当用户向 Publisher 注册新的观察者对象时&＃xff0c;观察者的 update() 方法会执行&＃xff0c;这使得它能够用模型当前的状态初始化自己。模型状态发生变化时&＃xff0c;应该调用继承而来的 notify() 方法&＃xff0c;这样的话&＃xff0c;就会执行每个观察者对象的 update() 方法&＃xff0c;以确保他们都能反映出模型的最新状态。

add() 方法的写法值得注意&＃xff0c;这里是为了支持可以接受一个或多个观察者对象。这里我们采用了itertools.chain() 方法&＃xff0c;它可以接受任意数量的 iterable&＃xff0c;并返回单个iterable。遍历这个 iterable&＃xff0c;也就相当于依次遍历参数里的那些 iterable。

接下来是 DefaultFomatter 类。__init__() 做的第一件事就是调用基类的__init__() 方法&＃xff0c;因为这在 Python 中没法自动完成。DefaultFormatter 实例有自己的名字&＃xff0c;这样便于我们跟踪其状态。对于_data 变量&＃xff0c;我们使用了名称改编来声明不能直接访问该变量。DefaultFormatter 把_data 变量用作一个整数&＃xff0c;默认值为0。

class DefaultFormatter(Publisher):def __init__(self, name):Publisher.__init__(self)self.name &＃61; nameself._data &＃61; 0def __str__(self):return "{}: &＃39;{}&＃39; has data &＃61; {}".format(type(self).__name__, self.name, self._data)&＃64;propertydef data(self):return self._data&＃64;data.setterdef data(self, new_value):try:self._data &＃61; int(new_value)except ValueError as e:print(&＃39;Error: {}&＃39;.format(e))else:self.notify()

__str__() 方法返回关于发布者名称和 _data 值的信息。type(self).__name 是一种获取类名的方便技巧&＃xff0c;避免硬编码类名。&＃xff08;不过这会降低代码的可读性&＃xff09;
data() 方法有两个&＃xff0c;第一个使用了 &＃64;property 装饰器来提供_data 变量的读访问方式。这样&＃xff0c;我们就能使用 object.data 来代替 object._data。第二个 data() 方法使用了&＃64;setter 装饰器&＃xff0c;改装饰器会在每次使用赋值操作符(&＃61;)为_data 变量赋值时被调用。该方法也会尝试把新值强制转换为一个整数&＃xff0c;并在转换失败时处理异常。

接下来是添加观察者。HexFormatter 和 BinaryFormatter 功能基本相似。唯一的不同在于如何格式化从发布者那获取到的数据值&＃xff0c;即十六进制和二进制格式化。

class HexFormatter:def update(self, publisher):print("{}: &＃39;{}&＃39; has now hex data&＃61; {}".format(type(self).__name__,publisher.name, hex(publisher.data)))class BinaryFormatter:def update(self, publisher):print("{}: &＃39;{}&＃39; has now bin data&＃61; {}".format(type(self).__name__,publisher.name, bin(publisher.data)))

接下来我们添加一下测试数据&＃xff0c;运行代码观察一下结果&＃xff1a;

def main():df &＃61; DefaultFormatter(&＃39;test1&＃39;)print(df)print()hf &＃61; HexFormatter()df.add(hf)df.data &＃61; 3print(df)print()bf &＃61; BinaryFormatter()df.add(bf)df.data &＃61; 21print(df)print()df.remove(hf)df.data &＃61; 40print(df)print()df.remove(hf)df.add(bf)df.data &＃61; &＃39;hello&＃39;print(df)print()df.data &＃61; 4.2print(df)if __name__ &＃61;&＃61; &＃39;__main__&＃39;:main()

完整代码参考&＃xff1a;https://gist.github.com/gusibi/93a000c79f3d943dd58dcd39c4b547f1

运行代码&＃xff1a;

python observer.py ## output DefaultFormatter: &＃39;test1&＃39; has data &＃61; 0HexFormatter: &＃39;test1&＃39; has now hex data&＃61; 0x0 HexFormatter: &＃39;test1&＃39; has now hex data&＃61; 0x3 DefaultFormatter: &＃39;test1&＃39; has data &＃61; 3BinaryFormatter: &＃39;test1&＃39; has now bin data&＃61; 0b11 BinaryFormatter: &＃39;test1&＃39; has now bin data&＃61; 0b10101 HexFormatter: &＃39;test1&＃39; has now hex data&＃61; 0x15 DefaultFormatter: &＃39;test1&＃39; has data &＃61; 21BinaryFormatter: &＃39;test1&＃39; has now bin data&＃61; 0b101000 DefaultFormatter: &＃39;test1&＃39; has data &＃61; 40BinaryFormatter: &＃39;test1&＃39; has now bin data&＃61; 0b101000 Error: invalid literal for int() with base 10: &＃39;hello&＃39; DefaultFormatter: &＃39;test1&＃39; has data &＃61; 40BinaryFormatter: &＃39;test1&＃39; has now bin data&＃61; 0b100 DefaultFormatter: &＃39;test1&＃39; has data &＃61; 4

在输出中我们看到&＃xff0c;添加额外的观察者&＃xff0c;就会出现更多的输出&＃xff1b;一个观察者被删除后就不再被通知到。

总结

这一篇我们介绍了观察者模式的原理以及 Python 代码的实现。在实际的项目开发中&＃xff0c;观察者模式广泛的运用于 GUI 编程&＃xff0c;而且在仿真及服务器等其他时间处理架构中也能用到&＃xff0c;比如&＃xff1a;数据库触发器、Django 的信号系统、Qt GUI 应用程序框架的信号&＃xff08;signal&＃xff09;与槽&＃xff08;slot&＃xff09;机智以及WebSocket的许多用例。