initialize 事件(即框架初始化事件)
框架初始化事件，在執(zhí)行 initialize 初始化事件時(shí)，EasySwoole 框架此刻已經(jīng)完成了如下工作：
- 加載配置文件
- 初始化
Log/Temp目錄，完成系統(tǒng)默認(rèn)Log/Temp目錄的定義
函數(shù)原型
public static function initialize(): void
{
}開(kāi)發(fā)者自定義處理
開(kāi)發(fā)者可以在 initialize 事件可以進(jìn)行如下修改：
- 修改框架默認(rèn)使用的
error_report級(jí)別，使用自定義的error_report級(jí)別 - 修改框架默認(rèn)使用的
Logger處理器，使用自定義的Logger處理器 - 修改框架默認(rèn)使用的
Trigger處理器，使用自定義的Trigger處理器 - 修改框架默認(rèn)使用的
Error處理器，使用自定義的Error處理器 - 修改框架默認(rèn)使用的
Shutdown處理器，使用自定義的Shutdown處理器 - 修改框架默認(rèn)使用的
HttpException全局處理器，使用自定義的HttpException全局處理器 - 設(shè)置
Http全局OnRequest及AfterRequest事件 - 注冊(cè)數(shù)據(jù)庫(kù)、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');
// 開(kāi)發(fā)者自定義設(shè)置 錯(cuò)誤級(jí)別
\EasySwoole\Component\Di::getInstance()->set(\EasySwoole\EasySwoole\SysConst::ERROR_REPORT_LEVEL, E_ALL);
// 開(kāi)發(fā)者自定義設(shè)置 日志處理類(lèi)(該類(lèi)需要實(shí)現(xiàn) \EasySwoole\Log\LoggerInterface，開(kāi)發(fā)者可自行查看并實(shí)現(xiàn)，方便開(kāi)發(fā)者自定義處理日志)
$logDir = EASYSWOOLE_LOG_DIR; // 定義日志存放目錄
$loggerHandler = new \EasySwoole\Log\Logger($logDir); // 定義日志處理對(duì)象
\EasySwoole\Component\Di::getInstance()->set(SysConst::LOGGER_HANDLER, $loggerHandler);
// 開(kāi)發(fā)者自定義設(shè)置 Trace 追蹤器(該類(lèi)需要實(shí)現(xiàn) \EasySwoole\Trigger\TriggerInterface，開(kāi)發(fā)者可自行查看并實(shí)現(xiàn)，方便開(kāi)發(fā)者自定義處理 Trace 鏈路)
// Trace 追蹤器需要依據(jù)上面的 logger_handler
\EasySwoole\Component\Di::getInstance()->set(SysConst::TRIGGER_HANDLER, new \EasySwoole\Trigger\Trigger($loggerHandler));
// 開(kāi)發(fā)者自定義設(shè)置 error_handler
\EasySwoole\Component\Di::getInstance()->set(\EasySwoole\EasySwoole\SysConst::ERROR_HANDLER, function ($errorCode, $description, $file = null, $line = null) {
// 開(kāi)發(fā)者對(duì)錯(cuò)誤進(jìn)行處理
});
// 開(kāi)發(fā)者自定義設(shè)置 shutdown
\EasySwoole\Component\Di::getInstance()->set(\EasySwoole\EasySwoole\SysConst::SHUTDOWN_FUNCTION, function () {
// 開(kāi)發(fā)者對(duì) shutdown 進(jìn)行處理
});
// 開(kāi)發(fā)者自定義設(shè)置 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);
});
// 開(kāi)發(fā)者自定義設(shè)置 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 中已定義，不必重新設(shè)置
});
// 開(kāi)發(fā)者自定義設(shè)置 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 中已定義，不必重新設(shè)置
});
// 注冊(cè)數(shù)據(jù)庫(kù)連接及連接池(詳見(jiàn)：http://www.b3f21.cn/Components/Orm/install.html)
// 注冊(cè) Redis 連接及連接池(詳見(jiàn)：http://www.b3f21.cn/Components/Redis/introduction.html)
}
public static function mainServerCreate(EventRegister $register)
{
}
}啟用前(在 initialize 事件中)調(diào)用協(xié)程 API
開(kāi)發(fā)者在 EasySwoole 主服務(wù)啟動(dòng)前調(diào)用協(xié)程 api，必須使用如下操作：
$scheduler = new \Swoole\Coroutine\Scheduler();
$scheduler->add(function() {
/* 調(diào)用協(xié)程API */
});
$scheduler->start();
// 清除全部定時(shí)器
\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() {
/* 調(diào)用協(xié)程API */
});
$scheduler->start();
// 清除全部定時(shí)器
\Swoole\Timer::clearAll();
}
public static function mainServerCreate(EventRegister $register)
{
}
}在 initialize 事件中調(diào)用連接池
initialize 事件在 EasySwoole 生命周期中屬于 主進(jìn)程，因此在主進(jìn)程中創(chuàng)建了連接池可能會(huì)導(dǎo)致以下問(wèn)題：
- 創(chuàng)建了全局的定時(shí)器
- 創(chuàng)建了全局的
EventLoop - 創(chuàng)建的連接被跨進(jìn)程公用，因此我們以服務(wù)啟動(dòng)前調(diào)用數(shù)據(jù)庫(kù)
ORM為例：
服務(wù)啟動(dòng)前調(diào)用數(shù)據(jù)庫(kù) ORM：
下文
\EasySwoole\EasySwoole\Config::getInstance()->getConf('MYSQL')獲取的 MYSQL 配置，詳細(xì)參考 配置文件
<?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));
// 創(chuàng)建一個(gè)協(xié)程調(diào)度器
$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，避免連接被克隆到子進(jìn)程，造成連接跨進(jìn)程公用。
// DbManager 如果有注冊(cè)多庫(kù)連接，請(qǐng)記得一起 getConnection($name) 獲取全部的 pool 去執(zhí)行 reset
// 其他的連接池請(qǐng)獲取到對(duì)應(yīng)的 pool，然后執(zhí)行 reset() 方法
// ORM 1.4.31 版本之前請(qǐng)使用 getClientPool()
// DbManager::getInstance()->getConnection()->getClientPool()->reset();
\EasySwoole\ORM\DbManager::getInstance()->getConnection()->__getClientPool()->reset();
});
//執(zhí)行調(diào)度器內(nèi)注冊(cè)的全部回調(diào)
$scheduler->start();
//清理調(diào)度器內(nèi)可能注冊(cè)的定時(shí)器，不要影響到swoole server 的event loop
\Swoole\Timer::clearAll();
}
public static function mainServerCreate(EventRegister $register)
{
}
}