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

eee

Browse Source
This commit is contained in:
whwyy
2023-11-29 14:36:28 +08:00
parent 6fc21e0557
commit ddfbf85fee
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Abstracts/AsyncServer.php
+6 -4
View File
@@ -15,6 +15,7 @@ use Kiri\Server\ServerInterface;
use Kiri\Server\Task\Task; use Kiri\Server\Task\Task;
use ReflectionException; use ReflectionException;
use Swoole\Server; use Swoole\Server;
use Symfony\Component\Console\Output\OutputInterface;
/** /**
* *
@@ -149,14 +150,15 @@ class AsyncServer implements ServerInterface
if ($port === false) { if ($port === false) {
throw new Exception('Listen port fail.' . swoole_last_error()); throw new Exception('Listen port fail.' . swoole_last_error());
} }
$writeln = Kiri::getDi()->get(OutputInterface::class);
if ($config->type == Constant::SERVER_TYPE_HTTP) { if ($config->type == Constant::SERVER_TYPE_HTTP) {
file_put_contents('php://output', 'Add http port listen ' . $config->host . '::' . $config->port, FILE_APPEND); $writeln->writeln('Add http port listen ' . $config->host . '::' . $config->port);
} else if ($config->type == Constant::SERVER_TYPE_WEBSOCKET) { } else if ($config->type == Constant::SERVER_TYPE_WEBSOCKET) {
file_put_contents('php://output', 'Add wss port listen ' . $config->host . '::' . $config->port, FILE_APPEND); $writeln->writeln('Add wss port listen ' . $config->host . '::' . $config->port);
} else if ($config->type == Constant::SERVER_TYPE_UDP) { } else if ($config->type == Constant::SERVER_TYPE_UDP) {
file_put_contents('php://output', 'Add udp port listen ' . $config->host . '::' . $config->port, FILE_APPEND); $writeln->writeln('Add udp port listen ' . $config->host . '::' . $config->port);
} else { } else {
file_put_contents('php://output', 'Add tcp port listen ' . $config->host . '::' . $config->port, FILE_APPEND); $writeln->writeln('Add tcp port listen ' . $config->host . '::' . $config->port);
} }
$port->set($this->resetSettings($config->type, $config->settings)); $port->set($this->resetSettings($config->type, $config->settings));