From fd2e76944e85d767a71529aa5af6bd309005061e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mr=C2=B7x?= Date: Wed, 21 Jul 2021 16:07:04 +0800 Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E5=90=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- Server/Worker/ServerWorker.php | 24 ++++++++++++++++++++++-- 1 file changed, 22 insertions(+), 2 deletions(-) diff --git a/Server/Worker/ServerWorker.php b/Server/Worker/ServerWorker.php index a4dc568d..12e3baee 100644 --- a/Server/Worker/ServerWorker.php +++ b/Server/Worker/ServerWorker.php @@ -3,11 +3,10 @@ namespace Server\Worker; use Exception; -use Psr\Log\Test\TestLogger; use Server\Constant; -use Server\ServerManager; use Snowflake\Abstracts\Config; use Snowflake\Event; +use Snowflake\Exception\ConfigException; use Snowflake\Runtime; use Snowflake\Snowflake; use Swoole\Server; @@ -40,14 +39,35 @@ class ServerWorker extends \Server\Abstracts\Server $loader = Snowflake::app()->getRouter(); $loader->_loader(); + $this->setProcessName(sprintf('Worker[%d]#%03d.', $server->worker_pid, $workerId)); + $annotation->runtime(CONTROLLER_PATH); $annotation->runtime(MODEL_PATH); } else { + $this->setProcessName(sprintf('Tasker[%d]#%03d.', $server->worker_pid, $workerId)); + $annotation->runtime(APP_PATH, [CONTROLLER_PATH]); } } + /** + * @param $prefix + * @throws ConfigException + */ + private function setProcessName($prefix) + { + if (Snowflake::getPlatform()->isMac()) { + return; + } + $name = Config::get('id', 'system-service') . '.'; + if (!empty($prefix)) { + $name .= '.' . $prefix; + } + swoole_set_process_name($name); + } + + /** * @param $worker_id * @throws Exception