PHP設計模式中觀察者模式詳解

//假設使用者成功購買商品後需要傳送郵件和簡訊通知
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() {
        //todo 訂單操作
        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();

class OrderListener implements SplSubject {
    //觀察者列表
    public $observers;
    public function __construct() {
        //SplObjectStorage類提供從物件到資料的對映，或者通過忽略資料，提供物件集的對映。在許多需要唯一標識物件的情況下，這種雙重用途非常有用。
        $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();
    }
}
//SplObserver介面與SplSubject介面一起使用，以實現觀察者設計模式。
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();

	//以上程式碼的notify方法使用原生手動調整指標的方式去實現。也可以使用foreach去遍歷實現
    public function notify() {
        foreach ($this->observers as $observer) {
            $observer->update($this);
        }
    }