From 487d2611343680144361d1d340297bc135e4a04a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=90=91=E6=9E=97?= Date: Sat, 22 Apr 2023 02:23:34 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8F=98=E6=9B=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../{WebSocketServer.php => WebSocket.php} | 30 +------------------ 1 file changed, 1 insertion(+), 29 deletions(-) rename Abstracts/{WebSocketServer.php => WebSocket.php} (78%) diff --git a/Abstracts/WebSocketServer.php b/Abstracts/WebSocket.php similarity index 78% rename from Abstracts/WebSocketServer.php rename to Abstracts/WebSocket.php index cca8285..f075fdf 100644 --- a/Abstracts/WebSocketServer.php +++ b/Abstracts/WebSocket.php @@ -18,23 +18,10 @@ use Swoole\Server; use Swoole\WebSocket\Frame; -class WebSocketServer extends Component implements OnHandshakeInterface, OnMessageInterface, OnDisconnectInterface, OnCloseInterface +class WebSocket extends Component implements OnHandshakeInterface, OnMessageInterface, OnDisconnectInterface, OnCloseInterface { - public string $host = '127.0.0.1'; - - - public int $port = 6086; - - - public array $events = []; - - public array $settings = []; - - public int $socket_type = SWOOLE_SOCK_TCP6; - - public Handler $handler; @@ -50,21 +37,6 @@ class WebSocketServer extends Component implements OnHandshakeInterface, OnMessa */ public function init(): void { - /** @var Server $server */ - $application = \Kiri::service(); - if (!$application->has('server')) { - $server = new \Swoole\WebSocket\Server($this->host, $this->port, SWOOLE_PROCESS); - $application->set('server', $server); - } else { - $server = $application->get('server'); - } - - $socket = $server->addlistener($this->host, $this->port, $this->socket_type); - $socket->set($this->settings); - $socket->on('handshake', [$this, 'onHandshake']); - $socket->on('message', [$this, 'onMessage']); - $socket->on('disconnect', [$this, 'onDisconnect']); - $this->collector = \Kiri::getDi()->get(DataGrip::class)->get('wss'); $this->handler = $this->collector->query('/', 'GET');