test/hyperf
1
0
Fork 0
mirror of https://gitee.com/hyperf/hyperf.git synced 2024-12-04 20:58:13 +08:00
Code Issues Actions 16 Packages Projects Releases Wiki Activity

Dump server message

Browse Source
This commit is contained in:
huangzhhui 2020-05-27 12:01:37 +08:00
parent 1caae43fed
commit e2800525ea
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/server/src/Listener/AfterWorkerStartListener.php
View File

@ -14,6 +14,7 @@ namespace Hyperf\Server\Listener;
use Hyperf\Contract\StdoutLoggerInterface;
use Hyperf\Event\Contract\ListenerInterface;
use Hyperf\Framework\Event\AfterWorkerStart;
use Hyperf\Server\Event\CoroutineServerStart;
use Hyperf\Server\Server;
use Hyperf\Server\ServerManager;
use Swoole\Server\Port;
@ -37,6 +38,7 @@ class AfterWorkerStartListener implements ListenerInterface
{
return [
AfterWorkerStart::class,
CoroutineServerStart::class,
];
}
@ -46,8 +48,9 @@ class AfterWorkerStartListener implements ListenerInterface
*/
public function process(object $event)
{
/** @var AfterWorkerStart $event */
if ($event->workerId === 0) {
/** @var AfterWorkerStart|CoroutineServerStart $event */
$isCoroutineServer = $event instanceof CoroutineServerStart;
if ($isCoroutineServer || $event->workerId === 0) {
/** @var Port $server */
foreach (ServerManager::list() as $name => [$type, $server]) {
$listen = $server->host . ':' . $server->port;
@ -65,7 +68,8 @@ class AfterWorkerStartListener implements ListenerInterface
break;
}
});
$this->logger->info(sprintf('%s Server listening at %s', $type, $listen));
$serverType = $isCoroutineServer ? 'Coroutine' : '';
$this->logger->info(sprintf('%s %s Server listening at %s', $type, $serverType, $listen));
}
}
}