参考PHP手册
laravel学院

Java设计模式之《观察者模式》及应用场景

• 思路

应该有两个角色，一个是被观察者Observables，一个是观察者Observer,被观察者发生变化的时候，通知观察者，进而观察者做出自己内容的更新。是一对多的关系

<?php
//先定义一个被观察者的接口，这个接口要实现注册观察者，删除观察者和通知的功能。
interface Observables
{
    public function attach(observer $ob);
    public function detach(observer $ob);
    public function notify();
}
// 定义一个卖家类继承这个被观察者  所有的买家都在观察卖家的价格波动
class Saler implements Observables
{
    private $_observers = array();       //把观察者保存在这里
    private $range = 0;

    public function attach(Observer $ob)
    {
        $this->_observers[] = $ob;
    }
    public function detach(Observer $observer)
    {
           $key = array_search($observer,$this->observers);
            if($key){
                unset($this->observers[$key]);
            }
    }

    public function notify()
    {
        foreach($this->_observers as $observer)
        {
            $observer->doActor($this);
        }
    }

    public function price($range)
    {
        $this->range = $range;
    }

    public function getAddRange()
    {
        return $this->range;
    }
}


//定义一个观察者的接口，这个接口要有一个在被通知的时候都要实现的方法
interface Observer
{
    /**
     * @param Observables $obv
     * @return mixed 观察者要可以接收被观察者的类，这样才能查看被观察者的变化
     */
    public function doActor(Observables $obv);
}

// 定义一个低收入观察者
class PoorBuyer implements Observer
{
    //PoorBurer的做法
    public function doActor(observables $obv)
    {
        if($obv->getAddRange() > 10)
            echo  '不买了.<br />';
        else
            echo '还行，买一点吧.<br />';
    }
}
// 定义一个高收入观察者
class RichBuyer implements Observer
{
    //RichBuyer的做法
    public function doActor(observables $obv)
    {
        echo '你再涨我也不怕，咱不差钱.<br />';
    }
}


$saler = new Saler();  //卖家(被观察者)
$saler->attach(new PoorBuyer()); //注册一个低收入的消费者(观察者)
$saler->attach(new RichBuyer()); //注册一个高收入的消费者(观察者)
$saler->notify(); //通知
//打印得到
//还行，买一点吧.
//你再涨我也不怕，咱不差钱.

$saler->price(15);  //涨价
$saler->notify();  //通知
//不买了.
//你再涨我也不怕，咱不差钱.

-如果我们想要操作一个观察者类

$saler_new = new Saler();  //小贩(被观察者)
$saler_new->price(15);  //涨价
$buy = new PoorBuyer();
$buy->doActor($saler_new);
// 不买了.

• 再看一个移除观察者的例子

$saler = new Saler();  //小贩(被观察者)
$saler->attach(new PoorBuyer()); //注册一个低收入的消费者(观察者)
$saler->attach(new RichBuyer()); //注册一个高收入的消费者(观察者)
$saler->detach(new RichBuyer());
$saler->increPrice(15);  //涨价
$saler->notify(); //通知
// 得到的是   不买了

在实际应用中，其实他类似一个触发器的作用，当被观察者改变了，观察者做一些操作数据库的动作，这样就实现了消息订阅

观察者模式有两种交互模式，一种是接听 一种是推送
内置有两个SLI我们可以直接引用\SplSubject,\SplObserver

<?php

class Observer implements \SplObserver{

    public function update(SplSubject $subject)
    {
        return $subject->getPrice();
    }

}

class Subject implements \SplSubject{

    protected $price;
    protected $observers;

    public function attach(SplObserver $observer)
    {
        $this->observers[] = $observer;
    }

    public function detach(SplObserver $observer)
    {
    $key = array_search($observer,$this->observers);
            if($key){
                unset($this->observers[$key]);
            }
    }

    public function setPrice($price)
    {
        $this->price = $price;
        if ($this->price > 12){
            $this->notify();
        }
        return true;
    }

    public function getPrice()
    {
        return $this->price;
    }

    public function notify()
    {
//        /**
//         * $observer Observer
//         */
//        foreach ($this->observers as $observer){
//            $observer->update($this);
//        }
    }

}

$observer1= new Observer();
$observer2= new Observer();
$observer3= new Observer();

$subject = new Subject();
$subject->attach($observer1);
echo $observer1->update($subject);
$subject->setPrice(15);
//$subject->notify();
echo $observer1->update($subject);
echo $observer2->update($subject);
echo $observer2->update($subject);