设计模式 | 观察者模式

说明

这个设计模式很常用、重要, 所以要好好看。这是一个非常经典的设计模式, 解决了不少问题, 在实际项目中应用比较广泛。

先简单说一下设计模式的定义: 一旦主体对象状态发生改变，与之关联的观察者对象会收到通知，并进行相应操作。观察者模式实现了低耦合，非侵入式的通知与更新机制。

举个🌰, 大家都知道, 今年的猪肉价格让人有望而却步, 让原本就不富裕的家庭更是雪上加霜, 我有个想法就是, 让这个超市猪肉价格一降价就通知我, 好让我能及时以较低价格购买。我这个时候我就需要观察者, 来观察猪肉的价格, 然后及时通知我。

示例




<?php
/**
 * Created by 憧憬.
 */


/**
 * 观察者约束
 * Interface Observer
 */
interface Observer {

    // 到时候接受到通知及时作出反应
    public function update();
}

/**
 * 被观察者 到时候也好通知观察者
 * Interface Observable
 */
interface Observable {

    // 添加观察者
    public function addObserver(Observer $observer);

    // 删除观察者
    public function deleteObserver(Observer $observer);

    // 通知观察者
    public function notifyObserver();
}

//
///**
// * 猪肉
// * Class Pork
// */
//class Pork implements Observable {
//
//    public $observableList;
//
//    public $price;
//
//    public function addObserver(Observer $observer)
//    {
//        $this->observableList[] = $observer;
//    }
//
//    public function deleteObserver(Observer $observer)
//    {
//        foreach ($this->observableList as $k => $v) {
//            if ($v === $observer) {
//                unset($this->observableList[$k]);
//            }
//        }
//    }
//
//    public function notifyObserver()
//    {
//        foreach ($this->observableList as $observer) {
//            $observer->update();
//        }
//    }
//
//    /**
//     * 设置猪肉价格
//     * @param $price
//     * @author: 憧憬
//     */
//    public function setPrice($price)
//    {
//        $this->price = $price;
//        $this->notifyObserver();
//    }
//
//}
//

/**
 * 博主自己
 * Class Aoppp
 */
class Aoppp implements Observer {
    public function update()
    {
        echo '憧憬 有你的通知来了  快快行动';
    }
}

/**
 * 李四也想吃猪肉
 * Class Lisi
 */
class Lisi implements Observer {
    public function update()
    {
        echo '李四 有你的通知来了  快快行动';
    }
}


//$pork = new Pork();
//
//$pork->addObserver(new Aoppp());
//$pork->addObserver(new Lisi());
//$pork->setPrice(100);


/**
 * 这个时候你发现 可以随便通知任何人,  也可以移除观察者  但是每个想观察的对象都要写这个函数 有点重复
 * 我们可以抽离出来
 */

class ObserverUtil implements Observable {

    public $observableList;


    public function addObserver(Observer $observer)
    {
        $this->observableList[] = $observer;
    }

    public function deleteObserver(Observer $observer)
    {
        foreach ($this->observableList as $k => $v) {
            if ($v === $observer) {
                unset($this->observableList[$k]);
            }
        }
    }

    public function notifyObserver()
    {
        foreach ($this->observableList as $observer) {
            $observer->update();
        }
    }
}




/**
 * 将猪肉类改为继承
 * Class Pork
 */
class Pork extends ObserverUtil {

    public $price;

    /**
     * 设置猪肉价格
     * @param $price
     * @author: 憧憬
     */
    public function setPrice($price)
    {
        $this->price = $price;
        $this->notifyObserver();
    }

}


$pork = new Pork();

$pork->addObserver(new Aoppp());
$pork->addObserver(new Lisi());
$pork->setPrice(100);

// 这样的话 你要监听鸡肉 还是什么乱七八糟的 都要方便很多了

观察者模式在实际项目的应用中非常常见，比如你到 ATM 机器上取钱，多次输错密码，卡就会被 ATM 吞掉，吞卡动作发生的时候，会触发哪些事件呢?第一摄像头连续快拍，第二，通知监控系统，吞卡发生; 第三，初始化 ATM 机屏幕，返回最初状态，你不能因为就吞了一张卡，整个 ATM 都不能用了吧，一般前两个动作都是通过观察者模式来完成的。

这个设计模式之后变种了一个发布/订阅的模式, 这个设计模式也是比较容易理解, 大家可以去了解下。

那观察者模式在什么情况下使用呢?观察者可以实现消息的广播，一个消息可以触发多个事件，这是观察者模式非常重要的功能。使用观察者模式也有两个重点问题要解决:

广播链的问题

如果你做过数据库的触发器，你就应该知道有一个触发器链的问题，比如表 A 上写了一个触发器，内容是一个字段更新后更新表 B 的一条数据，而表 B 上也有个触发器，要更新表 C，表 C 也有触发器...,完蛋了，这个数据库基本上就毁掉了!我们的观察者模式也是一样的问题，一个观察者可以有双重身份，即使观察者，也是被观察者，这没什么问题呀，但是链一旦建立，这个逻辑就比较复杂，可维护性非常差，根据经验建议，在一个观察者模式中最多出现一个对象既是观察者也是被观察者，也就是说消息最多转发一次(传递两次)，这还是比较好控制的;

异步处理问题

被观察者发生动作了，观察者要做出回应，如果观察者比较多，而且处理时间比较长怎么办?那就用异步呗，异步处理就要考虑线程安全和队列的问题，这个大家有时间看看 Message Queue，就会有更深的了解。

本文为作者原创，手码不易，允许转载，转载后请以链接形式说明文章出处。