as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

改名

Browse Source
This commit is contained in:
Mr·x
2021-08-18 19:11:19 +08:00
parent 7a2f8e0e00
commit d2731aa8b9
2 changed files with 46 additions and 46 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Server/Worker/OnServerWorker.php
+32 -32
View File
@@ -5,20 +5,18 @@ namespace Server\Worker;
use Annotation\Annotation;
use Annotation\Inject;
use Exception;
use Kiri\Abstracts\Config;
use Kiri\Core\Help;
use Kiri\Events\EventDispatch;
use Kiri\Exception\ConfigException;
use Kiri\Kiri;
use Kiri\Runtime;
use ReflectionException;
use Server\Constant;
use Server\Events\OnAfterWorkerStart;
use Server\Events\OnWorkerError;
use Server\Events\OnWorkerExit;
use Server\Events\OnWorkerStart;
use Server\Events\OnWorkerStop;
use Kiri\Abstracts\Config;
use Kiri\Core\Help;
use Kiri\Events\EventDispatch;
use Kiri\Exception\ConfigException;
use Kiri\Exception\NotFindClassException;
use Kiri\Runtime;
use Kiri\Kiri;
use Swoole\Server;
use Swoole\Timer;
@@ -45,18 +43,37 @@ class OnServerWorker extends \Server\Abstracts\Server
*/
public function onWorkerStart(Server $server, int $workerId)
{
$this->_setConfigCache($workerId);
$this->eventDispatch->dispatch(new OnWorkerStart($server, $workerId));
$this->onWorkerStartInit($server, $workerId);
$this->eventDispatch->dispatch(new OnAfterWorkerStart());
}
/**
* @param Server $server
* @param int $workerId
* @throws ConfigException
* @throws ReflectionException
* @throws Exception
*/
private function onWorkerStartInit(Server $server, int $workerId)
{
putenv('state=start');
putenv('worker=' . $workerId);
$serialize = file_get_contents(storage(Runtime::CONFIG_NAME));
if (!empty($serialize)) {
Config::sets(unserialize($serialize));
}
$annotation = Kiri::app()->getAnnotation();
$annotation->read(APP_PATH . 'app', 'App',
$workerId < $server->setting['worker_num'] ? [] : [CONTROLLER_PATH]
);
$this->eventDispatch->dispatch(new OnWorkerStart($server, $workerId));
$this->workerInitExecutor($server, $annotation, $workerId);
// $this->interpretDirectory($annotation);
$this->eventDispatch->dispatch(new OnAfterWorkerStart());
$this->interpretDirectory($annotation);
}
@@ -113,23 +130,6 @@ class OnServerWorker extends \Server\Abstracts\Server
}
/**
* @param $worker_id
* @throws Exception
*/
private function _setConfigCache($worker_id)
{
putenv('state=start');
putenv('worker=' . $worker_id);
$serialize = file_get_contents(storage(Runtime::CONFIG_NAME));
if (empty($serialize)) {
return;
}
Config::sets(unserialize($serialize));
}
/**
* @param Server $server
* @param int $workerId