initialize 事件(即框架初始化事件)
框架初始化事件,在执行 initialize
初始化事件时,EasySwoole
框架此刻已经完成了如下工作:
- 加载配置文件
- 初始化
Log/Temp
目录,完成系统默认Log/Temp
目录的定义
函数原型
public static function initialize(): void
{
}
开发者自定义处理
开发者可以在 initialize
事件可以进行如下修改:
- 修改框架默认使用的
error_report
级别,使用自定义的error_report
级别 - 修改框架默认使用的
Logger
处理器,使用自定义的Logger
处理器 - 修改框架默认使用的
Trigger
处理器,使用自定义的Trigger
处理器 - 修改框架默认使用的
Error
处理器,使用自定义的Error
处理器 - 修改框架默认使用的
Shutdown
处理器,使用自定义的Shutdown
处理器 - 修改框架默认使用的
HttpException
全局处理器,使用自定义的HttpException
全局处理器 - 设置
Http
全局OnRequest
及AfterRequest
事件 - 注册数据库、Redis 连接池
具体可查看 SysConst.php
使用示例代码:
<?php
namespace EasySwoole\EasySwoole;
use EasySwoole\EasySwoole\AbstractInterface\Event;
use EasySwoole\EasySwoole\Swoole\EventRegister;
class EasySwooleEvent implements Event
{
public static function initialize()
{
// TODO: Implement initialize() method.
date_default_timezone_set('Asia/Shanghai');
// 开发者自定义设置 错误级别
\EasySwoole\Component\Di::getInstance()->set(\EasySwoole\EasySwoole\SysConst::ERROR_REPORT_LEVEL, E_ALL);
// 开发者自定义设置 日志处理类(该类需要实现 \EasySwoole\Log\LoggerInterface,开发者可自行查看并实现,方便开发者自定义处理日志)
$logDir = EASYSWOOLE_LOG_DIR; // 定义日志存放目录
$loggerHandler = new \EasySwoole\Log\Logger($logDir); // 定义日志处理对象
\EasySwoole\Component\Di::getInstance()->set(SysConst::LOGGER_HANDLER, $loggerHandler);
// 开发者自定义设置 Trace 追踪器(该类需要实现 \EasySwoole\Trigger\TriggerInterface,开发者可自行查看并实现,方便开发者自定义处理 Trace 链路)
// Trace 追踪器需要依据上面的 logger_handler
\EasySwoole\Component\Di::getInstance()->set(SysConst::TRIGGER_HANDLER, new \EasySwoole\Trigger\Trigger($loggerHandler));
// 开发者自定义设置 error_handler
\EasySwoole\Component\Di::getInstance()->set(\EasySwoole\EasySwoole\SysConst::ERROR_HANDLER, function ($errorCode, $description, $file = null, $line = null) {
// 开发者对错误进行处理
});
// 开发者自定义设置 shutdown
\EasySwoole\Component\Di::getInstance()->set(\EasySwoole\EasySwoole\SysConst::SHUTDOWN_FUNCTION, function () {
// 开发者对 shutdown 进行处理
});
// 开发者自定义设置 HttpException 全局处理器
\EasySwoole\Component\Di::getInstance()->set(\EasySwoole\EasySwoole\SysConst::HTTP_EXCEPTION_HANDLER, function ($throwable, Request $request, Response $response) {
$response->withStatus(\EasySwoole\Http\Message\Status::CODE_INTERNAL_SERVER_ERROR);
$response->write(nl2br($throwable->getMessage() . "\n" . $throwable->getTraceAsString()));
Trigger::getInstance()->throwable($throwable);
});
// 开发者自定义设置 onRequest v3.4.x+
\EasySwoole\Component\Di::getInstance()->set(\EasySwoole\EasySwoole\SysConst::HTTP_GLOBAL_ON_REQUEST, function (\EasySwoole\Http\Request $request, \EasySwoole\Http\Response $response) {
// v3.4.x 之前的版本 onRequest 事件在 EasySwoolEvent.php 中已定义,不必重新设置
});
// 开发者自定义设置 afterRequest v3.4.x+
\EasySwoole\Component\Di::getInstance()->set(\EasySwoole\EasySwoole\SysConst::HTTP_GLOBAL_AFTER_REQUEST, function (\EasySwoole\Http\Request $request, \EasySwoole\Http\Response $response) {
// v3.4.x 之前的版本 afterRequest 事件在 EasySwoolEvent.php 中已定义,不必重新设置
});
// 注册数据库连接及连接池(详见:https://www.easyswoole.com/Components/Orm/install.html)
// 注册 Redis 连接及连接池(详见:https://www.easyswoole.com/Components/Redis/introduction.html)
}
public static function mainServerCreate(EventRegister $register)
{
}
}
启用前(在 initialize 事件中)调用协程 API
开发者在 EasySwoole
主服务启动前调用协程 api
,必须使用如下操作:
$scheduler = new \Swoole\Coroutine\Scheduler();
$scheduler->add(function() {
/* 调用协程API */
});
$scheduler->start();
// 清除全部定时器
\Swoole\Timer::clearAll();
具体使用示例:
<?php
namespace EasySwoole\EasySwoole;
use EasySwoole\EasySwoole\AbstractInterface\Event;
use EasySwoole\EasySwoole\Swoole\EventRegister;
class EasySwooleEvent implements Event
{
public static function initialize()
{
// TODO: Implement initialize() method.
date_default_timezone_set('Asia/Shanghai');
$scheduler = new \Swoole\Coroutine\Scheduler();
$scheduler->add(function() {
/* 调用协程API */
});
$scheduler->start();
// 清除全部定时器
\Swoole\Timer::clearAll();
}
public static function mainServerCreate(EventRegister $register)
{
}
}
在 initialize 事件中调用连接池
initialize
事件在 EasySwoole
生命周期中属于 主进程
,因此在主进程中创建了连接池可能会导致以下问题:
- 创建了全局的定时器
- 创建了全局的
EventLoop
- 创建的连接被跨进程公用,因此我们以服务启动前调用数据库
ORM
为例:
服务启动前调用数据库 ORM
:
下文
\EasySwoole\EasySwoole\Config::getInstance()->getConf('MYSQL')
获取的 MYSQL 配置,详细参考 配置文件
<?php
namespace EasySwoole\EasySwoole;
use EasySwoole\EasySwoole\AbstractInterface\Event;
use EasySwoole\EasySwoole\Swoole\EventRegister;
class EasySwooleEvent implements Event
{
public static function initialize()
{
// TODO: Implement initialize() method.
date_default_timezone_set('Asia/Shanghai');
$config = new \EasySwoole\ORM\Db\Config(\EasySwoole\EasySwoole\Config::getInstance()->getConf('MYSQL'));
\EasySwoole\ORM\DbManager::getInstance()->addConnection(new \EasySwoole\ORM\Db\Connection($config));
// 创建一个协程调度器
$scheduler = new \Swoole\Coroutine\Scheduler();
$scheduler->add(function () {
$builder = new \EasySwoole\Mysqli\QueryBuilder();
$builder->raw('select version()');
\EasySwoole\ORM\DbManager::getInstance()->query($builder, true);
// 这边重置 ORM 连接池的 pool,避免连接被克隆到子进程,造成连接跨进程公用。
// DbManager 如果有注册多库连接,请记得一起 getConnection($name) 获取全部的 pool 去执行 reset
// 其他的连接池请获取到对应的 pool,然后执行 reset() 方法
// ORM 1.4.31 版本之前请使用 getClientPool()
// DbManager::getInstance()->getConnection()->getClientPool()->reset();
\EasySwoole\ORM\DbManager::getInstance()->getConnection()->__getClientPool()->reset();
});
//执行调度器内注册的全部回调
$scheduler->start();
//清理调度器内可能注册的定时器,不要影响到swoole server 的event loop
\Swoole\Timer::clearAll();
}
public static function mainServerCreate(EventRegister $register)
{
}
}