diff --git a/HttpServer/Events/OnConnect.php b/HttpServer/Events/OnConnect.php index 2bf992c3..98239f9e 100644 --- a/HttpServer/Events/OnConnect.php +++ b/HttpServer/Events/OnConnect.php @@ -18,17 +18,21 @@ class OnConnect extends Callback { - /** * @param Server $server * @param int $fd * @param int $reactorId * @throws Exception */ - public function onHandler(\Swoole\Server $server, int $fd, int $reactorId) + public function onHandler(Server $server, int $fd, int $reactorId) { $event = Snowflake::app()->getEvent(); - $event->trigger(Event::RECEIVE_CONNECTION, [$server, $fd, $reactorId]); + + $clientInfo = $server->getClientInfo($fd); + + $name = 'listen ' . $clientInfo['server_port'] . ' ' . Event::RECEIVE_CONNECTION; + + $event->trigger($name, [$server, $fd, $reactorId]); fire(Event::SYSTEM_RESOURCE_RELEASES); logger()->insert(); diff --git a/HttpServer/Server.php b/HttpServer/Server.php index d34fad43..876b6c04 100644 --- a/HttpServer/Server.php +++ b/HttpServer/Server.php @@ -308,7 +308,7 @@ class Server extends HttpService } $event = Snowflake::app()->getEvent(); foreach ($config['events'] as $name => $_event) { - $event->on($name, $_event); + $event->on('listen ' . $config['port'] . ' ' . $name, $_event); } }