PHP 怎么PHP 事件回顾

wen PHP项目 2026-07-27 191

本文目录导读：

PHP 怎么PHP 事件回顾

使用观察者模式实现事件
自定义事件系统
使用Composer包（推荐）
WordPress风格的事件系统
使用闭包和匿名类
最佳实践建议

我理解您想了解PHP中事件机制的实现方式，PHP不像JavaScript那样原生支持事件监听，但我们可以通过几种模式来实现类似的功能,让我为您详细介绍：

使用观察者模式实现事件

这是最常用的方式，通过SplSubject和SplObserver接口：

<?php
// 事件类（被观察者）
class EventManager implements SplSubject {
    private $observers = [];
    private $eventData;
    public function attach(SplObserver $observer) {
        $this->observers[] = $observer;
    }
    public function detach(SplObserver $observer) {
        $key = array_search($observer, $this->observers, true);
        if ($key !== false) {
            unset($this->observers[$key]);
        }
    }
    public function notify() {
        foreach ($this->observers as $observer) {
            $observer->update($this);
        }
    }
    public function setEventData($data) {
        $this->eventData = $data;
        $this->notify();
    }
    public function getEventData() {
        return $this->eventData;
    }
}
// 观察者（事件监听器）
class LoggerObserver implements SplObserver {
    public function update(SplSubject $subject) {
        echo "日志记录: " . $subject->getEventData() . "\n";
    }
}
class EmailObserver implements SplObserver {
    public function update(SplSubject $subject) {
        echo "发送邮件通知: " . $subject->getEventData() . "\n";
    }
}
// 使用示例
$eventManager = new EventManager();
$eventManager->attach(new LoggerObserver());
$eventManager->attach(new EmailObserver());
$eventManager->setEventData("用户注册成功");
?>

自定义事件系统

更灵活的实现方式：

<?php
class EventDispatcher {
    private static $listeners = [];
    // 注册事件监听
    public static function listen($event, $callback, $priority = 0) {
        self::$listeners[$event][] = [
            'callback' => $callback,
            'priority' => $priority
        ];
        // 按优先级排序
        usort(self::$listeners[$event], function($a, $b) {
            return $b['priority'] - $a['priority'];
        });
    }
    // 触发事件
    public static function dispatch($event, $data = null) {
        if (!isset(self::$listeners[$event])) {
            return;
        }
        foreach (self::$listeners[$event] as $listener) {
            call_user_func($listener['callback'], $data);
        }
    }
    // 移除监听器
    public static function remove($event, $callback = null) {
        if ($callback === null) {
            unset(self::$listeners[$event]);
        } else {
            if (isset(self::$listeners[$event])) {
                foreach (self::$listeners[$event] as $key => $listener) {
                    if ($listener['callback'] === $callback) {
                        unset(self::$listeners[$event][$key]);
                    }
                }
            }
        }
    }
}
// 使用示例
EventDispatcher::listen('user.register', function($data) {
    echo "发送欢迎邮件给: " . $data['email'] . "\n";
}, 10);
EventDispatcher::listen('user.register', function($data) {
    echo "记录用户日志: " . $data['username'] . "\n";
}, 5);
EventDispatcher::dispatch('user.register', [
    'username' => '张三',
    'email' => 'zhangsan@example.com'
]);
?>

使用Composer包（推荐）

在生产环境中,建议使用成熟的库：

Symfony EventDispatcher

composer require symfony/event-dispatcher

<?php
use Symfony\Component\EventDispatcher\EventDispatcher;
use Symfony\Component\EventDispatcher\Event;
// 自定义事件
class UserRegisteredEvent extends Event {
    const NAME = 'user.registered';
    private $user;
    public function __construct($user) {
        $this->user = $user;
    }
    public function getUser() {
        return $this->user;
    }
}
// 事件监听器
$dispatcher = new EventDispatcher();
$dispatcher->addListener(UserRegisteredEvent::NAME, function(UserRegisteredEvent $event) {
    echo "用户注册: " . $event->getUser()['name'] . "\n";
});
$dispatcher->dispatch(new UserRegisteredEvent(['name' => '张三']), UserRegisteredEvent::NAME);
?>

WordPress风格的事件系统

<?php
class EventSystem {
    private static $actions = [];
    private static $filters = [];
    // 添加动作钩子
    public static function addAction($hook, $callback, $priority = 10, $acceptedArgs = 1) {
        self::$actions[$hook][$priority][] = [
            'callback' => $callback,
            'acceptedArgs' => $acceptedArgs
        ];
    }
    // 执行动作
    public static function doAction($hook, ...$args) {
        if (!isset(self::$actions[$hook])) {
            return;
        }
        ksort(self::$actions[$hook]);
        foreach (self::$actions[$hook] as $priority => $actions) {
            foreach ($actions as $action) {
                call_user_func_array($action['callback'], array_slice($args, 0, $action['acceptedArgs']));
            }
        }
    }
    // 添加过滤器
    public static function addFilter($hook, $callback, $priority = 10, $acceptedArgs = 1) {
        self::$filters[$hook][$priority][] = [
            'callback' => $callback,
            'acceptedArgs' => $acceptedArgs
        ];
    }
    // 应用过滤器
    public static function applyFilters($hook, $value, ...$args) {
        if (!isset(self::$filters[$hook])) {
            return $value;
        }
        ksort(self::$filters[$hook]);
        foreach (self::$filters[$hook] as $priority => $filters) {
            foreach ($filters as $filter) {
                $args = array_merge([$value], array_slice($args, 0, $filter['acceptedArgs'] - 1));
                $value = call_user_func_array($filter['callback'], $args);
            }
        }
        return $value;
    }
}
// 使用示例
EventSystem::addAction('user_login', function($username) {
    echo "用户 {$username} 登录成功\n";
});
EventSystem::addFilter('message', function($message) {
    return "【系统消息】" . $message;
});
EventSystem::doAction('user_login', '张三');
echo EventSystem::applyFilters('message', "欢迎回来");
?>

使用闭包和匿名类

<?php
class Event {
    private $listeners = [];
    public function on($event, callable $listener) {
        $this->listeners[$event][] = $listener;
        return $this;
    }
    public function emit($event, ...$args) {
        if (!isset($this->listeners[$event])) {
            return;
        }
        foreach ($this->listeners[$event] as $listener) {
            call_user_func_array($listener, $args);
        }
    }
    public function once($event, callable $listener) {
        $onceListener = function(...$args) use ($listener, $event, &$onceListener) {
            $this->removeListener($event, $onceListener);
            call_user_func_array($listener, $args);
        };
        $this->on($event, $onceListener);
    }
    private function removeListener($event, $listener) {
        if (isset($this->listeners[$event])) {
            $key = array_search($listener, $this->listeners[$event], true);
            if ($key !== false) {
                unset($this->listeners[$event][$key]);
            }
        }
    }
}
// 使用示例
$event = new Event();
$event->on('data', function($data) {
    echo "收到数据: " . json_encode($data) . "\n";
});
$event->once('init', function() {
    echo "初始化事件（只执行一次）\n";
});
$event->emit('init');
$event->emit('init'); // 不会执行
$event->emit('data', ['name' => '张三', 'age' => 25]);
?>