【设计模式】观察者模式

· 浏览次数 : 0

小编点评

观察者模式是一种行为设计模式，它定义对象间的一种一对多的依赖关系。当一个对象的状态发生改变时，所有依赖于它的对象都得到通知并自动更新。这种模式通常用于实现事件驱动的系统，其中对象之间通过观察彼此的状态变化来响应。 ### 适用场景 - 当一个对象需要通知多个其他对象时。 - 当一个对象的改变需要同时改变其他对象，而不知道具体有多少对象有待改变。 - 不希望这些对象是紧密耦合的。 ### 核心概念 - **Subject（目标）**：被观察者，提供了添加、删除和通知观察者的方法。 - **ConcreteSubject（具体目标）**：具体目标的子类，实现了Subject的接口，并在其状态改变时通知所有观察者。 - **Observer（观察者）**：接口，声明了更新数据的方法。 - **ConcreteObserver（具体观察者）**：实现了观察者接口的具体对象，存储了与具体目标相关的状态信息，并在状态改变时更新自身。 ### 代码示例 以下是使用PHP实现观察者模式的一个简单示例： #### 1. 定义Subject和Observer接口 ```php // Subject.php interface Subject { public function attach(Observer $observer); public function detach(Observer $observer); public function notify(); } // Observer.php interface Observer { public function update(Subject $subject); } ``` #### 2. 实现ConcreteSubject（具体目标） ```php // ConcreteSubject.php class ConcreteSubject implements Subject { private $observers = []; public function attach(Observer $observer) { $this->observers[] = $observer; } public function detach(Observer $observer) { $this->observers = array_diff($this->observers, [$observer]); } public function notify() { foreach ($this->observers as $observer) { $observer->update($this); } } public function doSomething() { // 执行业务逻辑... $this->notify(); } } ``` #### 3. 实现ConcreteObserver（具体观察者） ```php // ConcreteObserverA.php class ConcreteObserverA implements Observer { private $subject; public function __construct(ConcreteSubject $subject) { $this->subject = $subject; } public function update(Subject $subject) { if ($subject->status < 5) { echo "ConcreteObserverA: 我接受到状态，并做出了相应的反应。\n"; } } } // ConcreteObserverB.php class ConcreteObserverB implements Observer { private $subject; public function __construct(ConcreteSubject $subject) { $this->subject = $subject; } public function update(Subject $subject) { if ($subject->status < 5) { echo "ConcreteObserverB: 我接受到状态，并做出了相应的反应。\n"; } } } ``` #### 4. 客户端调用 ```php // ObserversController.php class ObserversController { public function index() { $subject = new ConcreteSubject(); $obA = new ConcreteObserverA($subject); $obB = new ConcreteObserverB($subject); $subject->attach($obA); $subject->attach($obB); $subject->doSomething(); $subject->detach($obB); $subject->doSomething(); } } ``` #### 5. 运行结果展示 ``` 添加一个观察者 Subject: 我做了一些业务... 添加一个观察者 添加一个观察者 Subject: 业务状态小于5时观察者才做出反应，当前业务状态: 7 已通知观察者 已通知观察者 Subject: 我做了一些业务... Subject: 业务状态小于5时观察者才做出反应，当前业务状态: 3 已通知观察者 已通知观察者 Subject: 我做了一些业务... Subject: 业务状态小于5时观察者才做出反应，当前业务状态: 1 已通知观察者 已通知观察者 结束 ``` 在这个示例中，我们创建了一个`ConcreteSubject`（具体目标）对象，并实现了它的`attach`、`detach`和`notify`方法。我们还创建了两个具体的观察者`ConcreteObserverA`和`ConcreteObserverB`，它们实现了`Observer`接口，并重写了`update`方法以便在状态改变时做出响应。最后，我们在`ObserversController`中创建了几个观察者实例，并通过调用`index`方法来演示观察者如何响应观察者的状态改变。

正文

设计模式

 

一、介绍

观察者模式是一种行为设计模式，当一个对象的状态发生改变时，依赖（观察）它的对象会接收到通知，并进行自动的更新操作。

举例：某公司发布了一款新的手机，性能很强大，许多人都想买，但是该公司又没宣布售卖时间。想买的人为了第一时间就拥有这台手机，就必须每天到官网或线下实体店看有没有出售，这样对于用户来说体验很不好。如果不想频繁的去查看，这时想买手机的用户就可以在实体店或网站上留下联系方式，等到手机出售的当天公司通过邮件或者短信的形式通知到购买者。

 

二、优缺点

优点：

  • 符合开闭原则。 无需修改发布者代码就能引入新的观察者类 。
  • 可以在运行时建立对象之间的联系。

缺点：

  • 无法设置订阅者收到的顺序
  • 当观察者对象很多时，通知的发布会花费很多时间，影响程序的效率

 

三、核心结构

  • Subject（目标）：被观察者，它是指被观察的对象。 类中有一个用来存放观察者对象的容器，这个容器是被观察者类的核心。其中还有几个方法：
    • attach方法是向这个容器中添加观察者对象。
    • detach方法是从容器中移除观察者对象。
    • notify方法是依次调用观察者对象的对应方法。
  • ConcreteSubject（具体目标）：目标类的具体子类，当它的状态发生改变时，向它的各个观察者发出通知。同时它还实现了在目标类中定义的抽象业务逻辑方法（如果有的话）。
  • Observer（观察者）：观察者将对观察目标的改变做出反应，观察者一般定义为接口，该接口声明了更新数据的方法 update()。
  • ConcreteObserver（具体观察者）：在具体观察者中维护一个指向具体目标对象的引用，它存储具体观察者的有关状态，这些状态需要和具体目标的状态保持一致，它实现了在观察者 Observer 中定义的 update()方法。

 

四、代码实现

1、在PHP中已经有相关的Subject（目标）和Observer（观察者）接口了，我们可以拿来直接实现。分别是SplSubject和SplObserver接口，以下代码就是以这两个接口为例进行编写。其中还用到一个SplObjectStorage类，它也是PHP中的一个类，用于存储和管理对象。它是一个关联数组，其中键是对象的哈希值，值是对象本身。

1.1、实现ConcreteSubject（具体目标）

<?php
/**
 * Created by PhpStorm
 * Author: fengzi
 * Date: 2024/5/17
 * Time: 10:43
 */

namespace app\admin\service\mode\observers;

use SplObserver;

/**
 * 观察者模式
 * 使用PHP自带的观察者设计模式
 */
class ObserversService implements \SplSubject
{
    public int $status;

    private $observers;

    public function __construct()
    {
        $this->observers = new \SplObjectStorage();
    }

    /**
     * 添加观察者
     * @param SplObserver $observer
     * @return void
     * @Author: fengzi
     * @Date: 2024/5/20 17:50
     */
    public function attach(SplObserver $observer)
    {
        // TODO: Implement attach() method.
        echo "添加一个观察者\n";
        $this->observers->attach($observer);
    }

    /**
     * 删除观察者
     * @param SplObserver $observer
     * @return void
     * @Author: fengzi
     * @Date: 2024/5/20 17:50
     */
    public function detach(SplObserver $observer)
    {
        // TODO: Implement detach() method.
        echo "\n分离一个观察者\n";
        $this->observers->detach($observer);
    }

    /**
     * 通知观察者
     * @return void
     * @Author: fengzi
     * @Date: 2024/5/20 17:51
     */
    public function notify()
    {
        // TODO: Implement notify() method.
        echo "已通知观察者\n";
        foreach ($this->observers as $observer) {
            $observer->update($this);
        }
    }

    /**
     * 实现被观察者业务，并通知观察者
     * @return void
     * @Author: fengzi
     * @Date: 2024/5/20 17:51
     */
    public function doSomeLogic(): void
    {
        echo "\nSubject: 我做了一些业务...\n";
        $this->status = rand(0, 10);

        echo "Subject: 业务状态小于5时观察者才做出反应，当前业务状态: {$this->status}\n";
        $this->notify();
    }
}

 

1.2、实现ConcreteObserver（具体观察者），我这里实现了两个观察者，分别为 ConcreteObserverB 和 ConcreteObserverA 。

<?php
/**
 * Created by PhpStorm
 * Author: fengzi
 * Date: 2024/5/17
 * Time: 10:54
 */

namespace app\admin\service\mode\observers;

use SplSubject;

class ConcreteObserverB implements \SplObserver
{

    public function update(SplSubject $subject)
    {
        // TODO: Implement update() method.
        if ($subject->status < 5) {
            echo "ConcreteObserverB: 我接受到状态，并做出了相应的反应。\n";
        }
    }
}

 

<?php
/**
 * Created by PhpStorm
 * Author: fengzi
 * Date: 2024/5/17
 * Time: 10:54
 */

namespace app\admin\service\mode\observers;

use SplSubject;

class ConcreteObserverA implements \SplObserver
{

    public function update(SplSubject $subject)
    {
        // TODO: Implement update() method.
        if ($subject->status < 5) {
            echo "ConcreteObserverA: 我接受到状态，并做出了相应的反应。\n";
        }
    }
}

 

1.3、客户端调用

<?php
/**
 * Created by PhpStorm
 * Author: fengzi
 * Date: 2024/5/17
 * Time: 10:34
 */

namespace app\admin\controller\mode\observers;

use app\admin\service\mode\observers\ConcreteObserverA;
use app\admin\service\mode\observers\ConcreteObserverB;
use app\admin\service\mode\observers\ObserversService;

/**
 * 观察者模式客户端调用
 */
class ObserversController
{
    public function index()
    {
        // 创建被观察者
        $subject = new ObserversService();

        // 创建观察者
        $obA = new ConcreteObserverA();
        $obB = new ConcreteObserverB();

        // 注册观察者
        $subject->attach($obA);
        $subject->attach($obB);

        // 被观察者执行业务逻辑并通知给观察者
        $subject->doSomeLogic();

        // 移除观察者
        $subject->detach($obB);

        // 被观察者执行业务逻辑并通知给观察者
        $subject->doSomeLogic();

        dd('结束');
    }
}

 

1.4、客户端调用结果展示

 

2、上面介绍了使用PHP本身观察者设计模式的接口，下面就自己手写一个观察者模式。

2.1、实现Subject（目标）接口

<?php
/**
 * Created by PhpStorm
 * Author: fengzi
 * Date: 2024/5/21
 * Time: 10:52
 */

namespace app\admin\service\mode\observers\my;

/**
 * 被观察者接口
 */
interface Subject
{
    /**
     * 添加观察者对象
     * @param Observer $observer    观察者对象
     * @return mixed
     * @Author: fengzi
     * @Date: 2024/5/21 10:56
     */
    public function attach(Observer $observer);

    /**
     * 删除观察者对象
     * @param Observer $observer    观察者对象
     * @return mixed
     * @Author: fengzi
     * @Date: 2024/5/21 10:56
     */
    public function detach(Observer $observer);

    /**
     * 通知观察者
     * @return mixed
     * @Author: fengzi
     * @Date: 2024/5/21 10:54
     */
    public function notify();

}

 

2.2、实现ConcreteSubject（具体目标）

<?php
/**
 * Created by PhpStorm
 * Author: fengzi
 * Date: 2024/5/21
 * Time: 10:54
 */

namespace app\admin\service\mode\observers\my;

class ConcreteSubject implements Subject
{
    public int $status;

    private array $observers = [];

    public function attach(Observer $observer)
    {
        // TODO: Implement attach() method.
        echo "添加一个观察者\n";
        if ( !in_array($observer, $this->observers, true) ) {
            $this->observers[] = $observer;
        }
    }

    public function detach(Observer $observer)
    {
        // TODO: Implement detach() method.
        echo "\n分离一个观察者：".get_class($observer)."\n";
        if ( in_array($observer, $this->observers, true) ) {
            unset($this->observers[array_search($observer, $this->observers, true)]);
        }
    }

    public function notify()
    {
        // TODO: Implement notify() method.
        echo "已通知观察者\n";
        foreach ($this->observers as $observer) {
            $observer->update($this);
        }
    }

    public function doSomething()
    {
        echo "\nSubject: 我做了一些业务...\n";
        $this->status = rand(0, 10);

        echo "Subject: 业务状态小于5时观察者才做出反应，当前业务状态: {$this->status}\n";
        $this->notify();
    }
}

 

2.3、实现Observer（观察者）

<?php
/**
 * Created by PhpStorm
 * Author: fengzi
 * Date: 2024/5/21
 * Time: 10:57
 */

namespace app\admin\service\mode\observers\my;

/**
 * 观察者接口
 */
interface Observer
{
    public function update(Subject $subject);
}

 

2.4、实现ConcreteObserver（具体观察者），分别为 ConcreteObserverB 和 ConcreteObserverA 。

<?php
/**
 * Created by PhpStorm
 * Author: fengzi
 * Date: 2024/5/21
 * Time: 10:58
 */

namespace app\admin\service\mode\observers\my;

/**
 * 具体观察者A
 */
class ConcreteObserverA implements Observer
{
    public function update(Subject $subject)
    {
        // TODO: Implement update() method.
        if ($subject->status < 5) {
            echo "ConcreteObserverA: 我接受到状态，并做出了相应的反应。\n";
        }
    }
}

 

<?php
/**
 * Created by PhpStorm
 * Author: fengzi
 * Date: 2024/5/21
 * Time: 11:06
 */

namespace app\admin\service\mode\observers\my;

class ConcreteObserverB implements Observer
{

    public function update(Subject $subject)
    {
        // TODO: Implement update() method.
        if ($subject->status < 5) {
            echo "ConcreteObserverB: 我接受到状态，并做出了相应的反应。\n";
        }
    }
}

 

2.5、客户端调用

<?php
/**
 * Created by PhpStorm
 * Author: fengzi
 * Date: 2024/5/17
 * Time: 10:34
 */

namespace app\admin\controller\mode\observers;

use app\admin\service\mode\observers\ConcreteObserverA;
use app\admin\service\mode\observers\ConcreteObserverB;
use app\admin\service\mode\observers\my\ConcreteSubject;
use app\admin\service\mode\observers\ObserversService;

/**
 * 观察者模式客户端调用
 */
class ObserversController
{
    /**
     * 使用PHP自带的观察者模式
     * @return void
     * @Author: fengzi
     * @Date: 2024/5/21 11:18
     */
    public function index()
    {
        // 创建被观察者
        $subject = new ObserversService();

        // 创建观察者
        $obA = new ConcreteObserverA();
        $obB = new ConcreteObserverB();

        // 注册观察者
        $subject->attach($obA);
        $subject->attach($obB);

        // 被观察者执行业务逻辑并通知给观察者
        $subject->doSomeLogic();

        // 移除观察者
        $subject->detach($obB);

        // 被观察者执行业务逻辑并通知给观察者
        $subject->doSomeLogic();

        dd('结束');
    }

    /**
     * 使用自定义的观察者模式
     * @return void
     * @Author: fengzi
     * @Date: 2024/5/21 11:18
     */
    public function mySubject()
    {
        // 创建被观察者
        $subject = new ConcreteSubject();

        // 创建观察者
        $obA = new \app\admin\service\mode\observers\my\ConcreteObserverA();
        $obB = new \app\admin\service\mode\observers\my\ConcreteObserverB();

        // 注册观察者
        $subject->attach($obA);
        $subject->attach($obB);

        // 被观察者执行业务逻辑并通知给观察者
        $subject->doSomething();

        // 移除观察者
        $subject->detach($obB);

        // 被观察者执行业务逻辑并通知给观察者
        $subject->doSomething();

        dd('结束');
    }
}

 

2.6、运行结果展示

 

与【设计模式】观察者模式相似的内容：

【设计模式】观察者模式

设计模式 【设计模式】工厂方法模式 【设计模式】抽象工厂模式 【设计模式】单例模式 【设计模式】策略模式 【设计模式】观察者模式 一、介绍 观察者模式是一种行为设计模式，当一个对象的状态发生改变时，依赖（观察）它的对象会接收到通知，并进行自动的更新操作。 举例：某公司发布了一款新的手机，性能很强大，

0
设计模式学习（二十四）：Spring 中使用到的设计模式

设计模式学习（二十四）：Spring 中使用到的设计模式 作者：Grey 原文地址： 博客园：设计模式学习（二十四）：Spring 中使用到的设计模式 CSDN：设计模式学习（二十四）：Spring 中使用到的设计模式 观察者模式 定义一个继承 ApplicationEvent 的事件；定义一个实现

设计模式 学习 二十四 spring
192
Netty-介绍-1

Netty介绍和应用场景 要求 已经掌握了 主要技术构成： Java OOP 编程、 Java 多线程编程、 Java IO 编程 、 Java 网络编程、 常用的Java 设计模式(比如 观察者模式 ，命令模式，职责链模式 )、 常用的数据结构(比如 链表) Netty的介绍 1、Netty 是由

netty 介绍
58
设计模式学习（十三）：观察者模式

设计模式学习（十三）：观察者模式 作者：Grey 原文地址： 博客园：设计模式学习（十三）：观察者模式 CSDN：设计模式学习（十三）：观察者模式 观察者模式 观察者模式是一种行为型模式。在对象之间定义一个一对多的依赖，当一个对象状态改变的时候，所有依赖的对象都会自动收到通知。 一般可以用做事件处理

设计模式 学习 十三 观察者
356
软件设计模式系列之二十一——观察者模式

观察者模式（Observer Pattern）是一种行为型设计模式，它允许对象之间建立一对多的依赖关系，当一个对象的状态发生变化时，所有依赖于它的对象都会得到通知并自动更新。这个模式也被称为发布-订阅模式，因为它模拟了一个主题（发布者）与多个观察者（订阅者）之间的关系。观察者模式主要用于实现对象之间...

软件设计 模式 系列 之二
4
设计模式之订阅发布模式

# 一、简介 订阅发布模式（Publish-Subscribe Pattern）是一种行之有效的解耦框架与业务逻辑的方式，也是一种常见的观察者设计模式，它被广泛应用于事件驱动架构中。 在这个模式中，发布者（或者说是主题）并不直接发送消息给订阅者，而是通过调度中心（或者叫消息代理）来传递消息。 发布者

设计模式 订阅 发布 模式
280
视频剪辑中生成花字特效的代码案例详述

本文为阿里云智能媒体服务IMS「云端智能剪辑」实践指南第四期，通过运用官方提供的花字模版或自定义设计花字，完成丰富、精美的花字特效视频剪辑。 昱尘｜作者 在视频后期剪辑中，“花字”是一种特别的存在。 通过使用适合视频的花字，不仅可以丰富视频内容，还可以让视频传达的信息更加容易让用户接受，加深观众对于

视频剪辑 生成 特效 代码
17
程序设计思路-球连球组成的群

编码设计有很多思路，都是在简化映射实际问题时遇到的问题。 之前和别人交流，得到一句“把它放在同一个地方好维护”，相同的功能只出现在一个地方。就会出现代码的聚合设计，也就是一种通用的功能索引，或者说面向对象的思想。 首先程序可以被观察成，计算、存储、缓存、链接，这是代码打交道的四个方面。由它组成了一个

0
【转帖】nginx变量使用方法详解-1

https://www.diewufeiyang.com/post/575.html Nginx 的配置文件使用的就是一门微型的编程语言，许多真实世界里的 Nginx 配置文件其实就是一个一个的小程序。当然，是不是“图灵完全的”暂且不论，至少据我观察，它在设计上受 Perl 和 Bourne She

nginx 变量 使用 方法
0
[转帖]Linux性能优化和内核观测 - 内存篇（一）

内存虚拟内存Linux 采用的是​​虚拟内存​​机制，每个进程都有自己的虚拟内存地址空间，仅当实际使用内存的时候才会映射到物理内存地址之上。这种设计提供了物理内存的超额分配，Linux 中的内存管理机制包括页换出守护进程（page out daemon）、物理换页设备（swap device），以及

linux 性能 优化 内核
0
# 热门排行
微软 New Bing AI 申请与使用保姆级教程（免魔法） ChatGPT API使用介绍 ChatGPT开发实战 一篇带你了解如何使用纯前端类Excel表格构建现金流量表 手把手教你玩转 Excel 数据透视表 为什么 C# 可能是最好的第一编程语言 .NET 入门到高级路线 提高工作效率的神器：基于前端表格实现Chrome Excel扩展插件 React + Springboot + Quartz，从0实现Excel报表自动化 用Echarts实现前端表格引用从属关系可视化
© PmDaddy. 2023 PmDaddy教程网 All rights reserved.