initialize 事件(即框架初始化事件)

框架初始化事件，在執(zhí)行 initialize 初始化事件時(shí)，EasySwoole 框架此刻已經(jīng)完成了如下工作：

加載配置文件
初始化 Log/Temp 目錄，完成系統(tǒng)默認(rèn) Log/Temp 目錄的定義

函數(shù)原型

public static function initialize(): void
{
}

開發(fā)者自定義處理

開發(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');

        // 開發(fā)者自定義設(shè)置 錯(cuò)誤級(jí)別
        \EasySwoole\Component\Di::getInstance()->set(\EasySwoole\EasySwoole\SysConst::ERROR_REPORT_LEVEL, E_ALL);

        // 開發(fā)者自定義設(shè)置 日志處理類(該類需要實(shí)現(xiàn) \EasySwoole\Log\LoggerInterface，開發(fā)者可自行查看并實(shí)現(xiàn)，方便開發(fā)者自定義處理日志)
        $logDir = EASYSWOOLE_LOG_DIR; // 定義日志存放目錄
        $loggerHandler = new \EasySwoole\Log\Logger($logDir); // 定義日志處理對(duì)象
        \EasySwoole\Component\Di::getInstance()->set(SysConst::LOGGER_HANDLER, $loggerHandler);

        // 開發(fā)者自定義設(shè)置 Trace 追蹤器(該類需要實(shí)現(xiàn) \EasySwoole\Trigger\TriggerInterface，開發(fā)者可自行查看并實(shí)現(xiàn)，方便開發(fā)者自定義處理 Trace 鏈路)
        // Trace 追蹤器需要依據(jù)上面的 logger_handler
        \EasySwoole\Component\Di::getInstance()->set(SysConst::TRIGGER_HANDLER, new \EasySwoole\Trigger\Trigger($loggerHandler));

        // 開發(fā)者自定義設(shè)置 error_handler
        \EasySwoole\Component\Di::getInstance()->set(\EasySwoole\EasySwoole\SysConst::ERROR_HANDLER, function ($errorCode, $description, $file = null, $line = null) {
            // 開發(fā)者對(duì)錯(cuò)誤進(jìn)行處理
        });

        // 開發(fā)者自定義設(shè)置 shutdown
        \EasySwoole\Component\Di::getInstance()->set(\EasySwoole\EasySwoole\SysConst::SHUTDOWN_FUNCTION, function () {
            // 開發(fā)者對(duì) shutdown 進(jìn)行處理
        });

        // 開發(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);
        });

        // 開發(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è)置
        });

        // 開發(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.zbjtqy.com/Components/Orm/install.html)
        // 注冊(cè) Redis 連接及連接池(詳見(jiàn)：http://www.zbjtqy.com/Components/Redis/introduction.html)
    }

    public static function mainServerCreate(EventRegister $register)
    {

    }
}

啟用前(在 initialize 事件中)調(diào)用協(xié)程 API

開發(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)
    {

    }
}

easyswoole - 基于swoole扩展实现的一款高性能php框架

initialize 事件(即框架初始化事件)

函數(shù)原型

開發(fā)者自定義處理

啟用前(在 initialize 事件中)調(diào)用協(xié)程 API

在 initialize 事件中調(diào)用連接池