as2252258/kiri-http-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

变更

Browse Source
This commit is contained in:
向林
2023-04-22 02:23:34 +08:00
parent ace208f467
commit 487d261134
1 changed files with 1 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Abstracts/WebSocketServer.php → Abstracts/WebSocket.php
+1 -29
View File
@@ -18,23 +18,10 @@ use Swoole\Server;
use Swoole\WebSocket\Frame; 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; public Handler $handler;
@@ -50,21 +37,6 @@ class WebSocketServer extends Component implements OnHandshakeInterface, OnMessa
*/ */
public function init(): void 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->collector = \Kiri::getDi()->get(DataGrip::class)->get('wss');
$this->handler = $this->collector->query('/', 'GET'); $this->handler = $this->collector->query('/', 'GET');