Compare commits
59 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 14db451313 | |||
| ced92a10e1 | |||
| 0d12baf49f | |||
| b798270bb7 | |||
| 955f358577 | |||
| 97a5deda23 | |||
| 8ae395e9cd | |||
| 44a9a507f6 | |||
| 903ee0d6ce | |||
| a36943cd2d | |||
| 26e0ce7778 | |||
| 5a9f9da347 | |||
| a1bf157408 | |||
| 27834d37ed | |||
| c260ac6df4 | |||
| 7479bed4e4 | |||
| 39394f76d5 | |||
| 065555a80e | |||
| 13a8ca73bd | |||
| 8456e1b7d5 | |||
| 82b5650c8a | |||
| 03601f2db6 | |||
| a7082b76fd | |||
| e872e04da1 | |||
| 370b255862 | |||
| d4b5bed960 | |||
| 740dc7ebbd | |||
| adc63be3e4 | |||
| 34432225c4 | |||
| fd854b28a9 | |||
| ba43c969cf | |||
| efbd390d77 | |||
| 8f3d040cf2 | |||
| 59391c5489 | |||
| 801d4a3129 | |||
| c02f182601 | |||
| 994d0694e8 | |||
| c170ed745e | |||
| 7c1f950ea3 | |||
| de67663c64 | |||
| d46f09bd18 | |||
| 36fedb789e | |||
| 441e0867f6 | |||
| 31fd26aba5 | |||
| 16d5794ed0 | |||
| 78bca3b855 | |||
| 72536a34be | |||
| b5dbf7e779 | |||
| 1d48fdebc0 | |||
| 62b4e9edeb | |||
| f5785815ed | |||
| 30a1081f33 | |||
| 5cbbe5ac48 | |||
| f3a6b46104 | |||
| b435eb4e82 | |||
| 353692d016 | |||
| 6a1a0503e2 | |||
| 98cecce76a | |||
| 0570689e2c |
+55
-98
@@ -4,8 +4,7 @@ namespace Server\Abstracts;
|
||||
|
||||
|
||||
use JetBrains\PhpStorm\Pure;
|
||||
use Kiri\Kiri;
|
||||
use Server\SInterface\OnProcessInterface;
|
||||
use Server\Contract\OnProcessInterface;
|
||||
use Swoole\Coroutine;
|
||||
use Swoole\Process;
|
||||
|
||||
@@ -15,13 +14,63 @@ use Swoole\Process;
|
||||
abstract class BaseProcess implements OnProcessInterface
|
||||
{
|
||||
|
||||
/** @var bool */
|
||||
protected bool $enableSwooleCoroutine = true;
|
||||
|
||||
|
||||
protected bool $isStop = false;
|
||||
|
||||
|
||||
protected mixed $redirect_stdin_and_stdout = null;
|
||||
|
||||
|
||||
protected int $pipe_type = SOCK_DGRAM;
|
||||
|
||||
|
||||
protected bool $enable_coroutine = true;
|
||||
|
||||
|
||||
public string $name = 'swoole process.';
|
||||
|
||||
|
||||
/**
|
||||
* @return string
|
||||
*/
|
||||
public function getName(): string
|
||||
{
|
||||
return $this->name;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @return bool
|
||||
*/
|
||||
public function isStop(): bool
|
||||
{
|
||||
return $this->isStop;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return mixed
|
||||
*/
|
||||
public function getRedirectStdinAndStdout(): mixed
|
||||
{
|
||||
return $this->redirect_stdin_and_stdout;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return int
|
||||
*/
|
||||
public function getPipeType(): int
|
||||
{
|
||||
return $this->pipe_type;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return bool
|
||||
*/
|
||||
public function isEnableCoroutine(): bool
|
||||
{
|
||||
return $this->enable_coroutine;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
@@ -31,96 +80,4 @@ abstract class BaseProcess implements OnProcessInterface
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @return bool
|
||||
*/
|
||||
public function checkProcessIsStop(): bool
|
||||
{
|
||||
return $this->isStop === true;
|
||||
}
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* @param Process $process
|
||||
*/
|
||||
public function signListen(Process $process): void
|
||||
{
|
||||
// if (Coroutine::getCid() === -1) {
|
||||
// Process::signal(SIGTERM | SIGKILL, function ($signo) use ($process) {
|
||||
// if ($signo) {
|
||||
// $lists = Kiri::app()->getProcess();
|
||||
// foreach ($lists as $process) {
|
||||
// $process->exit(0);
|
||||
// }
|
||||
// }
|
||||
// });
|
||||
// } else {
|
||||
// Coroutine::create(function () use ($process) {
|
||||
// /** @var Coroutine\Socket $message */
|
||||
// $message = $process->exportSocket();
|
||||
// if ($message->recv() == 0x03455343213212) {
|
||||
// $this->waiteExit($process);
|
||||
// }
|
||||
// });
|
||||
// Coroutine::create(function () use ($process) {
|
||||
// $data = Coroutine::waitSignal(SIGTERM | SIGKILL, -1);
|
||||
// if ($data) {
|
||||
// $lists = Kiri::app()->getProcess();
|
||||
// foreach ($lists as $name => $process) {
|
||||
// foreach ($process as $item) {
|
||||
// /** @var Coroutine\Socket $export */
|
||||
// $export = $item->exportSocket();
|
||||
// $export->send(0x03455343213212);
|
||||
// }
|
||||
// }
|
||||
// }
|
||||
// });
|
||||
// }
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
protected function exit(): void
|
||||
{
|
||||
putenv('process.status=idle');
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @return bool
|
||||
*/
|
||||
#[Pure] public function isWorking(): bool
|
||||
{
|
||||
return env('process.status', 'working') == 'working';
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private function waiteExit(Process $process): void
|
||||
{
|
||||
$this->onProcessStop();
|
||||
while ($this->isWorking()) {
|
||||
$this->sleep();
|
||||
}
|
||||
$process->exit(0);
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
private function sleep(): void
|
||||
{
|
||||
if ($this->enableSwooleCoroutine) {
|
||||
Coroutine::sleep(0.1);
|
||||
} else {
|
||||
usleep(100);
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -1,36 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Server\Abstracts;
|
||||
|
||||
use Kiri\Exception\ConfigException;
|
||||
use Kiri\Kiri;
|
||||
use Psr\EventDispatcher\EventDispatcherInterface;
|
||||
use ReflectionException;
|
||||
use Server\ServerManager;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
class OnTaskerStart extends WorkerStart implements EventDispatcherInterface
|
||||
{
|
||||
|
||||
|
||||
/**
|
||||
* @throws ConfigException
|
||||
* @throws ReflectionException
|
||||
*/
|
||||
public function dispatch(object $event)
|
||||
{
|
||||
$time = microtime(true);
|
||||
|
||||
ServerManager::setEnv('environmental', Kiri::TASK);
|
||||
// if (!is_enable_file_modification_listening()) {
|
||||
// $this->interpretDirectory();
|
||||
// }
|
||||
|
||||
$this->mixed($event, false, $time);
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
@@ -1,39 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Server\Abstracts;
|
||||
|
||||
use Annotation\Annotation;
|
||||
use Annotation\Inject;
|
||||
use Exception;
|
||||
use Http\Handler\Router;
|
||||
use Kiri\Abstracts\Config;
|
||||
use Kiri\Di\NoteManager;
|
||||
use Kiri\Exception\ConfigException;
|
||||
use Kiri\Kiri;
|
||||
use Psr\EventDispatcher\EventDispatcherInterface;
|
||||
use ReflectionException;
|
||||
use Server\ServerManager;
|
||||
|
||||
class OnWorkerStart extends WorkerStart implements EventDispatcherInterface
|
||||
{
|
||||
|
||||
|
||||
/**
|
||||
* @param object $event
|
||||
* @return void
|
||||
* @throws ConfigException
|
||||
* @throws Exception
|
||||
*/
|
||||
public function dispatch(object $event)
|
||||
{
|
||||
$time = microtime(true);
|
||||
|
||||
ServerManager::setEnv('environmental', Kiri::WORKER);
|
||||
// if (is_enable_file_modification_listening()) {
|
||||
// $this->router->read_files();
|
||||
// $this->interpretDirectory();
|
||||
// }
|
||||
$this->mixed($event, true, $time);
|
||||
}
|
||||
|
||||
}
|
||||
@@ -4,7 +4,7 @@
|
||||
namespace Server\Abstracts;
|
||||
|
||||
|
||||
use Annotation\Inject;
|
||||
use Note\Inject;
|
||||
use Exception;
|
||||
use Kiri\Abstracts\Config;
|
||||
use Kiri\Exception\ConfigException;
|
||||
@@ -36,7 +36,7 @@ abstract class Server
|
||||
if (Kiri::getPlatform()->isMac()) {
|
||||
return;
|
||||
}
|
||||
$name = Config::get('id', 'system-service');
|
||||
$name = '[' . Config::get('id', 'system-service') . ']';
|
||||
if (!empty($prefix)) {
|
||||
$name .= '.' . $prefix;
|
||||
}
|
||||
|
||||
@@ -1,88 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Server\Abstracts;
|
||||
|
||||
use Annotation\Annotation;
|
||||
use Annotation\Inject;
|
||||
use Http\Handler\Router;
|
||||
use Kiri\Abstracts\Config;
|
||||
use Kiri\Di\NoteManager;
|
||||
use Kiri\Exception\ConfigException;
|
||||
use Kiri\Kiri;
|
||||
|
||||
class WorkerStart
|
||||
{
|
||||
|
||||
|
||||
/**
|
||||
* @var Annotation
|
||||
*/
|
||||
#[Inject(Annotation::class)]
|
||||
public Annotation $annotation;
|
||||
|
||||
|
||||
/**
|
||||
* @var Router
|
||||
*/
|
||||
#[Inject(Router::class)]
|
||||
public Router $router;
|
||||
|
||||
|
||||
/**
|
||||
* @throws \ReflectionException
|
||||
* @throws \Exception
|
||||
*/
|
||||
protected function interpretDirectory()
|
||||
{
|
||||
$di = Kiri::getDi();
|
||||
|
||||
$this->annotation->read(APP_PATH . 'app', 'App');
|
||||
|
||||
$fileLists = $this->annotation->read(APP_PATH . 'app');
|
||||
foreach ($fileLists->runtime(APP_PATH . 'app') as $class) {
|
||||
foreach (NoteManager::getTargetNote($class) as $value) {
|
||||
$value->execute($class);
|
||||
}
|
||||
$methods = $di->getMethodAttribute($class);
|
||||
foreach ($methods as $method => $attribute) {
|
||||
if (empty($attribute)) {
|
||||
continue;
|
||||
}
|
||||
foreach ($attribute as $item) {
|
||||
$item->execute($class, $method);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param $event
|
||||
* @param $isWorker
|
||||
* @param $time
|
||||
* @throws \Kiri\Exception\ConfigException
|
||||
*/
|
||||
protected function mixed($event, $isWorker, $time)
|
||||
{
|
||||
$name = Config::get('id', 'system-service');
|
||||
echo sprintf("\033[36m[" . date('Y-m-d H:i:s') . "]\033[0m [%s]Builder %s[%d].%d use time %s.", $name, $isWorker ? 'Worker' : 'Taker',
|
||||
$event->server->worker_pid, $event->workerId, round(microtime(true) - $time, 6) . 's') . PHP_EOL;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param $prefix
|
||||
* @throws ConfigException
|
||||
*/
|
||||
protected function setProcessName($prefix)
|
||||
{
|
||||
if (Kiri::getPlatform()->isMac()) {
|
||||
return;
|
||||
}
|
||||
$name = Config::get('id', 'system-service');
|
||||
if (!empty($prefix)) {
|
||||
$name .= '.' . $prefix;
|
||||
}
|
||||
swoole_set_process_name($name);
|
||||
}
|
||||
|
||||
}
|
||||
@@ -19,6 +19,7 @@ class Constant
|
||||
const WORKER_EXIT = 'WorkerExit';
|
||||
const CONNECT = 'Connect';
|
||||
const HANDSHAKE = 'handshake';
|
||||
const OPEN = 'open';
|
||||
const DISCONNECT = 'disconnect';
|
||||
const MESSAGE = 'message';
|
||||
const RECEIVE = 'Receive';
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
<?php
|
||||
|
||||
namespace Server\SInterface;
|
||||
namespace Server\Contract;
|
||||
|
||||
interface OnBeforeShutdown
|
||||
{
|
||||
@@ -1,6 +1,6 @@
|
||||
<?php
|
||||
|
||||
namespace Server\SInterface;
|
||||
namespace Server\Contract;
|
||||
|
||||
use Swoole\Server;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
<?php
|
||||
|
||||
namespace Server\SInterface;
|
||||
namespace Server\Contract;
|
||||
|
||||
use Swoole\Server;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
<?php
|
||||
|
||||
namespace Server\SInterface;
|
||||
namespace Server\Contract;
|
||||
|
||||
use Swoole\Server;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
<?php
|
||||
|
||||
namespace Server\SInterface;
|
||||
namespace Server\Contract;
|
||||
|
||||
use Swoole\Http\Request;
|
||||
use Swoole\Http\Response;
|
||||
@@ -1,6 +1,6 @@
|
||||
<?php
|
||||
|
||||
namespace Server\SInterface;
|
||||
namespace Server\Contract;
|
||||
|
||||
use Swoole\Server;
|
||||
use Swoole\WebSocket\Frame;
|
||||
@@ -1,6 +1,6 @@
|
||||
<?php
|
||||
|
||||
namespace Server\SInterface;
|
||||
namespace Server\Contract;
|
||||
|
||||
use Swoole\Http\Request;
|
||||
use Swoole\WebSocket\Server;
|
||||
@@ -10,8 +10,8 @@ interface OnOpenInterface
|
||||
|
||||
|
||||
/**
|
||||
* @param \Swoole\WebSocket\Server $server
|
||||
* @param \Swoole\Http\Request $request
|
||||
* @param Server $server
|
||||
* @param Request $request
|
||||
*/
|
||||
public function onOpen(Server $server, Request $request): void;
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
<?php
|
||||
|
||||
namespace Server\SInterface;
|
||||
namespace Server\Contract;
|
||||
|
||||
use Server\Abstracts\Server;
|
||||
|
||||
@@ -1,12 +1,12 @@
|
||||
<?php
|
||||
|
||||
|
||||
namespace Server\SInterface;
|
||||
namespace Server\Contract;
|
||||
|
||||
|
||||
/**
|
||||
* Interface OnPipeMessageInterface
|
||||
* @package Server\SInterface
|
||||
* @package Server\Contract
|
||||
*/
|
||||
interface OnPipeMessageInterface
|
||||
{
|
||||
@@ -0,0 +1,25 @@
|
||||
<?php
|
||||
|
||||
|
||||
namespace Server\Contract;
|
||||
|
||||
|
||||
use Swoole\Process;
|
||||
|
||||
|
||||
/**
|
||||
* Interface BaseProcess
|
||||
* @package Contract
|
||||
*/
|
||||
interface OnProcessInterface
|
||||
{
|
||||
|
||||
|
||||
/**
|
||||
* @param Process $process
|
||||
*/
|
||||
public function process(Process $process): void;
|
||||
|
||||
|
||||
|
||||
}
|
||||
@@ -1,6 +1,6 @@
|
||||
<?php
|
||||
|
||||
namespace Server\SInterface;
|
||||
namespace Server\Contract;
|
||||
|
||||
use Swoole\Server;
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
<?php
|
||||
|
||||
|
||||
namespace Server\SInterface;
|
||||
namespace Server\Contract;
|
||||
|
||||
|
||||
use Swoole\Server;
|
||||
@@ -1,16 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Server\Events;
|
||||
|
||||
class OnAfterCommandExecute
|
||||
{
|
||||
|
||||
|
||||
/**
|
||||
* @param mixed $data
|
||||
*/
|
||||
public function __construct(public mixed $data)
|
||||
{
|
||||
}
|
||||
|
||||
}
|
||||
@@ -2,7 +2,7 @@
|
||||
|
||||
namespace Server\Events;
|
||||
|
||||
class OnBeforeCommandExecute
|
||||
class OnServerBeforeStart
|
||||
{
|
||||
|
||||
}
|
||||
@@ -2,10 +2,10 @@
|
||||
|
||||
namespace Server\Handler;
|
||||
|
||||
use Annotation\Inject;
|
||||
use Note\Inject;
|
||||
use Server\Abstracts\Server;
|
||||
use Exception;
|
||||
use Server\SInterface\OnPipeMessageInterface;
|
||||
use Server\Contract\OnPipeMessageInterface;
|
||||
use Kiri\Events\EventDispatch;
|
||||
|
||||
/**
|
||||
|
||||
@@ -2,7 +2,7 @@
|
||||
|
||||
namespace Server\Handler;
|
||||
|
||||
use Annotation\Inject;
|
||||
use Note\Inject;
|
||||
use Kiri\Events\EventDispatch;
|
||||
use Kiri\Exception\ConfigException;
|
||||
use Server\Abstracts\Server;
|
||||
|
||||
@@ -2,7 +2,7 @@
|
||||
|
||||
namespace Server\Handler;
|
||||
|
||||
use Annotation\Inject;
|
||||
use Note\Inject;
|
||||
use Kiri\Events\EventDispatch;
|
||||
use Server\Abstracts\Server;
|
||||
use Kiri\Exception\ConfigException;
|
||||
|
||||
@@ -2,7 +2,7 @@
|
||||
|
||||
namespace Server\Handler;
|
||||
|
||||
use Annotation\Inject;
|
||||
use Note\Inject;
|
||||
use Kiri\Events\EventDispatch;
|
||||
use Server\Events\OnAfterReload;
|
||||
use Server\Events\OnBeforeReload;
|
||||
|
||||
+10
-24
@@ -2,12 +2,12 @@
|
||||
|
||||
namespace Server\Handler;
|
||||
|
||||
use Annotation\Inject;
|
||||
use Note\Inject;
|
||||
use Exception;
|
||||
use Kiri\Abstracts\Config;
|
||||
use Kiri\Core\Help;
|
||||
use Kiri\Events\EventDispatch;
|
||||
use Kiri\Runtime;
|
||||
use Kiri\Kiri;
|
||||
use Server\Events\OnAfterWorkerStart;
|
||||
use Server\Events\OnBeforeWorkerStart;
|
||||
use Server\Events\OnTaskerStart as OnTaskStart;
|
||||
@@ -15,7 +15,6 @@ use Server\Events\OnWorkerError;
|
||||
use Server\Events\OnWorkerExit;
|
||||
use Server\Events\OnWorkerStart;
|
||||
use Server\Events\OnWorkerStop;
|
||||
use Server\ServerManager;
|
||||
use Swoole\Server;
|
||||
use Swoole\Timer;
|
||||
|
||||
@@ -46,28 +45,16 @@ class OnServerWorker extends \Server\Abstracts\Server
|
||||
if ($workerId < $server->setting['worker_num']) {
|
||||
$this->eventDispatch->dispatch(new OnWorkerStart($server, $workerId));
|
||||
$this->setProcessName(sprintf('Worker[%d].%d', $server->worker_pid, $workerId));
|
||||
set_env('environmental', Kiri::WORKER);
|
||||
} else {
|
||||
$this->eventDispatch->dispatch(new OnTaskStart($server, $workerId));
|
||||
$this->setProcessName(sprintf('Tasker[%d].%d', $server->worker_pid, $workerId));
|
||||
set_env('environmental', Kiri::TASK);
|
||||
}
|
||||
$this->eventDispatch->dispatch(new OnAfterWorkerStart());
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param OnBeforeWorkerStart $worker
|
||||
* @throws Exception
|
||||
*/
|
||||
public function setConfigure(OnBeforeWorkerStart $worker)
|
||||
{
|
||||
ServerManager::setEnv('worker', $worker->workerId);
|
||||
$serialize = file_get_contents(storage(Runtime::CONFIG_NAME));
|
||||
if (!empty($serialize)) {
|
||||
Config::sets(unserialize($serialize));
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param Server $server
|
||||
* @param int $workerId
|
||||
@@ -75,9 +62,8 @@ class OnServerWorker extends \Server\Abstracts\Server
|
||||
*/
|
||||
public function onWorkerStop(Server $server, int $workerId)
|
||||
{
|
||||
$this->eventDispatch->dispatch(new OnWorkerStop($server, $workerId));
|
||||
|
||||
Timer::clearAll();
|
||||
Timer::clearAll();
|
||||
$this->eventDispatch->dispatch(new OnWorkerStop($server, $workerId));
|
||||
}
|
||||
|
||||
|
||||
@@ -88,10 +74,10 @@ class OnServerWorker extends \Server\Abstracts\Server
|
||||
*/
|
||||
public function onWorkerExit(Server $server, int $workerId)
|
||||
{
|
||||
$this->eventDispatch->dispatch(new OnWorkerExit($server, $workerId));
|
||||
set_env('state', 'exit');
|
||||
|
||||
ServerManager::setEnv('state', 'exit');
|
||||
}
|
||||
$this->eventDispatch->dispatch(new OnWorkerExit($server, $workerId));
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
@@ -112,7 +98,7 @@ class OnServerWorker extends \Server\Abstracts\Server
|
||||
|
||||
$this->logger->error($message);
|
||||
|
||||
$this->system_mail($message);
|
||||
// $this->system_mail($message);
|
||||
}
|
||||
|
||||
|
||||
|
||||
@@ -1,12 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Server\SInterface;
|
||||
|
||||
use Swoole\Http\Response;
|
||||
|
||||
interface OnDownloadInterface
|
||||
{
|
||||
|
||||
public function dispatch(Response $response);
|
||||
|
||||
}
|
||||
@@ -1,43 +0,0 @@
|
||||
<?php
|
||||
|
||||
|
||||
namespace Server\SInterface;
|
||||
|
||||
|
||||
use Swoole\Process;
|
||||
|
||||
|
||||
/**
|
||||
* Interface BaseProcess
|
||||
* @package SInterface
|
||||
*/
|
||||
interface OnProcessInterface
|
||||
{
|
||||
|
||||
|
||||
/**
|
||||
* @param Process $process
|
||||
* @return string
|
||||
*/
|
||||
public function getProcessName(Process $process): string;
|
||||
|
||||
|
||||
/**
|
||||
* @param Process $process
|
||||
*/
|
||||
public function signListen(Process $process): void;
|
||||
|
||||
|
||||
/**
|
||||
* @param Process $process
|
||||
*/
|
||||
public function onHandler(Process $process): void;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
public function onProcessStop(): void;
|
||||
|
||||
|
||||
}
|
||||
+17
-8
@@ -3,14 +3,15 @@
|
||||
|
||||
namespace Server;
|
||||
|
||||
use Annotation\Inject;
|
||||
use Exception;
|
||||
use Http\Handler\Abstracts\HttpService;
|
||||
use JetBrains\PhpStorm\Pure;
|
||||
use Kiri\Abstracts\Config;
|
||||
use Kiri\Error\LoggerProcess;
|
||||
use Kiri\Events\EventDispatch;
|
||||
use Kiri\Exception\ConfigException;
|
||||
use Note\Inject;
|
||||
use Psr\Container\ContainerExceptionInterface;
|
||||
use Psr\Container\NotFoundExceptionInterface;
|
||||
use Server\Events\OnShutdown;
|
||||
|
||||
|
||||
@@ -24,7 +25,6 @@ class Server extends HttpService
|
||||
{
|
||||
|
||||
private array $process = [
|
||||
LoggerProcess::class
|
||||
];
|
||||
|
||||
|
||||
@@ -43,6 +43,13 @@ class Server extends HttpService
|
||||
public EventDispatch $eventDispatch;
|
||||
|
||||
|
||||
/**
|
||||
* @var State
|
||||
*/
|
||||
#[Inject(State::class)]
|
||||
public State $state;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
@@ -61,10 +68,11 @@ class Server extends HttpService
|
||||
|
||||
|
||||
/**
|
||||
* @return string start server
|
||||
*
|
||||
* start server
|
||||
* @return string
|
||||
* @throws ConfigException
|
||||
* @throws ContainerExceptionInterface
|
||||
* @throws NotFoundExceptionInterface
|
||||
* @throws \ReflectionException
|
||||
* @throws Exception
|
||||
*/
|
||||
public function start(): string
|
||||
@@ -96,7 +104,7 @@ class Server extends HttpService
|
||||
{
|
||||
$configs = Config::get('server', [], true);
|
||||
foreach ($this->manager->sortService($configs['ports'] ?? []) as $config) {
|
||||
$this->manager->stopServer($config['port']);
|
||||
$this->state->exit($config['port']);
|
||||
}
|
||||
$this->eventDispatch->dispatch(new OnShutdown());
|
||||
}
|
||||
@@ -105,10 +113,11 @@ class Server extends HttpService
|
||||
/**
|
||||
* @return bool
|
||||
* @throws ConfigException
|
||||
* @throws Exception
|
||||
*/
|
||||
public function isRunner(): bool
|
||||
{
|
||||
return $this->manager->isRunner();
|
||||
return $this->state->isRunner();
|
||||
}
|
||||
|
||||
|
||||
|
||||
+30
-42
@@ -4,23 +4,13 @@ declare(strict_types=1);
|
||||
namespace Server;
|
||||
|
||||
|
||||
use Annotation\Inject;
|
||||
use Note\Inject;
|
||||
use Exception;
|
||||
use Http\Constrict\Request;
|
||||
use Http\Constrict\RequestInterface;
|
||||
use Http\Constrict\Response;
|
||||
use Http\Constrict\ResponseInterface;
|
||||
use Kiri\Abstracts\Config;
|
||||
use Kiri\Di\ContainerInterface;
|
||||
use Kiri\Events\EventProvider;
|
||||
use Kiri\Events\EventDispatch;
|
||||
use Kiri\Exception\ConfigException;
|
||||
use Kiri\Kiri;
|
||||
use Server\Abstracts\OnTaskerStart as TaskerDispatch;
|
||||
use Server\Abstracts\OnWorkerStart as WorkerDispatch;
|
||||
use Server\Events\OnBeforeWorkerStart;
|
||||
use Server\Events\OnTaskerStart;
|
||||
use Server\Events\OnWorkerStart;
|
||||
use Server\Handler\OnServerWorker;
|
||||
use Server\Events\OnServerBeforeStart;
|
||||
use Swoole\Coroutine;
|
||||
use Symfony\Component\Console\Command\Command;
|
||||
use Symfony\Component\Console\Input\InputArgument;
|
||||
@@ -40,10 +30,10 @@ class ServerCommand extends Command
|
||||
|
||||
|
||||
/**
|
||||
* @var EventProvider
|
||||
* @var EventDispatch
|
||||
*/
|
||||
#[Inject(EventProvider::class)]
|
||||
public EventProvider $eventProvider;
|
||||
#[Inject(EventDispatch::class)]
|
||||
public EventDispatch $eventProvider;
|
||||
|
||||
|
||||
/**
|
||||
@@ -53,8 +43,8 @@ class ServerCommand extends Command
|
||||
{
|
||||
$this->setName('sw:server')
|
||||
->setDescription('server start|stop|reload|restart')
|
||||
->addArgument('action', InputArgument::REQUIRED)
|
||||
->addOption('daemon', 'd', InputOption::VALUE_OPTIONAL,'is run daemonize',-1);
|
||||
->addArgument('action', InputArgument::OPTIONAL, 'run action', 'start')
|
||||
->addOption('daemon', 'd', InputOption::VALUE_OPTIONAL, 'is run daemonize');
|
||||
}
|
||||
|
||||
|
||||
@@ -66,25 +56,22 @@ class ServerCommand extends Command
|
||||
*/
|
||||
public function execute(InputInterface $input, OutputInterface $output): int
|
||||
{
|
||||
try {
|
||||
$manager = Kiri::app()->getServer();
|
||||
$manager->setDaemon((int)is_null($input->getOption('daemon')));
|
||||
if (!in_array($input->getArgument('action'), self::ACTIONS)) {
|
||||
throw new Exception('I don\'t know what I want to do.');
|
||||
}
|
||||
if ($manager->isRunner() && $input->getArgument('action') == 'start') {
|
||||
throw new Exception('Service is running. Please use restart.');
|
||||
}
|
||||
$manager->shutdown();
|
||||
if ($input->getArgument('action') == 'stop') {
|
||||
throw new Exception('shutdown success');
|
||||
}
|
||||
$this->generate_runtime_builder($manager);
|
||||
} catch (\Throwable $throwable) {
|
||||
$output->write(jTraceEx($throwable));
|
||||
} finally {
|
||||
return 1;
|
||||
$manager = Kiri::app()->getServer();
|
||||
$manager->setDaemon((int)!is_null($input->getOption('daemon')));
|
||||
if (is_null($input->getArgument('action'))) {
|
||||
$input->setArgument('action', 'restart');
|
||||
}
|
||||
if (!in_array($input->getArgument('action'), self::ACTIONS)) {
|
||||
throw new Exception('I don\'t know what I want to do.');
|
||||
}
|
||||
if ($manager->isRunner() && $input->getArgument('action') == 'start') {
|
||||
throw new Exception('Service is running. Please use restart.');
|
||||
}
|
||||
$manager->shutdown();
|
||||
if ($input->getArgument('action') == 'stop') {
|
||||
return 0;
|
||||
}
|
||||
return $this->generate_runtime_builder($manager);
|
||||
}
|
||||
|
||||
|
||||
@@ -109,18 +96,19 @@ class ServerCommand extends Command
|
||||
|
||||
/**
|
||||
* @param $manager
|
||||
* @return int
|
||||
* @throws ConfigException
|
||||
* @throws Exception
|
||||
*/
|
||||
private function generate_runtime_builder($manager): void
|
||||
private function generate_runtime_builder($manager): int
|
||||
{
|
||||
$this->configure_set();
|
||||
|
||||
exec(PHP_BINARY . ' ' . APP_PATH . 'kiri.php runtime:builder');
|
||||
|
||||
$this->eventProvider->on(OnBeforeWorkerStart::class, [di(OnServerWorker::class), 'setConfigure']);
|
||||
$this->eventProvider->on(OnWorkerStart::class, [di(WorkerDispatch::class), 'dispatch']);
|
||||
$this->eventProvider->on(OnTaskerStart::class, [di(TaskerDispatch::class), 'dispatch']);
|
||||
Kiri::app()->getRouter()->read_files();
|
||||
|
||||
$manager->start();
|
||||
|
||||
return 1;
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
+86
-222
@@ -2,31 +2,34 @@
|
||||
|
||||
namespace Server;
|
||||
|
||||
use Annotation\Inject;
|
||||
use Closure;
|
||||
use Exception;
|
||||
use Kiri\Abstracts\Config;
|
||||
use Kiri\Di\ContainerInterface;
|
||||
use Kiri\Di\Container;
|
||||
use Kiri\Error\Logger;
|
||||
use Kiri\Events\EventDispatch;
|
||||
use Kiri\Exception\ConfigException;
|
||||
use Kiri\Kiri;
|
||||
use Note\Inject;
|
||||
use Psr\Container\ContainerExceptionInterface;
|
||||
use Psr\Container\ContainerInterface;
|
||||
use Psr\Container\NotFoundExceptionInterface;
|
||||
use ReflectionException;
|
||||
|
||||
use Server\Abstracts\BaseProcess;
|
||||
use Server\Contract\OnCloseInterface;
|
||||
use Server\Contract\OnConnectInterface;
|
||||
use Server\Contract\OnDisconnectInterface;
|
||||
use Server\Contract\OnHandshakeInterface;
|
||||
use Server\Contract\OnMessageInterface;
|
||||
use Server\Contract\OnPacketInterface;
|
||||
use Server\Contract\OnProcessInterface;
|
||||
use Server\Contract\OnReceiveInterface;
|
||||
use Server\Events\OnServerBeforeStart;
|
||||
use Server\Handler\OnPipeMessage;
|
||||
use Server\Handler\OnServer;
|
||||
use Server\Handler\OnServerManager;
|
||||
use Server\Handler\OnServerReload;
|
||||
use Server\Handler\OnServerWorker;
|
||||
use Server\Handler\OnServerTask;
|
||||
|
||||
use Server\SInterface\OnCloseInterface;
|
||||
use Server\SInterface\OnConnectInterface;
|
||||
use Server\SInterface\OnDisconnectInterface;
|
||||
use Server\SInterface\OnHandshakeInterface;
|
||||
use Server\SInterface\OnMessageInterface;
|
||||
use Server\SInterface\OnPacketInterface;
|
||||
use Server\SInterface\OnProcessInterface;
|
||||
use Server\SInterface\OnReceiveInterface;
|
||||
use Server\SInterface\OnTaskInterface;
|
||||
use Server\Tasker\OnServerTask;
|
||||
use Swoole\Http\Server as HServer;
|
||||
use Swoole\Process;
|
||||
use Swoole\Server;
|
||||
@@ -41,12 +44,29 @@ use Swoole\WebSocket\Server as WServer;
|
||||
class ServerManager
|
||||
{
|
||||
|
||||
|
||||
use TraitServer;
|
||||
|
||||
/** @var string */
|
||||
public string $host = '';
|
||||
|
||||
public int $port = 0;
|
||||
|
||||
|
||||
/**
|
||||
* @var Logger
|
||||
*/
|
||||
#[Inject(Logger::class)]
|
||||
public Logger $logger;
|
||||
|
||||
|
||||
/**
|
||||
* @var State
|
||||
*/
|
||||
#[Inject(State::class)]
|
||||
public State $state;
|
||||
|
||||
|
||||
/** @var array<string,Port> */
|
||||
public array $ports = [];
|
||||
|
||||
@@ -57,7 +77,7 @@ class ServerManager
|
||||
|
||||
|
||||
/**
|
||||
* @var ContainerInterface
|
||||
* @var Container
|
||||
*/
|
||||
#[Inject(ContainerInterface::class)]
|
||||
public ContainerInterface $container;
|
||||
@@ -91,9 +111,11 @@ class ServerManager
|
||||
|
||||
/**
|
||||
* @return Server|WServer|HServer|null
|
||||
* @throws ReflectionException
|
||||
*/
|
||||
public function getServer(): Server|WServer|HServer|null
|
||||
{
|
||||
di(EventDispatch::class)->dispatch(new OnServerBeforeStart());
|
||||
return $this->server;
|
||||
}
|
||||
|
||||
@@ -104,13 +126,13 @@ class ServerManager
|
||||
* @param int $port
|
||||
* @param int $mode
|
||||
* @param array $settings
|
||||
* @throws ReflectionException
|
||||
* @throws ConfigException
|
||||
* @throws Exception
|
||||
* @throws ContainerExceptionInterface
|
||||
* @throws NotFoundExceptionInterface
|
||||
* @throws ReflectionException
|
||||
*/
|
||||
public function addListener(string $type, string $host, int $port, int $mode, array $settings = [])
|
||||
{
|
||||
if ($this->checkPortIsAlready($port)) $this->stopServer($port);
|
||||
if (!$this->server) {
|
||||
$this->createBaseServer($type, $host, $port, $mode, $settings);
|
||||
} else {
|
||||
@@ -123,8 +145,12 @@ class ServerManager
|
||||
|
||||
|
||||
/**
|
||||
* @throws ReflectionException
|
||||
* @param $configs
|
||||
* @param int $daemon
|
||||
* @throws ConfigException
|
||||
* @throws ContainerExceptionInterface
|
||||
* @throws NotFoundExceptionInterface
|
||||
* @throws ReflectionException
|
||||
*/
|
||||
public function initBaseServer($configs, int $daemon = 0): void
|
||||
{
|
||||
@@ -132,79 +158,29 @@ class ServerManager
|
||||
foreach ($this->sortService($configs['ports']) as $config) {
|
||||
$this->startListenerHandler($context, $config, $daemon);
|
||||
}
|
||||
$this->bindCallback($this->server, [Constant::PIPE_MESSAGE => [OnPipeMessage::class, 'onPipeMessage']]);
|
||||
// $this->bindCallback($this->server, $this->getSystemEvents($configs));
|
||||
$this->bindCallback([Constant::PIPE_MESSAGE => [OnPipeMessage::class, 'onPipeMessage']]);
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @return bool
|
||||
* @throws ConfigException
|
||||
* @param string|OnProcessInterface|BaseProcess $customProcess
|
||||
* @throws Exception
|
||||
*/
|
||||
public function isRunner(): bool
|
||||
public function addProcess(string|OnProcessInterface|BaseProcess $customProcess)
|
||||
{
|
||||
$configs = Config::get('server', [], true);
|
||||
foreach ($this->sortService($configs['ports']) as $config) {
|
||||
if ($this->checkPortIsAlready($config['port'])) {
|
||||
return true;
|
||||
}
|
||||
if (is_string($customProcess)) {
|
||||
$customProcess = Kiri::getDi()->get($customProcess);
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param string|OnProcessInterface $customProcess
|
||||
* @param null $redirect_stdin_and_stdout
|
||||
* @param int|null $pipe_type
|
||||
* @param bool $enable_coroutine
|
||||
* @throws Exception
|
||||
*/
|
||||
public function addProcess(string|OnProcessInterface $customProcess, $redirect_stdin_and_stdout = null, ?int $pipe_type = SOCK_DGRAM, bool $enable_coroutine = true)
|
||||
{
|
||||
$process = $this->initProcess($customProcess, $redirect_stdin_and_stdout, $pipe_type, $enable_coroutine);
|
||||
$this->server->addProcess($process);
|
||||
if ($customProcess instanceof OnProcessInterface) {
|
||||
Kiri::app()->addProcess($customProcess::class, $process);
|
||||
} else {
|
||||
Kiri::app()->addProcess($customProcess, $process);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param $customProcess
|
||||
* @param $redirect_stdin_and_stdout
|
||||
* @param $pipe_type
|
||||
* @param $enable_coroutine
|
||||
* @return Process
|
||||
*/
|
||||
private function initProcess($customProcess, $redirect_stdin_and_stdout, $pipe_type, $enable_coroutine): Process
|
||||
{
|
||||
$server = $this->server;
|
||||
return new Process(function (Process $soloProcess) use ($customProcess, $server) {
|
||||
$time = microtime(true);
|
||||
if (is_string($customProcess)) {
|
||||
$customProcess = Kiri::createObject($customProcess, [$server]);
|
||||
}
|
||||
|
||||
$name = $customProcess->getProcessName($soloProcess);
|
||||
|
||||
$system = sprintf('%s.process[%d]', Config::get('id', 'system-service'), $soloProcess->pid);
|
||||
$system = sprintf('[%s].process', Config::get('id', 'system-service'));
|
||||
$process = new Process(function (Process $process) use ($customProcess, $system) {
|
||||
if (Kiri::getPlatform()->isLinux()) {
|
||||
$soloProcess->name($system . '.' . $name . ' start.');
|
||||
$process->name($system . '(' . $customProcess->getName() . ')');
|
||||
}
|
||||
$name = Config::get('id', 'system-service');
|
||||
echo sprintf("\033[36m[" . date('Y-m-d H:i:s') . "]\033[0m [%s]Builder %s[%d].%d use time %s.", $name, 'Process ' . $name,
|
||||
$server->master_pid, $soloProcess->pid, round(microtime(true) - $time, 6) . 's') . PHP_EOL;
|
||||
$customProcess->signListen($soloProcess);
|
||||
$customProcess->onHandler($soloProcess);
|
||||
},
|
||||
$redirect_stdin_and_stdout,
|
||||
$pipe_type,
|
||||
$enable_coroutine
|
||||
);
|
||||
$customProcess->process($process);
|
||||
}, $customProcess->getRedirectStdinAndStdout(), $customProcess->getPipeType(), $customProcess->isEnableCoroutine());
|
||||
$this->logger->debug($system . ' ' . $customProcess->getName() . ' start.');
|
||||
$this->container->setBindings($customProcess->getName(), $process);
|
||||
$this->server->addProcess($process);
|
||||
}
|
||||
|
||||
|
||||
@@ -217,45 +193,13 @@ class ServerManager
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param array $ports
|
||||
* @return array
|
||||
*/
|
||||
public function sortService(array $ports): array
|
||||
{
|
||||
$array = [];
|
||||
foreach ($ports as $port) {
|
||||
if ($port['type'] == Constant::SERVER_TYPE_WEBSOCKET) {
|
||||
array_unshift($array, $port);
|
||||
} else if ($port['type'] == Constant::SERVER_TYPE_HTTP) {
|
||||
if (!empty($array) && $array[0]['type'] == Constant::SERVER_TYPE_WEBSOCKET) {
|
||||
$array[] = $port;
|
||||
} else {
|
||||
array_unshift($array, $port);
|
||||
}
|
||||
} else {
|
||||
$array[] = $port;
|
||||
}
|
||||
}
|
||||
return $array;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param string $key
|
||||
* @param string|int $value
|
||||
*/
|
||||
public static function setEnv(string $key, string|int $value): void
|
||||
{
|
||||
putenv(sprintf('%s=%s', $key, (string)$value));
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param ServerManager $context
|
||||
* @param array $config
|
||||
* @param int $daemon
|
||||
* @throws ConfigException
|
||||
* @throws ContainerExceptionInterface
|
||||
* @throws NotFoundExceptionInterface
|
||||
* @throws ReflectionException
|
||||
* @throws Exception
|
||||
*/
|
||||
@@ -279,13 +223,12 @@ class ServerManager
|
||||
private function mergeConfig($config, $daemon): array
|
||||
{
|
||||
$config['settings'] = $config['settings'] ?? [];
|
||||
if (!isset($config['settings']['daemonize']) || !$config['settings']['daemonize'] != $daemon) {
|
||||
$config['settings']['daemonize'] = $daemon;
|
||||
}
|
||||
$config['settings']['daemonize'] = $daemon;
|
||||
if (!isset($config['settings']['log_file'])) {
|
||||
$config['settings']['log_file'] = storage('system.log');
|
||||
}
|
||||
$config['settings']['pid_file'] = storage('.swoole.pid');
|
||||
$config['settings'][Constant::OPTION_ENABLE_REUSE_PORT] = true;
|
||||
$config['events'] = $config['events'] ?? [];
|
||||
return $config;
|
||||
}
|
||||
@@ -297,13 +240,17 @@ class ServerManager
|
||||
* @param int $port
|
||||
* @param int $mode
|
||||
* @param array $settings
|
||||
* @throws ConfigException
|
||||
* @throws ContainerExceptionInterface
|
||||
* @throws NotFoundExceptionInterface
|
||||
* @throws Exception
|
||||
*/
|
||||
private function addNewListener(string $type, string $host, int $port, int $mode, array $settings = [])
|
||||
{
|
||||
$id = Config::get('id', 'system-service');
|
||||
|
||||
echo sprintf("\033[36m[" . date('Y-m-d H:i:s') . "]\033[0m [%s]$type service %s::%d start.", $id, $host, $port) . PHP_EOL;
|
||||
$this->logger->debug(sprintf('[%s].' . $type . ' service %s::%d start', $id, $host, $port));
|
||||
|
||||
/** @var Server\Port $service */
|
||||
$this->ports[$port] = $this->server->addlistener($host, $port, $mode);
|
||||
if ($this->ports[$port] === false) {
|
||||
@@ -323,30 +270,17 @@ class ServerManager
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param int $port
|
||||
* @param string $event
|
||||
* @return Closure|array|null
|
||||
*/
|
||||
public function getPortCallback(int $port, string $event): Closure|array|null
|
||||
{
|
||||
/** @var Server\Port $_port */
|
||||
$_port = $this->ports[$port] ?? null;
|
||||
if (is_null($_port)) {
|
||||
return null;
|
||||
}
|
||||
return $_port->getCallback($event);
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param string $type
|
||||
* @param string $host
|
||||
* @param int $port
|
||||
* @param int $mode
|
||||
* @param array $settings
|
||||
* @throws ReflectionException
|
||||
* @throws ConfigException
|
||||
* @throws ContainerExceptionInterface
|
||||
* @throws NotFoundExceptionInterface
|
||||
* @throws ReflectionException
|
||||
* @throws Exception
|
||||
*/
|
||||
private function createBaseServer(string $type, string $host, int $port, int $mode, array $settings = [])
|
||||
{
|
||||
@@ -361,59 +295,17 @@ class ServerManager
|
||||
|
||||
$id = Config::get('id', 'system-service');
|
||||
|
||||
echo sprintf("\033[36m[" . date('Y-m-d H:i:s') . "]\033[0m [%s]$type service %s::%d start.", $id, $host, $port) . PHP_EOL;
|
||||
$this->logger->debug(sprintf('[%s]' . $type . ' service %s::%d start', $id, $host, $port));
|
||||
|
||||
$this->addDefaultListener($settings);
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param int $port
|
||||
* @throws Exception
|
||||
*/
|
||||
public function stopServer(int $port)
|
||||
{
|
||||
if (!($pid = $this->checkPortIsAlready($port))) {
|
||||
return;
|
||||
}
|
||||
while ($this->checkPortIsAlready($port)) {
|
||||
Process::kill($pid, SIGTERM);
|
||||
usleep(300);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param $port
|
||||
* @return bool|string
|
||||
* @throws Exception
|
||||
*/
|
||||
private function checkPortIsAlready($port): bool|string
|
||||
{
|
||||
if (!Kiri::getPlatform()->isLinux()) {
|
||||
exec("lsof -i :" . $port . " | grep -i 'LISTEN' | awk '{print $2}'", $output);
|
||||
if (empty($output)) return false;
|
||||
$output = explode(PHP_EOL, $output[0]);
|
||||
return $output[0];
|
||||
}
|
||||
|
||||
$serverPid = file_get_contents(storage('.swoole.pid'));
|
||||
if (!empty($serverPid) && shell_exec('ps -ef | grep ' . $serverPid . ' | grep -v grep')) {
|
||||
Process::kill($serverPid, SIGTERM);
|
||||
}
|
||||
|
||||
exec('netstat -lnp | grep ' . $port . ' | grep "LISTEN" | awk \'{print $7}\'', $output);
|
||||
if (empty($output)) {
|
||||
return false;
|
||||
}
|
||||
return explode('/', $output[0])[0];
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param array $settings
|
||||
* @throws ContainerExceptionInterface
|
||||
* @throws NotFoundExceptionInterface
|
||||
* @throws ReflectionException
|
||||
* @throws Exception
|
||||
*/
|
||||
private function addDefaultListener(array $settings): void
|
||||
{
|
||||
@@ -431,6 +323,9 @@ class ServerManager
|
||||
/**
|
||||
* @param array $events
|
||||
* @param Server|Port $server
|
||||
* @throws ContainerExceptionInterface
|
||||
* @throws NotFoundExceptionInterface
|
||||
* @throws ReflectionException
|
||||
*/
|
||||
private function addServiceEvents(array $events, Server|Port $server)
|
||||
{
|
||||
@@ -452,40 +347,6 @@ class ServerManager
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param string $class
|
||||
* @return object
|
||||
*/
|
||||
private function getNewInstance(string $class): object
|
||||
{
|
||||
return $this->container->create($class);
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param OnTaskInterface|string $handler
|
||||
* @param array $params
|
||||
* @param int|null $workerId
|
||||
* @throws ReflectionException
|
||||
* @throws Exception
|
||||
*/
|
||||
public function task(OnTaskInterface|string $handler, array $params = [], int $workerId = null)
|
||||
{
|
||||
if ($workerId === null || $workerId <= $this->server->setting['worker_num']) {
|
||||
$workerId = random_int($this->server->setting['worker_num'] + 1,
|
||||
$this->server->setting['worker_num'] + 1 + $this->server->setting['task_worker_num']);
|
||||
}
|
||||
if (is_string($handler)) {
|
||||
$implements = $this->container->getReflect($handler);
|
||||
if (!in_array(OnTaskInterface::class, $implements->getInterfaceNames())) {
|
||||
throw new Exception('Task must instance ' . OnTaskInterface::class);
|
||||
}
|
||||
$handler = $implements->newInstanceArgs($params);
|
||||
}
|
||||
$this->server->task(serialize($handler), $workerId);
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param mixed $message
|
||||
* @param int $workerId
|
||||
@@ -499,28 +360,31 @@ class ServerManager
|
||||
|
||||
/**
|
||||
* @param array $events
|
||||
* @throws ContainerExceptionInterface
|
||||
* @throws NotFoundExceptionInterface
|
||||
* @throws ReflectionException
|
||||
*/
|
||||
private function addTaskListener(array $events = []): void
|
||||
{
|
||||
$task_use_object = $this->server->setting['task_object'] ?? $this->server->setting['task_use_object'] ?? false;
|
||||
$reflect = $this->container->getReflect(OnServerTask::class)?->newInstance();
|
||||
$reflect = $this->container->get(OnServerTask::class);
|
||||
$this->server->on('finish', $events[Constant::FINISH] ?? [$reflect, 'onFinish']);
|
||||
if ($task_use_object || $this->server->setting['task_enable_coroutine']) {
|
||||
$this->server->on('task', $events[Constant::TASK] ?? [$reflect, 'onCoroutineTask']);
|
||||
} else {
|
||||
$this->server->on('task', $events[Constant::TASK] ?? [$reflect, 'onTask']);
|
||||
}
|
||||
$this->server->on('finish', $events[Constant::FINISH] ?? [$reflect, 'onFinish']);
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param Port|Server $server
|
||||
* @param array|null $settings
|
||||
* @throws ContainerExceptionInterface
|
||||
* @throws NotFoundExceptionInterface
|
||||
* @throws ReflectionException
|
||||
*/
|
||||
public function bindCallback(Port|Server $server, ?array $settings = [])
|
||||
public function bindCallback(?array $settings = [])
|
||||
{
|
||||
// TODO: Implement bindCallback() method.
|
||||
if (count($settings) < 1) {
|
||||
return;
|
||||
}
|
||||
|
||||
@@ -0,0 +1,56 @@
|
||||
<?php
|
||||
|
||||
namespace Server;
|
||||
|
||||
use Exception;
|
||||
use Kiri\Abstracts\BaseObject;
|
||||
use Kiri\Abstracts\Config;
|
||||
use Swoole\Process;
|
||||
|
||||
class State extends BaseObject
|
||||
{
|
||||
|
||||
use TraitServer;
|
||||
|
||||
|
||||
public array $servers = [];
|
||||
|
||||
|
||||
public function init()
|
||||
{
|
||||
$this->servers = Config::get('server.ports');
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @return bool
|
||||
* @throws Exception
|
||||
*/
|
||||
public function isRunner(): bool
|
||||
{
|
||||
$ports = $this->sortService($this->servers);
|
||||
foreach ($ports as $config) {
|
||||
if (checkPortIsAlready($config['port'])) {
|
||||
return true;
|
||||
}
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param $port
|
||||
* @throws Exception
|
||||
*/
|
||||
public function exit($port)
|
||||
{
|
||||
if (!($pid = checkPortIsAlready($port))) {
|
||||
return;
|
||||
}
|
||||
while (checkPortIsAlready($port)) {
|
||||
Process::kill($pid, SIGTERM);
|
||||
usleep(300);
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,102 @@
|
||||
<?php
|
||||
|
||||
namespace Server\Tasker;
|
||||
|
||||
use Exception;
|
||||
use Kiri\Abstracts\BaseObject;
|
||||
use Kiri\Core\HashMap;
|
||||
use Kiri\Di\Container;
|
||||
use Kiri\Kiri;
|
||||
use Note\Inject;
|
||||
use Psr\Container\ContainerInterface;
|
||||
use ReflectionException;
|
||||
use Server\Contract\OnTaskInterface;
|
||||
use Server\SwooleServerInterface;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
class AsyncTaskExecute extends BaseObject
|
||||
{
|
||||
|
||||
|
||||
/**
|
||||
* @var SwooleServerInterface|null
|
||||
*/
|
||||
public ?SwooleServerInterface $server = null;
|
||||
|
||||
|
||||
/**
|
||||
* @var Container
|
||||
*/
|
||||
#[Inject(ContainerInterface::class)]
|
||||
public ContainerInterface $container;
|
||||
|
||||
|
||||
private HashMap $hashMap;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
public function init()
|
||||
{
|
||||
$this->hashMap = new HashMap();
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param string $key
|
||||
* @param $handler
|
||||
*/
|
||||
public function reg(string $key, $handler)
|
||||
{
|
||||
$this->hashMap->put($key, $handler);
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param OnTaskInterface|string $handler
|
||||
* @param array $params
|
||||
* @param int|null $workerId
|
||||
* @throws Exception
|
||||
*/
|
||||
public function execute(OnTaskInterface|string $handler, array $params = [], int $workerId = null)
|
||||
{
|
||||
if (!$this->server) {
|
||||
$this->server = Kiri::getDi()->get(SwooleServerInterface::class);
|
||||
}
|
||||
if ($workerId === null || $workerId <= $this->server->setting['worker_num']) {
|
||||
$workerNum = $this->server->setting['worker_num'];
|
||||
$taskerNum = $workerNum + $this->server->setting['task_worker_num'];
|
||||
$workerId = random_int($workerNum, $taskerNum - 1);
|
||||
}
|
||||
if (is_string($handler)) {
|
||||
$handler = $this->handle($handler, $params);
|
||||
}
|
||||
$this->server->task(serialize($handler), $workerId);
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param $handler
|
||||
* @param $params
|
||||
* @return object
|
||||
* @throws ReflectionException
|
||||
* @throws Exception
|
||||
*/
|
||||
private function handle($handler, $params): object
|
||||
{
|
||||
if (!class_exists($handler) && $this->hashMap->has($handler)) {
|
||||
$handler = $this->hashMap->get($handler);
|
||||
}
|
||||
$implements = $this->container->getReflect($handler);
|
||||
if (!in_array(OnTaskInterface::class, $implements->getInterfaceNames())) {
|
||||
throw new Exception('Task must instance ' . OnTaskInterface::class);
|
||||
}
|
||||
return $implements->newInstanceArgs($params);
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
@@ -1,15 +1,14 @@
|
||||
<?php
|
||||
|
||||
|
||||
namespace Server\Handler;
|
||||
namespace Server\Tasker;
|
||||
|
||||
|
||||
use Annotation\Inject;
|
||||
use Note\Inject;
|
||||
use Kiri\Abstracts\Logger;
|
||||
use Kiri\Exception\ConfigException;
|
||||
use Kiri\Kiri;
|
||||
use ReflectionException;
|
||||
use Server\SInterface\OnTaskInterface;
|
||||
use Server\Contract\OnTaskInterface;
|
||||
use Swoole\Server;
|
||||
|
||||
|
||||
@@ -68,19 +67,14 @@ class OnServerTask
|
||||
/**
|
||||
* @param $data
|
||||
* @return null
|
||||
* @throws ReflectionException
|
||||
*/
|
||||
private function resolve($data)
|
||||
{
|
||||
[$class, $params] = json_encode($data, true);
|
||||
|
||||
$reflect = Kiri::getDi()->getReflect($class);
|
||||
|
||||
if (!$reflect->isInstantiable()) {
|
||||
return null;
|
||||
$execute = unserialize($data);
|
||||
if ($execute instanceof OnTaskInterface) {
|
||||
return $execute->execute();
|
||||
}
|
||||
$class = $reflect->newInstanceArgs($params);
|
||||
return $class->execute();
|
||||
return null;
|
||||
}
|
||||
|
||||
|
||||
@@ -0,0 +1,32 @@
|
||||
<?php
|
||||
|
||||
namespace Server;
|
||||
|
||||
trait TraitServer
|
||||
{
|
||||
|
||||
|
||||
/**
|
||||
* @param array $ports
|
||||
* @return array
|
||||
*/
|
||||
public function sortService(array $ports): array
|
||||
{
|
||||
$array = [];
|
||||
foreach ($ports as $port) {
|
||||
if ($port['type'] == Constant::SERVER_TYPE_WEBSOCKET) {
|
||||
array_unshift($array, $port);
|
||||
} else if ($port['type'] == Constant::SERVER_TYPE_HTTP) {
|
||||
if (!empty($array) && $array[0]['type'] == Constant::SERVER_TYPE_WEBSOCKET) {
|
||||
$array[] = $port;
|
||||
} else {
|
||||
array_unshift($array, $port);
|
||||
}
|
||||
} else {
|
||||
$array[] = $port;
|
||||
}
|
||||
}
|
||||
return $array;
|
||||
}
|
||||
|
||||
}
|
||||
+2
-2
@@ -1,5 +1,5 @@
|
||||
{
|
||||
"name": "game-worker/http-server",
|
||||
"name": "game-worker/kiri-http-server",
|
||||
"description": "http-server",
|
||||
"license": "MIT",
|
||||
"authors": [
|
||||
@@ -15,7 +15,7 @@
|
||||
"psr/http-server-middleware": "^1.0",
|
||||
"psr/http-message": "^1.0",
|
||||
"psr/event-dispatcher": "^1.0",
|
||||
"game-worker/kiri-http-message": "^v1.0"
|
||||
"game-worker/kiri-http-message": "^v1.2"
|
||||
},
|
||||
"autoload": {
|
||||
"psr-4": {
|
||||
|
||||
Reference in New Issue
Block a user