简介
观察者模式是行为型模式的一种,定义了对象间一对多的关系。当对象的状态发生变化时候,依赖于它的对象会得到通知。
适用场景
- 类似触发钩子事件,可做消息通知、框架底层监听。
- 一个对象的改变会导致一个或多个对象发生改变,方便扩展的写法。
优点
方便扩展,降低耦合,统一触发规则。当需要新增或者删除一个观察者的时候,只需要增加观察者就行。
缺点
- 相比于不用观察者而是直接依赖某些类,增加代码的复杂度。
- 如果观察者者被观察者互相依赖,有产生死循环的可能。
补充
- 需要理清楚观察者和被观察者是谁,观察者可以理解为被动受到通知的对象。被观察者是主动发送通知的对象。
- 固定的套路,被观察者至少需要一个添加观察者的方法和一个通知观察者的方法用来确定身份和发送通知(一般有三个,多一个删除观察者的方法),观察者至少需要一个更新的方法用于接收被观察者的通知。
代码(自定义实现)
class Order {
private $observers = [];
public function attach($type, $observer) {
$this->observers[$type] = $observer;
}
public function notify() {
if ($this->observers == []) {
return null;
}
foreach ($this->observers as $every_observer) {
(new $every_observer)->update($this);
}
}
public function buyGoods() {
echo '商品购买完成' . PHP_EOL;
$this->notify();
}
}
class Mail {
public function update($observer) {
echo '发送电子邮件' . PHP_EOL;
}
}
class Sms {
public function update($observer) {
echo '发送短信' . PHP_EOL;
}
}
$order = new Order();
$order->attach('mail', Mail::class);
$order->attach('sms', Sms::class);
$order->buyGoods();
代码(基于SPL实现)
SPL(Standard PHP Library)标准PHP类库,用于解决典型问题的一组接口与类的集合。
class OrderListener implements \SplSubject {
public $observers;
public function __construct() {
$this->observers = new \SplObjectStorage();
}
public function attach(\SplObserver $observer) {
$this->observers->attach($observer);
}
public function detach(\SplObserver $observer) {
$this->observers->detach($observer);
}
public function notify() {
$this->observers->rewind();
while($this->observers->valid()) {
$curr_obj = $this->observers->current();
$curr_obj->update($this);
$this->observers->next();
}
}
public function buyGoods() {
echo '购买成功' . PHP_EOL;
$this->notify();
}
}
class Mail implements \SplObserver {
public function update(\SplSubject $subject) {
echo '发送邮件' . PHP_EOL;
}
}
class Sms implements \SplObserver {
public function update(\SplSubject $subject) {
echo '发送短信' . PHP_EOL;
}
}
$listener = new OrderListener();
$listener->attach(new Mail());
$listener->attach(new Sms());
$listener->buyGoods();
通知代码(基于SPL实现的notify方法优化)
public function notify() {
foreach ($this->observers as $observer) {
$observer->update($this);
}
}
|