### 1、什么是消息事件机制
消息事件，主要用于消息通知，又或者消息处理，属于行为状态的一种业务处理机制。

消息事件最少需要提供两个方法：`注册事件`和`调用事件`。

例如在生活中举个例子：

银行取钱，ATM机需要校验密码，触发取款，成功后触发短信余额通知。

那么这台ATM机，就需要提前注册以下3个事件，否则无法正常使用：
```
校验密码（passwordCheck）
触发取款（withdrawMoney）
成功后触发短信余额通知（reminderBalance）
```

### 2、消息事件机制与回调事件机制的区别

消息事件在使用前，需要提前注册好相应的事件处理信息。

回调事件主要针对业务回调类的触发，并不需要提前注册好相关服务。

同时，消息事件，主要针对消息分发的处理。

而，回调事件，主要针对回调的处理。

两者之间的应用场景有所不同。

### 3、封装消息事件管理类
```php
class Event
{
    /**
     * 事件注册队列
    */
    public static $list = [];
    
    /**
     * 绑定
     * @todo 无
     * @author 小黄牛
     * @version v2.5.6 + 2021-09-15
     * @deprecated 暂不启用
     * @global 无
     * @param string $name 事件名称
     * @param mixed $function 事件类
     * @param mixed $function 事件方法
     * @return void
    */
    public static function listen($name, $function, $action=null) {
        $name = strtolower($name);
        if (isset(self::$list[$name])) {
            throw new \Exception("Event：{$name} has been registered！");
            return false;
        }
        // 闭包
        if (is_callable($function)) {
            self::$list[$name] = $function;
        // 动态类
        } else if (is_object($function)) {
            $action = !empty($action) ? $action : 'run';
            $function = [$function, $action];
        // 静态类，字符串函数
        } else {
            self::$list[$name] = $function;
        }

self::$list[$name] = $function;
        return true;
    }

/**
     * 触发
     * @todo 无
     * @author 小黄牛
     * @version v2.5.6 + 2021-09-15
     * @deprecated 暂不启用
     * @global 无
     * @param string $name 事件名称
     * @param array $arg 事件额外参数
     * @return void
    */
    public static function trigger($name, ...$arg) {
        $name = strtolower($name);
        if (isset(self::$list[$name]) == false) {
            throw new \Exception("Event：{$name} does not exist！");
            return false;
        }
        $function = self::$list[$name];

// 闭包
        if (is_callable($function)) {
            return call_user_func_array($function, $arg);
        // 动态类
        } else if (is_object($function)) {
            return call_user_func_array([$function[0], $function[1]], $arg);
        }
        //  字符串函数 或 静态方法
        return call_user_func_array($function, $arg);
    }
}
// 测试事件处理场景
class Demo
{
    public function testA($text, $msg) {
        echo $text.$msg.'<br/>';
    }
    public static function testB($text, $msg) {
        echo $text.$msg.'<br/>';
    }
}
function testC($text, $msg) {
    echo $text.$msg.'<br/>';
}
// 注册消息事件
Event::listen('A', new Demo, 'testA');
Event::listen('B', 'Demo::testB');
Event::listen('C', 'testC');
Event::listen('D', function ($text, $msg) {
    echo $text.$msg.'<br/>';
});
// 调用消息事件
Event::trigger('A', '我是', 'Demo->testA');
Event::trigger('B', '我是', 'Demo::testB');
Event::trigger('C', '我是', 'testC()');
Event::trigger('D', '我是', '匿名函数');
// 当调用不存在的事件
Event::trigger('E', '我是', '不存在报错');
```

### 4、实现银行案例的代码
```php
class Event
{
    /**
     * 事件注册队列
    */
    public static $list = [];
    
    /**
     * 绑定
     * @todo 无
     * @author 小黄牛
     * @version v2.5.6 + 2021-09-15
     * @deprecated 暂不启用
     * @global 无
     * @param string $name 事件名称
     * @param mixed $function 事件类
     * @param mixed $function 事件方法
     * @return void
    */
    public static function listen($name, $function, $action=null) {
        $name = strtolower($name);
        if (isset(self::$list[$name])) {
            throw new \Exception("Event：{$name} has been registered！");
            return false;
        }
        // 闭包
        if (is_callable($function)) {
            self::$list[$name] = $function;
        // 动态类
        } else if (is_object($function)) {
            $action = !empty($action) ? $action : 'run';
            $function = [$function, $action];
        // 静态类，字符串函数
        } else {
            self::$list[$name] = $function;
        }

self::$list[$name] = $function;
        return true;
    }

/**
     * 触发
     * @todo 无
     * @author 小黄牛
     * @version v2.5.6 + 2021-09-15
     * @deprecated 暂不启用
     * @global 无
     * @param string $name 事件名称
     * @param array $arg 事件额外参数
     * @return void
    */
    public static function trigger($name, ...$arg) {
        $name = strtolower($name);
        if (isset(self::$list[$name]) == false) {
            throw new \Exception("Event：{$name} does not exist！");
            return false;
        }
        $function = self::$list[$name];

// 闭包
        if (is_callable($function)) {
            return call_user_func_array($function, $arg);
        // 动态类
        } else if (is_object($function)) {
            return call_user_func_array([$function[0], $function[1]], $arg);
        }
        //  字符串函数 或 静态方法
        return call_user_func_array($function, $arg);
    }
}
// 银行事件处理场景
class Atm
{
    // 验证密码
    public static function passwordCheck($pwd) {
        if ($pwd == '123456') return true;
        return false;
    }
    // 取钱
    public static function withdrawMoney($money) {
        if ($money > 100 || $money < 0) return false;
        return true;
    }
    // 余额通知
    public static function reminderBalance($phone) {
        echo '客户：'.$phone.'，您的余额不足，当前剩余：99.12元';
    }
}
// 注册消息事件
Event::listen('passwordCheck', 'Atm::passwordCheck');
Event::listen('withdrawMoney', 'Atm::withdrawMoney');
Event::listen('reminderBalance', 'Atm::reminderBalance');
// 调用消息事件
$pwd = 123456;
$money = 50;
$phone = 15900000000;
// 鉴权
if (Event::trigger('passwordCheck', $pwd)) {
    // 取钱
    if (Event::trigger('withdrawMoney', $money)) {
        // 通知余额
        Event::trigger('reminderBalance', $phone);
    }
}
```

已有0条评论

添加新评论☺

如果认为本文对您有所帮助请赞助本站

支付宝扫一扫赞助

已有0条评论

添加新评论☺