PHP观察者模式

太过爱你忘了你带给我的痛 2023-10-06 17:27 23阅读 0赞

#### 阅读目录 ####

*  PHP观察者模式简单示例
 *  PHP观察者模式
 *   *  问题
     *  解决
     *   *  被观察者
         *  观察者
         *  客户端
         *  新增观察者
         *  特点
         *  预览代码
     *  实例A
     *  实例B
 *  PHP 观察者模式

## PHP观察者模式简单示例 ##

当一个对象发生变化时，依赖他的对象全部会收到通知，并自动更新。

# EventGenerator.php
 <?php
 abstract class EventGenerator{
 
 	private $observers = array();
 
 	function addObserver(Observer $observer){
 
 		$this->observers[]=$observer;
 	}
 
 	function notify(){
 
 		foreach ($this->observers as $observer){
 
 			$observer->update();
 		}
 	}
 }
 ?>
 
 # 定义一个观察者接口 Observer.php
 <?php
 interface Observer{
 
 	function update();//这里就是在事件发生后要执行的逻辑
 }
 
 # 一个实现了 EventGenerator 抽象类的类，用于具体定义某个 发生的事件实现
 class Event extends EventGenerator{
 
 	function triger(){
 
 		echo "Event ";
 	}
 }
 
 class Observer1 implements Observer{
 
 	function update(){
 
 		echo "逻辑 1 ";
 	}
 }
 
 class Observer2 implements Observer{
 
 	function update(){
 
 		echo "逻辑 2 ";
 	}
 }
 
 $event = new Event();
 $event->addObserver(new Observer1());
 $event->addObserver(new Observer2());
 $event->triger();
 $event->notify();

## PHP观察者模式 ##

`观察者模式，也称发布-订阅模式，定义了一个被观察者和多个观察者的、一对多的对象关系。`

在被观察者状态发生变化的时候，它的所有观察者都会收到通知，并自动更新。

观察者模式通常用在实时事件处理系统、组件间解耦、数据库驱动的消息队列系统，同时也是MVC设计模式中的重要组成部分。

以下我们以订单创建为例。

当订单创建后，系统会发送邮件和短信，并保存日志记录。

### 问题 ###

在没有用观察者模式的时候，如下：

class Order
    {
        
        // 订单状态
        private $state = 0;
    
        // 订单状态有变化时发送通知
        public function addOrder()
        {
        
            $this->state = 1;
            // 发送邮件
            Email::update($this->state);
            // 短信通知
            Message::update($this->state);
            // 记录日志
            Log::update();
            // 其他更多通知
        }
    }

代码中，在Order类中调用各类的方法来实现通知。当在客户端创建订单：

$order = new Order();
    $order->addOrder();

就会同时产生三个通知：发送邮件、发送短信和记录日志。

在系统小的时候，这是非常快捷有效的方式。

可是，当系统变大的时候，这种方法马上面临难以扩展的问题，并且容易出错：

1、如果订单不需要某种通知，比如不需要记录日志，则必须修改Order类，做状态的判断；  
2、如果再加一种通知方式，如系统消息通知，则除了增加新类，同时还需要修改Order类和客户端。

这两条都不符合面向对象中的开闭原则，会让系统越来越难维护。

### 解决 ###

接下来我们用观察者模式解决这个问题。

#### 被观察者 ####

被观察者是一些具体的实例，比如订单管理、用户登陆、评论回复、状态审核等等。

别的功能会依赖于它们的状态进行各种动作。

被观察者至少要实现attach()、detach()、notify()三个方法，用以添加、删除和通知观察者。

通知的方式是，在类中的其他方法（如：创建订单）调用notify()方法。

另外，观察者可能用到被观察者的一些状态信息。

所以，要在notify()中把当前对象作为参数传给观察者，方便其通过提供的public方法获得被观察者的状态信息。

本例用getState()方法供给观察者获取状态信息。

#### 观察者 ####

观察者可能有多个，但每个观察者都必须实现Observer接口规定的update()方法，这是接收被观察者通知的唯一渠道。

# 观察者接口
    interface Observer
    {
        
        // 接收到通知的处理方法
        public function update(Observable $observable);
    }
    
    # 观察者1：发送邮件
    class Email implements Observer
    {
        
        public function update(Observable $observable)
        {
        
            $state = $observable->getState();
            if ($state) {
        
                echo '发送邮件：您已经成功下单。';
            } else {
        
                echo '发送邮件：下单失败，请重试。';
            }
        }
    }
    
    # 观察者2：短信通知
    class Message implements Observer
    {
        
        public function update(Observable $observable)
        {
        
            $state = $observable->getState();
            if ($state) {
        
                echo '短信通知：您已下单成功。';
            } else {
        
                echo '短信通知：下单失败，请重试。';
            }
        }
    }
    
    # 观察者3：记录日志
    class Log implements Observer
    {
        
        public function update(Observable $observable)
        {
        
            echo '记录日志：生成了一个订单记录。';
        }
    }

这里有三个观察者：发送邮件、短信通知和记录日志，它们都实现了update()方法。

其中，发送邮件和短信依赖于订单、也就是被观察者的状态，来决定发送消息的内容，记录日志则不需要订单的状态。

#### 客户端 ####

然后我们创建一个客户端，内容：

// 创建观察者对象
 $email = new Email();
 $message = new Message();
 $log = new Log();
 // 创建订单对象
 $order = new Order();
 
 // 向订单对象中注册3个观察者：发送邮件、短信通知、记录日志
 $order->attach($email);
 $order->attach($message);
 $order->attach($log);
 // 添加订单，添加时会自动发送通知给观察者
 $order->addOrder();
 
 echo ' ';
 
 // 删除记录日志观察者
 $order->detach($log);
 // 添加另一个订单，会再次发送通知给观察着
 $order->addOrder();

对于不需要通知的观察者，用detach()移出观察者列表即可。

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaWd1YW5nMTAy_size_16_color_FFFFFF_t_70]  
![在这里插入图片描述][202104222134478.png]

#### 新增观察者 ####

<?php
 # 被观察者接口
 interface Observable
 {
 
 // 添加/注册观察者
 public function attach(Observer $observer);
 // 删除观察者
 public function detach(Observer $observer);
 // 触发通知
 public function notify();
 }
 
 /**
 * 被观察者
 * 职责：添加观察者到$observers属性中，
 * 有变动时通过notify()方法运行通知
 */
 class Order implements Observable
 {
 
 // 保存观察者
 private $observers = array();
 // 订单状态
 private $state = 0;
 
 // 添加（注册）观察者
 public function attach(Observer $observer)
 {
 
 $key = array_search($observer, $this->observers);
 if ($key === false) {
 
 $this->observers[] = $observer;
 }
 }
 
 // 移除观察者
 public function detach(Observer $observer)
 {
 
 $key = array_search($observer, $this->observers);
 if ($key !== false) {
 
 unset($this->observers[$key]);
 }
 }
 
 // 遍历调用观察者的update()方法进行通知，不关心其具体实现方式
 public function notify()
 {
 
 foreach ($this->observers as $observer) {
 
 // 把本类对象传给观察者，以便观察者获取当前类对象的信息
 $observer->update($this);
 }
 }
 
 // 订单状态有变化时发送通知
 public function addOrder()
 {
 
 $this->state = 1;
 $this->notify();
 }
 
 // 获取提供给观察者的状态
 public function getState()
 {
 
 return $this->state;
 }
 }
 
 # 观察者接口
 interface Observer
 {
 
 // 接收到通知的处理方法
 public function update(Observable $observable);
 }
 
 # 观察者1：发送邮件
 class Email implements Observer
 {
 
 public function update(Observable $observable)
 {
 
 $state = $observable->getState();
 if ($state) {
 
 echo '发送邮件：您已经成功下单。';
 } else {
 
 echo '发送邮件：下单失败，请重试。';
 }
 }
 }
 
 # 观察者2：短信通知
 class Message implements Observer
 {
 
 public function update(Observable $observable)
 {
 
 $state = $observable->getState();
 if ($state) {
 
 echo '短信通知：您已下单成功。';
 } else {
 
 echo '短信通知：下单失败，请重试。';
 }
 }
 }
 
 # 观察者3：记录日志
 class Log implements Observer
 {
 
 public function update(Observable $observable)
 {
 
 echo '记录日志：生成了一个订单记录。';
 }
 }
 
 // 创建观察者对象
 $email = new Email();
 $message = new Message();
 $log = new Log();
 // 创建订单对象
 $order = new Order();
 
 // 向订单对象中注册3个观察者：发送邮件、短信通知、记录日志
 $order->attach($email);
 $order->attach($message);
 $order->attach($log);
 // 添加订单，添加时会自动发送通知给观察者
 $order->addOrder();
 
 echo ' ';
 
 // 删除记录日志观察者
 $order->detach($log);
 // 添加另一个订单，会再次发送通知给观察着
 $order->addOrder();
 
 echo ' ';
 $order->detach($email);
 $order->detach($message);
 
 # 观察者4：系统消息
 class Alert implements Observer
 {
 
 public function update(Observable $observable)
 {
 
 echo '系统消息：您的订单有更新了~~~';
 }
 }
 
 // 创建“系统消息”观察者
 $alert = new Alert();
 // 注册观察者到订单对象中
 $order->attach($alert);
 $order->addOrder();

![在这里插入图片描述][20210422214616120.png]

#### 特点 ####

在观察者模式中，被观察者完全不需要关心观察者，在自身状态有变化是，遍历执行观察者update()方法即完成通知。

在观察者模式中，被观察者通过添加attach()方法，提供给观察者注册，使自己变得可见。

当被观察者改变时，给注册的观察者发送通知。至于观察者如何处理通知，被观察者不需要关心。

这是一种良好的设计，对象之间不必相互理解，同样能够相互通信。

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaWd1YW5nMTAy_size_16_color_FFFFFF_t_70 1]  
面向对象编程中，任何对象的状态都非常重要，它们是对象间交互的桥梁。

当一个对象的改变需要被其他对象关注时，观察者模式就派上用场了。

#### 预览代码 ####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaWd1YW5nMTAy_size_16_color_FFFFFF_t_70 2]  
![在这里插入图片描述][20210422215532965.png]

### 实例A ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaWd1YW5nMTAy_size_16_color_FFFFFF_t_70 3]

<?php
 # 事件产生类
 abstract class EventGenerator
 {
 
 private $ObServers = [];
 
 //增加观察者
 public function add(ObServer $ObServer)
 {
 
 $this->ObServers[] = $ObServer;
 }
 
 //事件通知
 public function notify()
 {
 
 foreach ($this->ObServers as $ObServer) {
 
 $ObServer->update();
 }
 }
 
 }
 
 # 观察者接口类
 interface ObServer
 {
 
 public function update($event_info = null);
 }
 
 # 观察者1
 class ObServer1 implements ObServer
 {
 
 public function update($event_info = null)
 {
 
 echo "观察者1 收到执行通知 执行完毕！\n";
 }
 }
 
 # 观察者2
 class ObServer2 implements ObServer
 {
 
 public function update($event_info = null)
 {
 
 echo "观察者2 收到执行通知 执行完毕！\n";
 }
 }
 
 # 事件
 class Event extends EventGenerator
 {
 
 # 触发事件
 public function trigger()
 {
 
 //通知观察者
 $this->notify();
 }
 }
 
 //创建一个事件
 $event = new Event();
 //为事件增加旁观者
 $event->add(new ObServer1());
 $event->add(new ObServer2());
 //执行事件 通知旁观者
 $event->trigger();

### 实例B ###

“观察者模式”的观察者三个字信息量很大。玩过很多网络游戏的童鞋们应该知道，即便是斗地主，除了玩家，还有一个角色叫“观察者"。在我们今天他谈论的模式设计中，观察者也是如此。首先，要有一个“主题”。只要有了一个主题，观察者才能搬着小板凳儿聚在一堆。其次，观察者还必须要有自己的操作。否则你聚在一堆儿没事做也没什么意义。

从面向过程的角度来看，首先是观察者向主题注册，注册完之后，主题再通知观察者做出相应的操作，整个事情就完了。

从面向对象的角度来看，主题提供注册和通知的接口，观察者提供自身操作的接口。（这些观察者拥有一个同一个接口。）观察者利用主题的接口向主题注册，而主题利用观察者接口通知观察者。耦合度相当之低。

如何实现观察者注册？

通过前面的注册者模式很容易给我们提供思路，把这些对象加到一棵注册树上就好了嘛。

如何通知？

这就更简单了，对注册树进行遍历，让每个对象实现其接口提供的操作。

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaWd1YW5nMTAy_size_16_color_FFFFFF_t_70 4]

![在这里插入图片描述][20210423104923269.png]

<?php
 // 主题接口
 interface Subject{
 
 public function register(Observer $observer);
 public function notify();
 }
 // 观察者接口
 interface Observer{
 
 public function watch();
 }
 // 观察者
 class Cat implements Observer{
 
 public function watch(){
 
 echo "Cat watches TV<hr/>";
 }
 }
 class Dog implements Observer{
 
 public function watch(){
 
 echo "Dog watches TV<hr/>";
 }
 }
 class People implements Observer{
 
 public function watch(){
 
 echo "People watches TV<hr/>";
 }
 }
 // 主题
 class Action implements Subject{
 
 public $_observers=array();
 public function register(Observer $observer){
 
 $this->_observers[]=$observer;
 }
 
 public function notify(){
 
 foreach ($this->_observers as $observer) {
 
 $observer->watch();
 }
 
 }
 }
 // 应用实例
 $action=new Action();
 $action->register(new Cat());
 $action->register(new People());
 $action->register(new Dog());
 $action->notify();

## PHP 观察者模式 ##

Laravel 的事件提供了一个简单的观察者实现，能够订阅和监听应用中发生的各种事件。

既然用到观察者实现，那我们先来说下什么是观察者

观察者模式 (Observer), 当一个对象的状态发生改变时，依赖他的对象会全部收到通知，并自动更新。

场景：一个事件发生后，要执行一连串更新操作。传统的编程方式，就是在事件的代码之后直接加入处理逻辑，当更新的逻辑增多之后，代码会变得难以维护。这种方式是耦合的，侵入式的，增加新的逻辑需要改变事件主题的代码

观察者模式实现了低耦合，非侵入式的通知与更新机制

具体代码实现

<?php
 /**
 * 观察者接口类
 * Interface ObServer
 */
 interface ObServer
 {
 
 public function update($event_info = null);
 }
 /**
 * 观察者1
 */
 class ObServer1 implements ObServer
 {
 
 public function update($event_info = null)
 {
 
 echo "观察者1 收到执行通知 执行完毕！\n";
 }
 }
 /**
 * 观察者2
 */
 class ObServer2 implements ObServer
 {
 
 public function update($event_info = null)
 {
 
 echo "观察者2 收到执行通知 执行完毕！\n";
 }
 }
 /**
 * 事件
 * Class Event
 */
 class Event
 {
 
 //增加观察者
 public function add(ObServer $ObServer)
 {
 
 $this->ObServers[] = $ObServer;
 }
 //事件通知
 public function notify()
 {
 
 foreach ($this->ObServers as $ObServer) {
 
 $ObServer->update();
 }
 }
 /**
 * 触发事件
 */
 public function trigger()
 {
 
 //通知观察者
 $this->notify();
 }
 }
 
 //创建一个事件
 $event = new Event();
 //为事件增加旁观者
 $event->add(new ObServer1());
 $event->add(new ObServer2());
 //执行事件 通知旁观者
 $event->trigger();

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaWd1YW5nMTAy_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20210422213429369.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaWd1YW5nMTAy,size_16,color_FFFFFF,t_70
[202104222134478.png]: https://img-blog.csdnimg.cn/202104222134478.png
[20210422214616120.png]: https://img-blog.csdnimg.cn/20210422214616120.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaWd1YW5nMTAy_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20210422215007217.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaWd1YW5nMTAy,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaWd1YW5nMTAy_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20210422215144909.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaWd1YW5nMTAy,size_16,color_FFFFFF,t_70
[20210422215532965.png]: https://img-blog.csdnimg.cn/20210422215532965.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaWd1YW5nMTAy_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/20210423104036445.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaWd1YW5nMTAy,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaWd1YW5nMTAy_size_16_color_FFFFFF_t_70 4]: https://img-blog.csdnimg.cn/20210423104953835.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaWd1YW5nMTAy,size_16,color_FFFFFF,t_70
[20210423104923269.png]: https://img-blog.csdnimg.cn/20210423104923269.png