PHP如何实现一个观察者模式_PHP观察者设计模式实现步骤

SplSubject

SplObserver

SplSubject

attach

detach

notify

<?php

class OrderSubject implements SplSubject
{
    private array $observers = []; // 存储观察者对象
    private string $orderStatus;   // 主题的内部状态，比如订单状态

    public function __construct()
    {
        // 使用 SplObjectStorage 可以更好地管理对象集合，尤其是移除时
        $this->observers = new SplObjectStorage();
    }

    /**
     * 附加一个观察者到主题。
     * @param SplObserver $observer
     */
    public function attach(SplObserver $observer): void
    {
        echo "附加观察者: " . get_class($observer) . "\n";
        $this->observers->attach($observer);
    }

    /**
     * 从主题中分离一个观察者。
     * @param SplObserver $observer
     */
    public function detach(SplObserver $observer): void
    {
        echo "分离观察者: " . get_class($observer) . "\n";
        $this->observers->detach($observer);
    }

    /**
     * 通知所有观察者，主题的状态已改变。
     */
    public function notify(): void
    {
        echo "通知所有观察者...\n";
        foreach ($this->observers as $observer) {
            $observer->update($this); // 调用观察者的 update 方法
        }
    }

    /**
     * 改变订单状态，并触发通知。
     * @param string $status
     */
    public function setOrderStatus(string $status): void
    {
        if ($this->orderStatus !== $status) { // 只有状态真正改变才通知
            $this->orderStatus = $status;
            echo "订单状态已改变为: " . $status . "\n";
            $this->notify(); // 关键：状态改变后调用通知
        } else {
            echo "订单状态未改变，无需通知。\n";
        }
    }

    /**
     * 获取当前订单状态
     * @return string
     */
    public function getOrderStatus(): string
    {
        return $this->orderStatus;
    }
}

SplObserver

update

<?php

// 邮件通知观察者
class EmailNotifier implements SplObserver
{
    /**
     * 接收主题的更新通知。
     * @param SplSubject $subject
     */
    public function update(SplSubject $subject): void
    {
        if ($subject instanceof OrderSubject) {
            echo "EmailNotifier: 正在发送邮件通知，订单状态为: " . $subject->getOrderStatus() . "\n";
            // 这里可以集成邮件发送服务，比如调用一个邮件发送类
            // Mailer::send($subject->getCustomerEmail(), "订单更新", "您的订单状态已变为: " . $subject->getOrderStatus());
        }
    }
}

// 日志记录观察者
class LoggerObserver implements SplObserver
{
    /**
     * 接收主题的更新通知。
     * @param SplSubject $subject
     */
    public function update(SplSubject $subject): void
    {
        if ($subject instanceof OrderSubject) {
            echo "LoggerObserver: 正在记录订单状态日志: " . $subject->getOrderStatus() . "\n";
            // 这里可以集成日志服务，比如写入文件或数据库
            // Log::info("订单 ID: " . $subject->getOrderId() . " 状态更新为: " . $subject->getOrderStatus());
        }
    }
}

// 短信通知观察者
class SmsNotifier implements SplObserver
{
    public function update(SplSubject $subject): void
    {
        if ($subject instanceof OrderSubject) {
            echo "SmsNotifier: 正在发送短信通知，订单状态为: " . $subject->getOrderStatus() . "\n";
            // 这里可以集成短信发送服务
        }
    }
}

<?php

// 创建主题（订单）
$order = new OrderSubject();

// 创建不同的观察者
$emailNotifier = new EmailNotifier();
$logger = new LoggerObserver();
$smsNotifier = new SmsNotifier();

echo "--- 第一次状态改变 ---\n";
// 附加观察者到订单主题
$order->attach($emailNotifier);
$order->attach($logger);
$order->attach($smsNotifier);

// 改变订单状态，所有附加的观察者都会收到通知
$order->setOrderStatus("Processing");
echo "\n";

echo "--- 第二次状态改变 ---\n";
// 再次改变订单状态
$order->setOrderStatus("Shipped");
echo "\n";

echo "--- 分离观察者后 ---\n";
// 分离一个观察者，比如邮件通知不再需要
$order->detach($emailNotifier);

// 再次改变订单状态，被分离的观察者将不再收到通知
$order->setOrderStatus("Delivered");
echo "\n";

// 如果状态没有实际改变，则不会触发通知
$order->setOrderStatus("Delivered");

EmailNotifier