PHP 观察者模式 (`Observer Pattern`)：事件驱动与发布/订阅

嘿，大家好！今天咱们来聊聊PHP里的观察者模式，这玩意儿听起来高大上，其实用起来贼简单，就像你订阅了喜欢的博主的更新，他一发文章，你就收到通知，差不多就这意思。

一、啥是观察者模式？（别被名字吓到）

想象一下，你是个游戏主播，每天直播《王者荣耀》。你的粉丝们都很关心你啥时候开播，如果让他们每天都来你直播间刷屏问“播了吗？播了吗？”，你肯定受不了，而且效率太低。观察者模式就像给你装了个自动通知系统。粉丝们（观察者）订阅了你的直播间（主题），你开始直播（主题状态改变）的时候，系统自动通知他们（主题通知观察者）。

简单来说，观察者模式是一种行为设计模式，它定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象。当主题对象的状态发生改变时，所有依赖它的观察者都会收到通知并自动更新。

二、为什么要用观察者模式？（这很重要）

解耦！解耦！还是解耦！ 观察者模式能让你把主题对象和观察者对象分离开来，它们之间不需要知道彼此的具体实现。这样，你可以随意增删观察者，而不用修改主题对象的代码。就像你可以随时取消关注某个博主，而不用通知他。
事件驱动架构： 观察者模式是实现事件驱动架构的基础。比如，用户注册成功后，你需要发送邮件、短信、增加积分等等。这些操作都可以作为观察者，监听用户注册事件。
发布/订阅模式： 观察者模式是发布/订阅模式的一个实现。主题对象发布事件，观察者对象订阅事件。
可扩展性： 可以方便地添加新的观察者，而无需修改主题对象的代码。这使得系统更加灵活和可维护。

三、观察者模式的组成部分（就这么几个）

组件	描述	示例 (游戏主播)
主题 (Subject)	也称为可观察者 (Observable)。它维护一个观察者列表，并提供添加、删除观察者的方法。当状态发生改变时，它负责通知所有观察者。	你的直播间。负责维护粉丝列表，并在开始直播时通知所有粉丝。
观察者 (Observer)	定义了一个更新接口，当接到主题的通知时，观察者会调用这个接口进行更新。	你的粉丝。收到直播开始的通知后，他们会打开直播间观看。
具体主题 (ConcreteSubject)	主题的具体实现。存储主题的状态，并在状态改变时通知所有观察者。	你的直播间，存储着当前是否正在直播的状态。当你开始直播时，状态变为“正在直播”，然后通知所有粉丝。
具体观察者 (ConcreteObserver)	观察者的具体实现。实现更新接口，并在接到通知时执行相应的操作。	你的粉丝的手机APP，收到直播开始的通知后，会弹出一个消息提醒，并提供快速进入直播间的链接。

四、 PHP代码实现（敲黑板，划重点啦！）

咱们先来个简单的例子，模拟一个新闻发布系统：

<?php

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

// 2. 主题接口 (Subject Interface)
interface Subject {
    public function attach(Observer $observer);
    public function detach(Observer $observer);
    public function notify();
}

// 3. 具体主题 (Concrete Subject) - 新闻发布者
class NewsPublisher implements Subject {
    private $observers = [];
    private $news;

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

    public function detach(Observer $observer): void {
        // PHP 数组操作有点坑，要遍历查找，找到再 unset
        foreach ($this->observers as $key => $value) {
            if ($value === $observer) {
                unset($this->observers[$key]);
                // 重新索引，避免出现索引断层
                $this->observers = array_values($this->observers);
                break;
            }
        }
    }

    public function notify(): void {
        echo "新闻发布啦！通知所有订阅者...n";
        foreach ($this->observers as $observer) {
            $observer->update($this);
        }
    }

    public function setNews(string $news): void {
        $this->news = $news;
        $this->notify(); // 发布新闻时通知所有观察者
    }

    public function getNews(): string {
        return $this->news;
    }
}

// 4. 具体观察者 (Concrete Observer) - 订阅者
class Subscriber implements Observer {
    private $name;

    public function __construct(string $name) {
        $this->name = $name;
    }

    public function update(Subject $subject): void {
        echo $this->name . " 收到新闻： " . $subject->getNews() . "n";
    }
}

// 客户端代码
$publisher = new NewsPublisher();

$subscriber1 = new Subscriber("张三");
$subscriber2 = new Subscriber("李四");
$subscriber3 = new Subscriber("王五");

$publisher->attach($subscriber1);
$publisher->attach($subscriber2);
$publisher->attach($subscriber3);

$publisher->setNews("今天天气真好！");

$publisher->detach($subscriber2); // 李四取消订阅

$publisher->setNews("明天要下雨了！");

?>

代码解释：

Observer 接口：定义了 update() 方法，观察者通过这个方法接收主题的通知。
Subject 接口：定义了 attach(), detach(), notify() 方法，用于添加、删除和通知观察者。
NewsPublisher 类：具体的主题，实现了 Subject 接口。它维护了一个观察者列表 $observers，并提供了 setNews() 方法来设置新闻内容，设置新闻内容后，它会调用 notify() 方法通知所有观察者。
Subscriber 类：具体的观察者，实现了 Observer 接口。它实现了 update() 方法，当收到主题的通知时，会输出订阅者姓名和收到的新闻内容。
客户端代码：创建了一个 NewsPublisher 对象和三个 Subscriber 对象。然后将三个订阅者添加到发布者的订阅列表。之后发布两条新闻，并取消李四的订阅，最后再发布一条新闻。

运行结果：

新闻发布啦！通知所有订阅者...
张三 收到新闻： 今天天气真好！
李四 收到新闻： 今天天气真好！
王五 收到新闻： 今天天气真好！
新闻发布啦！通知所有订阅者...
张三 收到新闻： 明天要下雨了！
王五 收到新闻： 明天要下雨了！

五、深入一点，聊聊事件驱动（进阶篇）

观察者模式是事件驱动架构的基础。咱们用一个更贴近实际的例子来说明：用户注册。

<?php

// 1. 事件类 (Event)
class UserRegisteredEvent {
    private $userId;
    private $email;

    public function __construct(int $userId, string $email) {
        $this->userId = $userId;
        $this->email = $email;
    }

    public function getUserId(): int {
        return $this->userId;
    }

    public function getEmail(): string {
        return $this->email;
    }
}

// 2. 事件监听器接口 (EventListener Interface)
interface EventListener {
    public function handle(UserRegisteredEvent $event);
}

// 3. 事件管理器 (EventManager)
class EventManager implements Subject {
    private $listeners = [];

    public function attach(Observer $listener, string $eventName): void {
        $this->listeners[$eventName][] = $listener;
    }

    public function detach(Observer $listener, string $eventName): void {
        if (isset($this->listeners[$eventName])) {
            foreach ($this->listeners[$eventName] as $key => $value) {
                if ($value === $listener) {
                    unset($this->listeners[$eventName][$key]);
                    $this->listeners[$eventName] = array_values($this->listeners[$eventName]);
                    break;
                }
            }
        }
    }

    public function notify(string $eventName, UserRegisteredEvent $event): void {
        if (isset($this->listeners[$eventName])) {
            foreach ($this->listeners[$eventName] as $listener) {
                $listener->handle($event);
            }
        }
    }

    // Subject接口需要实现的方法，但在此场景下可以留空，因为事件管理器直接使用notify
    public function attach(Observer $observer){}
    public function detach(Observer $observer){}
}

// 4. 具体事件监听器 (Concrete Event Listener) - 发送欢迎邮件
class SendWelcomeEmailListener implements EventListener {
    public function handle(UserRegisteredEvent $event): void {
        echo "发送欢迎邮件给: " . $event->getEmail() . "n";
        // 实际场景中，这里会调用邮件发送服务
    }
}

// 5. 具体事件监听器 (Concrete Event Listener) - 增加用户积分
class AddUserPointsListener implements EventListener {
    public function handle(UserRegisteredEvent $event): void {
        echo "为用户 " . $event->getUserId() . " 增加积分n";
        // 实际场景中，这里会调用积分服务
    }
}

// 6. 用户注册服务 (User Registration Service)
class UserService {
    private $eventManager;

    public function __construct(EventManager $eventManager) {
        $this->eventManager = $eventManager;
    }

    public function register(string $email): int {
        // 模拟用户注册
        $userId = rand(1000, 9999);
        echo "用户 " . $email . " 注册成功，用户ID: " . $userId . "n";

        // 触发用户注册事件
        $event = new UserRegisteredEvent($userId, $email);
        $this->eventManager->notify("user.registered", $event);

        return $userId;
    }
}

// 客户端代码
$eventManager = new EventManager();

// 注册事件监听器
$eventManager->attach(new SendWelcomeEmailListener(), "user.registered");
$eventManager->attach(new AddUserPointsListener(), "user.registered");

$userService = new UserService($eventManager);
$userService->register("[email protected]");

?>

代码解释：

UserRegisteredEvent 类：事件类，包含了用户注册事件的相关信息，例如用户ID和邮箱。
EventListener 接口：事件监听器接口，定义了 handle() 方法，用于处理事件。
EventManager 类：事件管理器，负责维护事件和监听器的关系，并负责触发事件。注意，这里使用了一个数组 $listeners 来存储事件和监听器的关系，键是事件名称，值是监听器数组。
SendWelcomeEmailListener 类：具体事件监听器，负责发送欢迎邮件。
AddUserPointsListener 类：具体事件监听器，负责增加用户积分。
UserService 类：用户注册服务，负责处理用户注册逻辑。在用户注册成功后，会触发 user.registered 事件。
客户端代码：创建了一个 EventManager 对象，并注册了两个事件监听器。然后创建了一个 UserService 对象，并调用 register() 方法注册用户。

运行结果：

用户 [email protected] 注册成功，用户ID: 3456
发送欢迎邮件给: [email protected]
为用户 3456 增加积分

这个例子展示了如何使用观察者模式来实现一个简单的事件驱动架构。当用户注册成功后，会自动发送欢迎邮件并增加用户积分，而这些操作都是通过事件监听器来实现的，用户注册服务本身并不需要知道这些操作的具体实现。

六、观察者模式的优缺点（任何东西都有两面性）

优点：

降低耦合度： 主题和观察者之间解耦，使得它们可以独立地改变。
提高可扩展性： 可以方便地添加新的观察者，而无需修改主题的代码。
支持广播通信： 主题可以同时通知多个观察者。
符合开闭原则： 可以对主题和观察者进行扩展，而无需修改已有的代码。

缺点：

可能导致性能问题： 如果观察者过多，或者通知的操作比较耗时，可能会影响性能。
可能导致循环依赖： 如果观察者和主题之间存在循环依赖，可能会导致程序崩溃。
难以调试： 由于主题和观察者之间是间接依赖关系，因此调试起来比较困难。
通知顺序不确定： 观察者的执行顺序是不确定的，这可能会导致一些问题。

七、 PHP内置的SplSubject 和 SplObserver (偷懒专用)

PHP提供了一组内置的接口 SplSubject 和 SplObserver，可以简化观察者模式的实现。

<?php

// 1. 具体主题 (Concrete Subject) - 新闻发布者
class SplNewsPublisher implements SplSubject {
    private $observers;
    private $news;

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

    public function attach(SplObserver $observer): void {
        $this->observers->attach($observer);
    }

    public function detach(SplObserver $observer): void {
        $this->observers->detach($observer);
    }

    public function notify(): void {
        echo "新闻发布啦！通知所有订阅者...n";
        foreach ($this->observers as $observer) {
            $observer->update($this);
        }
    }

    public function setNews(string $news): void {
        $this->news = $news;
        $this->notify(); // 发布新闻时通知所有观察者
    }

    public function getNews(): string {
        return $this->news;
    }
}

// 2. 具体观察者 (Concrete Observer) - 订阅者
class SplSubscriber implements SplObserver {
    private $name;

    public function __construct(string $name) {
        $this->name = $name;
    }

    public function update(SplSubject $subject): void {
        echo $this->name . " 收到新闻： " . $subject->getNews() . "n";
    }
}

// 客户端代码
$publisher = new SplNewsPublisher();

$subscriber1 = new SplSubscriber("张三");
$subscriber2 = new SplSubscriber("李四");
$subscriber3 = new SplSubscriber("王五");

$publisher->attach($subscriber1);
$publisher->attach($subscriber2);
$publisher->attach($subscriber3);

$publisher->setNews("今天天气真好！");

$publisher->detach($subscriber2); // 李四取消订阅

$publisher->setNews("明天要下雨了！");

?>

代码解释：

SplSubject 接口： PHP 内置的主题接口，定义了 attach(), detach(), notify() 方法。
SplObserver 接口： PHP 内置的观察者接口，定义了 update() 方法。
SplObjectStorage 类： PHP 内置的用于存储对象的类，可以用来存储观察者。

这个例子和之前的例子功能一样，但是使用了 PHP 内置的 SplSubject 和 SplObserver 接口，代码更加简洁。

八、实际应用场景（举几个栗子）

用户注册： 发送欢迎邮件、增加用户积分、生成用户Token等等。
订单创建： 发送订单确认邮件、扣减库存、生成物流信息等等。
博客文章发布： 通知订阅者、更新搜索引擎索引、推送到社交媒体等等。
数据库记录更新： 缓存失效、更新搜索索引等等。
消息队列： 当消息到达时，通知消费者。
前端框架： Vue.js 和 React.js 等前端框架也使用了观察者模式来实现数据绑定和事件监听。

九、注意事项（避坑指南）

避免循环依赖： 确保观察者和主题之间不存在循环依赖，否则会导致程序崩溃。
注意性能问题： 如果观察者过多，或者通知的操作比较耗时，可能会影响性能。可以考虑使用异步的方式来处理通知。
合理选择通知方式： 根据实际情况选择合适的通知方式，例如同步通知、异步通知、延迟通知等等。
考虑事务性： 如果通知的操作涉及到数据库操作，需要考虑事务性，确保数据的一致性。

十、总结 (划重点！)

观察者模式是一种非常有用的设计模式，可以帮助我们降低耦合度、提高可扩展性，并实现事件驱动架构。虽然观察者模式有一些缺点，但是只要注意避免这些坑，就可以充分发挥它的优势。

希望今天的讲解对大家有所帮助！下次有机会再跟大家聊聊其他的设计模式。拜拜！

发表回复 取消回复

发表回复取消回复