mainServerCreate 事件(即主服務創建事件)

函數原型

/**
 * @param \EasySwoole\EasySwoole\Swoole\EventRegister $register
 */
public static function mainServerCreate(EventRegister $register)
{

}

已完成工作

在執行主服務創建事件時，框架此時已經完成的工作有：

• bootstrap/initialize 事件加載完成
• 主 SwooleServer 創建成功
• 主 SwooleServer 注冊了默認的 onRequest/onWorkerStart/onWorkerStop/onWorkerExit 事件。

開發者可進行的操作有：

• 注冊主服務回調事件
• 添加子服務監聽
• SwooleTable/Atomic
• 創建自定義進程
• 啟用前(在 mainServerCreate 事件中)調用協程 API

注冊主服務回調事件

例如：為主服務注冊 onWorkerStart 回調事件：

/** @var \EasySwoole\EasySwoole\Swoole\EventRegister $register **/
$register->add($register::onWorkerStart, function (\Swoole\Server $server,int $workerId){
     var_dump($workerId . 'start');
});

例如：為主服務增加 onMessage 回調事件（前提是主服務類型為 WebSocket 服務）：

// 給 server 注冊相關事件，在 WebSocket 服務模式下 message 事件必須注冊 
/** @var \EasySwoole\EasySwoole\Swoole\EventRegister $register **/
$register->set($register::onMessage,function (\Swoole\WebSocket\Server $server, \Swoole\WebSocket\Frame $frame){

});

添加子服務監聽

例如：添加一個 tcp 子服務監聽

/** @var \Swoole\Server\Port $subPort **/
$subPort = \EasySwoole\EasySwoole\ServerManager::getInstance()->getSwooleServer()->addListener('0.0.0.0', 9503, SWOOLE_TCP);
$subPort->on('receive', function (\Swoole\Server $server, int $fd, int $reactor_id, string $data){
    var_dump($data);
});
// 配置 具體查看 Swoole 文檔
$subPort->set([

]);

具體可參考 TCP

Table && Atomic

具體調用方式請看具體章節：

Table

Atomic

創建自定義進程

具體詳細操作可到 基礎使用 -> 自定義進程中查看

\EasySwoole\Component\Process\Manager::getInstance()->addProcess(new Test('test_process'));

Test 是 EasySwoole\Component\Process\AbstractProcess 抽象類的子類

啟用前(在 mainServerCreate 事件中)調用協程 API

開發者在 EasySwoole 主服務啟動前調用協程 api，必須使用如下操作：

$scheduler = new \Swoole\Coroutine\Scheduler();
$scheduler->add(function() {
    /* 調用協程API */
});
$scheduler->start();
// 清除全部定時器
\Swoole\Timer::clearAll();