//被察者抽象类class observed implements splsubject{ protected $_name; protected $_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(){ foreach($this->_observers as $observer){ $observer->showmessage($this); } } //普通方法: 设置值 public function setname($name){ $this->_name = $name; $this->notify(); } //普通方法: 获取值 public function getname(){ return $this->_name; } //普通方法:设置年龄 public function setage($age){ $this->age = $age; foreach($this->_observers as $observer){ $observer->showage($this->_name,$this->age); } }}// 观察者抽象类class observer implements splobserver{ //显示消息提示 public function showmessage(splsubject $obj){ $user = $obj->getname(); if($user==='admin'){ echo '您好, ',$user,'欢迎您进入管理后台
'; }else{ echo 你好, '$user' 你已经被添加到了用户列表
; } } //这是继承父类的抽象方法 public function update(splsubject $subject) {} //显示个人年龄 public function showage($name,$age){ echo ; }}$subject = new observed(); //生成一个被观察者对象$observer = new observer(); //生成一个观察者对象$subject->attach($observer);//把观察者传入到被观察中去$subject->setname('张三'); //调用 setname 方法/* * 通过面的 setname 就会调用 $this->notify();* 通过调用 $this->notify()就会调用 $observer->showmessage($this)方法,* 即每个观察者对象的 showmessage($obj)方法;*/$subject->setname('admin');$subject->setage(24);
复制代码
例2，观察者模式：
interface subject { public function attach($observer); //添加观察者 public function detach($observer); //踢出观察者 public function notify(); //满足条件时通知观察者 public function subjectstate($subject); //观察条件 } class boss implements subject { public $_action; private $_observer; public function attach($observer) { $this->_observer[] = $observer; } public function detach($observer) { $observerkey = array_search($observer, $this->_observer); if($observerkey !== false) { unset($this->_observer[$observerkey]); } } public function notify() { foreach($this->_observer as $value ) { $value->update(); } } public function subjectstate($subject) { $this->_action = $subject; } } abstract class observer { protected $_username; protected $_sub; public function __construct($name,$sub) { $this->_username = $name; $this->_sub = $sub; } public abstract function update(); //接收通过方法 } // bbs.it-home.orgclass stockobserver extends observer { public function __construct($name,$sub) { parent::__construct($name,$sub); } public function update() { echo $this->_sub->_action.$this->_username. 你赶快跑...; } } $huhansan = new boss(); //被观察者 $gongshil = new stockobserver(三毛,$huhansan); //初始化观察者 $huhansan->attach($gongshil); //添加一个观察者 $huhansan->attach($gongshil); //添加一个相同的观察者 $huhansan->detach($gongshil); //踢出基中一个观察者 $huhansan->subjectstate(警察来了); //达到满足的条件 $huhansan->notify(); //通过所有有效的观察者
复制代码
说明：一个类（我们称之为被观察者），这个类继承了一个被观察者容器的借口 该接口中方法有：添加观察者，踢出观察者，提醒观察者，和观察条件 添加观察者，即相当于把一些类注册到这个容器之中，当然这些类的前提是需要有一个相应被观察者反应信息的方法， 被观察者容器通过接受不同的观察条件参数来判断是否需要提醒所有本容器中的已经注册过的观察者是否相应。一旦满足提醒条件，提醒容器内所有观察者让其调用相应方法并且实现对应观察者实例的变化。