From b41096636c77ee984fc9d52f406d0f1e0b1e4ac9 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mr=C2=B7x?= Date: Mon, 8 Mar 2021 18:23:46 +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 --- HttpServer/Events/OnConnect.php | 10 +++++++--- HttpServer/Server.php | 2 +- 2 files changed, 8 insertions(+), 4 deletions(-) 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); } }