改名
This commit is contained in:
@@ -106,8 +106,6 @@ class ServerCommand extends Command
|
|||||||
|
|
||||||
Kiri::app()->getRouter()->read_files();
|
Kiri::app()->getRouter()->read_files();
|
||||||
|
|
||||||
$this->eventProvider->dispatch(new OnServerBeforeStart());
|
|
||||||
|
|
||||||
$manager->start();
|
$manager->start();
|
||||||
|
|
||||||
return 1;
|
return 1;
|
||||||
|
|||||||
+13
-5
@@ -2,15 +2,16 @@
|
|||||||
|
|
||||||
namespace Server;
|
namespace Server;
|
||||||
|
|
||||||
use Note\Inject;
|
|
||||||
use Exception;
|
use Exception;
|
||||||
use Kiri\Abstracts\Config;
|
use Kiri\Abstracts\Config;
|
||||||
use Kiri\Di\Container;
|
use Kiri\Di\Container;
|
||||||
use Psr\Container\ContainerInterface;
|
|
||||||
use Kiri\Error\Logger;
|
use Kiri\Error\Logger;
|
||||||
|
use Kiri\Events\EventDispatch;
|
||||||
use Kiri\Exception\ConfigException;
|
use Kiri\Exception\ConfigException;
|
||||||
use Kiri\Kiri;
|
use Kiri\Kiri;
|
||||||
|
use Note\Inject;
|
||||||
use Psr\Container\ContainerExceptionInterface;
|
use Psr\Container\ContainerExceptionInterface;
|
||||||
|
use Psr\Container\ContainerInterface;
|
||||||
use Psr\Container\NotFoundExceptionInterface;
|
use Psr\Container\NotFoundExceptionInterface;
|
||||||
use ReflectionException;
|
use ReflectionException;
|
||||||
use Server\Abstracts\BaseProcess;
|
use Server\Abstracts\BaseProcess;
|
||||||
@@ -22,13 +23,13 @@ use Server\Contract\OnMessageInterface;
|
|||||||
use Server\Contract\OnPacketInterface;
|
use Server\Contract\OnPacketInterface;
|
||||||
use Server\Contract\OnProcessInterface;
|
use Server\Contract\OnProcessInterface;
|
||||||
use Server\Contract\OnReceiveInterface;
|
use Server\Contract\OnReceiveInterface;
|
||||||
use Server\Contract\OnTaskInterface;
|
use Server\Events\OnServerBeforeStart;
|
||||||
use Server\Handler\OnPipeMessage;
|
use Server\Handler\OnPipeMessage;
|
||||||
use Server\Handler\OnServer;
|
use Server\Handler\OnServer;
|
||||||
use Server\Handler\OnServerManager;
|
use Server\Handler\OnServerManager;
|
||||||
use Server\Handler\OnServerReload;
|
use Server\Handler\OnServerReload;
|
||||||
use Server\Tasker\OnServerTask;
|
|
||||||
use Server\Handler\OnServerWorker;
|
use Server\Handler\OnServerWorker;
|
||||||
|
use Server\Tasker\OnServerTask;
|
||||||
use Swoole\Http\Server as HServer;
|
use Swoole\Http\Server as HServer;
|
||||||
use Swoole\Process;
|
use Swoole\Process;
|
||||||
use Swoole\Server;
|
use Swoole\Server;
|
||||||
@@ -59,6 +60,13 @@ class ServerManager
|
|||||||
public Logger $logger;
|
public Logger $logger;
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @var EventDispatch
|
||||||
|
*/
|
||||||
|
#[Inject(EventDispatch::class)]
|
||||||
|
public EventDispatch $eventProvider;
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @var State
|
* @var State
|
||||||
*/
|
*/
|
||||||
@@ -66,7 +74,6 @@ class ServerManager
|
|||||||
public State $state;
|
public State $state;
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
/** @var array<string,Port> */
|
/** @var array<string,Port> */
|
||||||
public array $ports = [];
|
public array $ports = [];
|
||||||
|
|
||||||
@@ -114,6 +121,7 @@ class ServerManager
|
|||||||
*/
|
*/
|
||||||
public function getServer(): Server|WServer|HServer|null
|
public function getServer(): Server|WServer|HServer|null
|
||||||
{
|
{
|
||||||
|
$this->eventProvider->dispatch(new OnServerBeforeStart());
|
||||||
return $this->server;
|
return $this->server;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user