diff --git a/kiri-websocket-server/Sender.php b/kiri-websocket-server/Sender.php index 4f08cd94..821c2f69 100644 --- a/kiri-websocket-server/Sender.php +++ b/kiri-websocket-server/Sender.php @@ -8,7 +8,6 @@ class Sender public function push($fd, $data) { - } diff --git a/kiri-websocket-server/Server.php b/kiri-websocket-server/Server.php index b5c27a58..dc2d5897 100644 --- a/kiri-websocket-server/Server.php +++ b/kiri-websocket-server/Server.php @@ -63,6 +63,10 @@ class Server extends AbstractServer implements OnHandshakeInterface, OnMessageIn */ public function onClose(\Swoole\Server $server, int $fd): void { + $clientInfo = $server->getClientInfo($fd); + if (!isset($clientInfo['websocket_status'])) { + return; + } if ($this->callback instanceof OnCloseInterface) { $this->callback->onClose($server, $fd); }