PHP 设计模式之观察者模式
1. 观察者模式
PHP5.1.0以及更高版本有很多优秀的特性 其中之一就是提供了一组可以用于观察者接口 利用这些接口,构建 PHP 观察者模式简直易如反掌。" SPL "是标准 PHP 库( Standard PHP Library )的简写,这个库中包括一组解决标准问题的接口和类。
观察者模式（Observer），当一个对象状态发生改变时，依赖它的对象全部会收到通知，并自动更新。观察者模式的核心在于Subject和Observer 接口。Subject包含一个给定的状态，观察者"订阅"这个主题，将主题的当前状态通知观察者。可以认为它是一个博客，有很多订阅者，会定期地为订阅或定期阅读博客的各类用户更新一组信息。每次博客发生改变时（其状态改变），所有订阅者"都会得到通知"。观察者模式类图如下（画图不标准，能说明问题就好）：
2. 观察者模式使用场景
设计观察者模式是为了让一个对象跟踪某个状态，知道状态何时改变，一旦状态改变，所有订阅对象都能得到通知。如果需要保证一个状态的一致性，但是这个给定状态可能有多个不同的视图，这种情况下观察者模式就很适用，而且很有帮助。利用观察者模式，可以维护一致性，同时记录创建一个给定状态的对象的个数。
观察者模式很直观。何必让多个对象创建或跟踪一个给定的状态呢？如果由一个对象完成这个工作，然后通知其它可能用到这个状态的对象，这样会合理很多。观察者模式实现了低耦合，非侵入式的通知与更新机制。
3. php实现观察者模式
可用于观察者设计模式的3个SPL接口/类如下：
- SplSubject
- SplObserver
- SplObjectStorage
3.1 SplSubject 这个接口可用方法如下：
abstract public void attach ( SplObserver $observer )
abstract public void detach ( SplObserver $observer )
abstract public void notify ( void )
这个接口指定attach()和detach()方法参数中$observer的数据类型必须是一个SplObserver对象。
3.2 SplObserver
SplObserver 接口有一个方法update()，如下所示：
abstract public void update( SplSubject $subject)
update()方法对于观察者模式至关重要，因为它会得到Subject状态的最新变化，并交给观察者实例。
3.3 SplObjectStorage
SplObjectStorage类与观察者设计模式没有内在的关系，不过通过它可以很方便地将观察者实例与一个主题实例相关联以及解除关联。尽管一般将SplObjectStorage类描述为从
对象到数据或对象集的一个映射，但我更喜欢把它想象成是一个数组（带有内置的attach()和detach()方法）。这个类提供了一种简单的方法，可以使观察者与发出状态改变通知的主题对象关联以及解除关联。
3.4 实现观察者模式
代码如下：
<?php
class Article implements SplSubject{
public $has_update;
public $has_comments;
protected $observers = null;
public function __construct(){
$this->observers = new SplObjectStorage();
}
public function has_update($updated = false,$comments = true){
$this->has_update = $updated;
$this->has_comments = $comments;
$this->notify();
}
//绑定观察者
public function attach(SplObserver $observer){
$this->observers->attach($observer);
}
//解除观察者
public function detach(SplObserver $observer){
$this->observers->detach($observer);
}
//发送通知
public function notify(){
$this->observers->rewind();
//当前迭代项无效终止循环，也可以写成foreach
// while($this->observers->valid()){
// $observer = $this->observers->current();
// $observer->update($this);
// $this->observers->next(); //指针往后移
// }
//
foreach($this->observers as $observer){
$observer->update($this);
}
}
}
class ContentUpdateSubscribe implements SplObserver{
public function update(SplSubject $subject){
if($subject->has_update){
echo "您订阅的文章有新动态哦<br/>";
}
}
}
class CommentsUpdateSubscribe implements SplObserver{
public function update(SplSubject $subject){
if($subject->has_comments){
echo "您关注的文章有新评论哦<br/>";
}
}
}
$article_1 = new Article();
$article_1->attach(new ContentUpdateSubscribe());
$article_1->attach(new CommentsUpdateSubscribe());
$article_1->has_update(true,true);
运行结果：