Compare commits
136 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 122f37d6ce | |||
| 9fe40ff78a | |||
| ae4d75f310 | |||
| 707379c0fd | |||
| b861e0b17b | |||
| 7b576476a2 | |||
| 711a819ebb | |||
| 971b1f1fb0 | |||
| 4831bc67f5 | |||
| 1b8c6ecde0 | |||
| a4c78874e4 | |||
| b6c4693ef6 | |||
| adfa1cf3f2 | |||
| 6362a5ce91 | |||
| edeedd2258 | |||
| 02d0c9a8fd | |||
| d707b7f384 | |||
| b6f1d8eaf7 | |||
| c67fc70550 | |||
| e55be953bf | |||
| aca8cac1a4 | |||
| e699907970 | |||
| 97dc2f559b | |||
| 33a01eda28 | |||
| b38704374a | |||
| 318377212c | |||
| ddbdae5013 | |||
| 6eb7aa1fb0 | |||
| 078e8338fe | |||
| 6bcd76333a | |||
| b2728947a3 | |||
| 8ec5b0e8d8 | |||
| 2939d58585 | |||
| 146da1d00c | |||
| 51babeddc1 | |||
| 550197de96 | |||
| b5ad99332d | |||
| e9b51ffb1e | |||
| 8c9de79027 | |||
| 85c973469f | |||
| db8d9a8376 | |||
| 18b4e79f5f | |||
| 0b7f380298 | |||
| ea400c4ea5 | |||
| 07cfb62bb8 | |||
| a5efa0813f | |||
| d1f2912324 | |||
| ba0acf8f00 | |||
| 2788008fa1 | |||
| 5beee8352d | |||
| 35859fead1 | |||
| 0031d73eff | |||
| 89807fe548 | |||
| 9c28ce91ae | |||
| 7ed01ba893 | |||
| 926a8c0719 | |||
| 688a30531a | |||
| 1ff9d7f210 | |||
| da038f4fd8 | |||
| de20fa9582 | |||
| 80cf72adc9 | |||
| dabcea452a | |||
| 2feda943af | |||
| bffe375230 | |||
| efb69d02f3 | |||
| 79e5fa0b08 | |||
| de7e005b46 | |||
| a64fa8f493 | |||
| c19e141f68 | |||
| 94a522588d | |||
| 308c992fd3 | |||
| 458c6cbd22 | |||
| b717a7e9f7 | |||
| 6786b313b5 | |||
| 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 | |||
| 8937574ecc | |||
| bd9f9ce311 | |||
| 96481e1f4d |
+82
-92
@@ -1,11 +1,11 @@
|
||||
<?php
|
||||
|
||||
namespace Server\Abstracts;
|
||||
namespace Kiri\Server\Abstracts;
|
||||
|
||||
|
||||
use JetBrains\PhpStorm\Pure;
|
||||
use Kiri\Kiri;
|
||||
use Server\SInterface\OnProcessInterface;
|
||||
use Kiri\Context;
|
||||
use Kiri\Server\Broadcast\OnBroadcastInterface;
|
||||
use Kiri\Server\Contract\OnProcessInterface;
|
||||
use Swoole\Coroutine;
|
||||
use Swoole\Process;
|
||||
|
||||
@@ -15,13 +15,63 @@ use Swoole\Process;
|
||||
abstract class BaseProcess implements OnProcessInterface
|
||||
{
|
||||
|
||||
/** @var bool */
|
||||
protected bool $enableSwooleCoroutine = true;
|
||||
|
||||
|
||||
protected bool $isStop = false;
|
||||
|
||||
|
||||
protected bool $redirect_stdin_and_stdout = FALSE;
|
||||
|
||||
|
||||
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 bool
|
||||
*/
|
||||
public function getRedirectStdinAndStdout(): bool
|
||||
{
|
||||
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 +81,36 @@ 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
|
||||
public function onSigterm(): static
|
||||
{
|
||||
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);
|
||||
if (!Context::inCoroutine()) {
|
||||
Process::signal(SIGTERM, fn($data) => $this->onShutdown($data));
|
||||
} else {
|
||||
usleep(100);
|
||||
Coroutine::create(function () {
|
||||
$data = Coroutine::waitSignal(SIGTERM, -1);
|
||||
if ($data) {
|
||||
$this->onShutdown($data);
|
||||
}
|
||||
});
|
||||
}
|
||||
return $this;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param $data
|
||||
*/
|
||||
protected function onShutdown($data): void
|
||||
{
|
||||
$this->isStop = true;
|
||||
$value = Context::getContext('waite:process:message');
|
||||
if (Coroutine::exists($value)) {
|
||||
Coroutine::cancel($value);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
|
||||
@@ -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);
|
||||
}
|
||||
|
||||
}
|
||||
@@ -1,14 +1,14 @@
|
||||
<?php
|
||||
|
||||
|
||||
namespace Server\Abstracts;
|
||||
namespace Kiri\Server\Abstracts;
|
||||
|
||||
|
||||
use Annotation\Inject;
|
||||
use Kiri\Annotation\Inject;
|
||||
use Exception;
|
||||
use Kiri\Abstracts\Config;
|
||||
use Kiri\Exception\ConfigException;
|
||||
use Kiri\Kiri;
|
||||
use Kiri;
|
||||
use Psr\Log\LoggerInterface;
|
||||
|
||||
|
||||
@@ -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);
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,34 @@
|
||||
<?php
|
||||
|
||||
namespace Kiri\Server\Broadcast;
|
||||
|
||||
use Kiri;
|
||||
use Kiri\Server\ProcessManager;
|
||||
use Kiri\Server\SwooleServerInterface;
|
||||
|
||||
class Broadcast
|
||||
{
|
||||
|
||||
|
||||
/**
|
||||
* @param $message
|
||||
* @return void
|
||||
*/
|
||||
public function broadcast($message)
|
||||
{
|
||||
$di = Kiri::getDi();
|
||||
$di->get(ProcessManager::class)->push($message);
|
||||
|
||||
$server = $di->get(SwooleServerInterface::class);
|
||||
|
||||
$total = $server->setting['worker_num'] + $server->setting['task_worker_num'];
|
||||
for ($i = 0; $i < $total; $i++) {
|
||||
if ($i == env('environmental_workerId')) {
|
||||
continue;
|
||||
}
|
||||
$server->sendMessage(serialize(new Message($message)), $i);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
@@ -0,0 +1,34 @@
|
||||
<?php
|
||||
|
||||
namespace Kiri\Server\Broadcast;
|
||||
|
||||
|
||||
use Kiri;
|
||||
use Kiri\Server\Contract\OnPipeMessageInterface;
|
||||
use Psr\Log\LoggerInterface;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
class Message implements OnPipeMessageInterface, OnBroadcastInterface
|
||||
{
|
||||
|
||||
/**
|
||||
* @param mixed $data
|
||||
*/
|
||||
public function __construct(public mixed $data)
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @return void
|
||||
*/
|
||||
public function process(): void
|
||||
{
|
||||
$logger = Kiri::getDi()->get(LoggerInterface::class);
|
||||
$logger->debug(env('environmental') . '::' . env('environmental_workerId', 0) . '::' . $this->data);
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,14 @@
|
||||
<?php
|
||||
|
||||
namespace Kiri\Server\Broadcast;
|
||||
|
||||
interface OnBroadcastInterface
|
||||
{
|
||||
|
||||
|
||||
/**
|
||||
* @return void
|
||||
*/
|
||||
public function process(): void;
|
||||
|
||||
}
|
||||
+2
-1
@@ -1,7 +1,7 @@
|
||||
<?php
|
||||
|
||||
|
||||
namespace Server;
|
||||
namespace Kiri\Server;
|
||||
|
||||
|
||||
/**
|
||||
@@ -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 Kiri\Server\Contract;
|
||||
|
||||
interface OnBeforeShutdown
|
||||
{
|
||||
@@ -0,0 +1,21 @@
|
||||
<?php
|
||||
|
||||
namespace Kiri\Server\Contract;
|
||||
|
||||
use Swoole\Server;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
interface OnCloseInterface
|
||||
{
|
||||
|
||||
|
||||
/**
|
||||
* @param int $fd
|
||||
*/
|
||||
public function onClose(int $fd): void;
|
||||
|
||||
|
||||
}
|
||||
@@ -1,6 +1,6 @@
|
||||
<?php
|
||||
|
||||
namespace Server\SInterface;
|
||||
namespace Kiri\Server\Contract;
|
||||
|
||||
use Swoole\Server;
|
||||
|
||||
@@ -0,0 +1,18 @@
|
||||
<?php
|
||||
|
||||
namespace Kiri\Server\Contract;
|
||||
|
||||
use Swoole\Server;
|
||||
|
||||
interface OnDisconnectInterface
|
||||
{
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* @param int $fd
|
||||
*/
|
||||
public function onDisconnect(int $fd): void;
|
||||
|
||||
|
||||
}
|
||||
@@ -1,6 +1,6 @@
|
||||
<?php
|
||||
|
||||
namespace Server\SInterface;
|
||||
namespace Kiri\Server\Contract;
|
||||
|
||||
use Swoole\Http\Request;
|
||||
use Swoole\Http\Response;
|
||||
@@ -0,0 +1,18 @@
|
||||
<?php
|
||||
|
||||
namespace Kiri\Server\Contract;
|
||||
|
||||
use Kiri\Websocket\WebSocketInterface;
|
||||
use Swoole\WebSocket\Frame;
|
||||
|
||||
interface OnMessageInterface
|
||||
{
|
||||
|
||||
|
||||
/**
|
||||
* @param Frame $frame
|
||||
* @return void
|
||||
*/
|
||||
public function onMessage(Frame $frame): void;
|
||||
|
||||
}
|
||||
@@ -0,0 +1,16 @@
|
||||
<?php
|
||||
|
||||
namespace Kiri\Server\Contract;
|
||||
|
||||
use Swoole\Http\Request;
|
||||
|
||||
interface OnOpenInterface
|
||||
{
|
||||
|
||||
|
||||
/**
|
||||
* @param Request $request
|
||||
*/
|
||||
public function onOpen(Request $request): void;
|
||||
|
||||
}
|
||||
@@ -1,8 +1,8 @@
|
||||
<?php
|
||||
|
||||
namespace Server\SInterface;
|
||||
namespace Kiri\Server\Contract;
|
||||
|
||||
use Server\Abstracts\Server;
|
||||
use Kiri\Server\Abstracts\Server;
|
||||
|
||||
interface OnPacketInterface
|
||||
{
|
||||
@@ -1,12 +1,12 @@
|
||||
<?php
|
||||
|
||||
|
||||
namespace Server\SInterface;
|
||||
namespace Kiri\Server\Contract;
|
||||
|
||||
|
||||
/**
|
||||
* Interface OnPipeMessageInterface
|
||||
* @package Server\SInterface
|
||||
* @package Server\Contract
|
||||
*/
|
||||
interface OnPipeMessageInterface
|
||||
{
|
||||
@@ -0,0 +1,25 @@
|
||||
<?php
|
||||
|
||||
|
||||
namespace Kiri\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 Kiri\Server\Contract;
|
||||
|
||||
use Swoole\Server;
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
<?php
|
||||
|
||||
|
||||
namespace Server\SInterface;
|
||||
namespace Kiri\Server\Contract;
|
||||
|
||||
|
||||
use Swoole\Server;
|
||||
@@ -1,16 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Server\Events;
|
||||
|
||||
class OnAfterCommandExecute
|
||||
{
|
||||
|
||||
|
||||
/**
|
||||
* @param mixed $data
|
||||
*/
|
||||
public function __construct(public mixed $data)
|
||||
{
|
||||
}
|
||||
|
||||
}
|
||||
@@ -1,6 +1,6 @@
|
||||
<?php
|
||||
|
||||
namespace Server\Events;
|
||||
namespace Kiri\Server\Events;
|
||||
|
||||
use Swoole\Server;
|
||||
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
<?php
|
||||
|
||||
namespace Server\Events;
|
||||
namespace Kiri\Server\Events;
|
||||
|
||||
class OnAfterWorkerStart
|
||||
{
|
||||
|
||||
@@ -1,8 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Server\Events;
|
||||
|
||||
class OnBeforeCommandExecute
|
||||
{
|
||||
|
||||
}
|
||||
@@ -1,6 +1,6 @@
|
||||
<?php
|
||||
|
||||
namespace Server\Events;
|
||||
namespace Kiri\Server\Events;
|
||||
|
||||
use Swoole\Server;
|
||||
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
<?php
|
||||
|
||||
namespace Server\Events;
|
||||
namespace Kiri\Server\Events;
|
||||
|
||||
use Swoole\Server;
|
||||
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
<?php
|
||||
|
||||
namespace Server\Events;
|
||||
namespace Kiri\Server\Events;
|
||||
|
||||
class OnBeforeWorkerStart
|
||||
{
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
<?php
|
||||
|
||||
namespace Server\Events;
|
||||
namespace Kiri\Server\Events;
|
||||
|
||||
use Swoole\Server;
|
||||
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
<?php
|
||||
|
||||
namespace Server\Events;
|
||||
namespace Kiri\Server\Events;
|
||||
|
||||
use Swoole\Server;
|
||||
|
||||
|
||||
@@ -0,0 +1,8 @@
|
||||
<?php
|
||||
|
||||
namespace Kiri\Server\Events;
|
||||
|
||||
class OnServerBeforeStart
|
||||
{
|
||||
|
||||
}
|
||||
@@ -1,6 +1,6 @@
|
||||
<?php
|
||||
|
||||
namespace Server\Events;
|
||||
namespace Kiri\Server\Events;
|
||||
|
||||
use Swoole\Server;
|
||||
|
||||
|
||||
+1
-1
@@ -1,6 +1,6 @@
|
||||
<?php
|
||||
|
||||
namespace Server\Events;
|
||||
namespace Kiri\Server\Events;
|
||||
|
||||
use Swoole\Server;
|
||||
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
<?php
|
||||
|
||||
namespace Server\Events;
|
||||
namespace Kiri\Server\Events;
|
||||
|
||||
use Swoole\Server;
|
||||
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
<?php
|
||||
|
||||
namespace Server\Events;
|
||||
namespace Kiri\Server\Events;
|
||||
|
||||
use Swoole\Server;
|
||||
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
<?php
|
||||
|
||||
namespace Server\Events;
|
||||
namespace Kiri\Server\Events;
|
||||
|
||||
use Swoole\Server;
|
||||
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
<?php
|
||||
|
||||
namespace Server\Events;
|
||||
namespace Kiri\Server\Events;
|
||||
|
||||
use Swoole\Server;
|
||||
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
<?php
|
||||
|
||||
namespace Server\Events;
|
||||
namespace Kiri\Server\Events;
|
||||
|
||||
use Swoole\Server;
|
||||
|
||||
|
||||
@@ -1,12 +1,12 @@
|
||||
<?php
|
||||
|
||||
namespace Server\Handler;
|
||||
namespace Kiri\Server\Handler;
|
||||
|
||||
use Annotation\Inject;
|
||||
use Server\Abstracts\Server;
|
||||
use Exception;
|
||||
use Server\SInterface\OnPipeMessageInterface;
|
||||
use Kiri\Annotation\Inject;
|
||||
use Kiri\Events\EventDispatch;
|
||||
use Kiri\Server\Abstracts\Server;
|
||||
use Kiri\Server\Contract\OnPipeMessageInterface;
|
||||
|
||||
/**
|
||||
*
|
||||
@@ -15,7 +15,7 @@ class OnPipeMessage extends Server
|
||||
{
|
||||
|
||||
|
||||
/** @var EventDispatch */
|
||||
/** @var EventDispatch */
|
||||
#[Inject(EventDispatch::class)]
|
||||
public EventDispatch $eventDispatch;
|
||||
|
||||
@@ -28,6 +28,9 @@ class OnPipeMessage extends Server
|
||||
*/
|
||||
public function onPipeMessage(\Swoole\Server $server, int $src_worker_id, mixed $message)
|
||||
{
|
||||
if (is_string($message)) {
|
||||
$message = unserialize($message);
|
||||
}
|
||||
if (!is_object($message) || !($message instanceof OnPipeMessageInterface)) {
|
||||
return;
|
||||
}
|
||||
|
||||
+10
-6
@@ -1,14 +1,15 @@
|
||||
<?php
|
||||
|
||||
namespace Server\Handler;
|
||||
namespace Kiri\Server\Handler;
|
||||
|
||||
use Annotation\Inject;
|
||||
use Kiri\Annotation\Inject;
|
||||
use Kiri\Events\EventDispatch;
|
||||
use Kiri\Exception\ConfigException;
|
||||
use Server\Abstracts\Server;
|
||||
use Server\Events\OnBeforeShutdown;
|
||||
use Server\Events\OnShutdown;
|
||||
use Server\Events\OnStart;
|
||||
use ReflectionException;
|
||||
use Kiri\Server\Abstracts\Server;
|
||||
use Kiri\Server\Events\OnBeforeShutdown;
|
||||
use Kiri\Server\Events\OnShutdown;
|
||||
use Kiri\Server\Events\OnStart;
|
||||
|
||||
|
||||
/**
|
||||
@@ -28,6 +29,7 @@ class OnServer extends Server
|
||||
/**
|
||||
* @param \Swoole\Server $server
|
||||
* @throws ConfigException
|
||||
* @throws ReflectionException
|
||||
*/
|
||||
public function onStart(\Swoole\Server $server)
|
||||
{
|
||||
@@ -39,6 +41,7 @@ class OnServer extends Server
|
||||
|
||||
/**
|
||||
* @param \Swoole\Server $server
|
||||
* @throws ReflectionException
|
||||
*/
|
||||
public function onBeforeShutdown(\Swoole\Server $server)
|
||||
{
|
||||
@@ -48,6 +51,7 @@ class OnServer extends Server
|
||||
|
||||
/**
|
||||
* @param \Swoole\Server $server
|
||||
* @throws ReflectionException
|
||||
*/
|
||||
public function onShutdown(\Swoole\Server $server)
|
||||
{
|
||||
|
||||
@@ -1,13 +1,14 @@
|
||||
<?php
|
||||
|
||||
namespace Server\Handler;
|
||||
namespace Kiri\Server\Handler;
|
||||
|
||||
use Annotation\Inject;
|
||||
use Kiri\Annotation\Inject;
|
||||
use Kiri\Events\EventDispatch;
|
||||
use Server\Abstracts\Server;
|
||||
use ReflectionException;
|
||||
use Kiri\Server\Abstracts\Server;
|
||||
use Kiri\Exception\ConfigException;
|
||||
use Server\Events\OnManagerStart;
|
||||
use Server\Events\OnManagerStop;
|
||||
use Kiri\Server\Events\OnManagerStart;
|
||||
use Kiri\Server\Events\OnManagerStop;
|
||||
|
||||
|
||||
/**
|
||||
@@ -26,8 +27,8 @@ class OnServerManager extends Server
|
||||
|
||||
/**
|
||||
* @param \Swoole\Server $server
|
||||
* @throws ConfigException
|
||||
*/
|
||||
* @throws ConfigException|ReflectionException
|
||||
*/
|
||||
public function onManagerStart(\Swoole\Server $server)
|
||||
{
|
||||
$this->setProcessName(sprintf('manger[%d].0', $server->manager_pid));
|
||||
@@ -38,6 +39,7 @@ class OnServerManager extends Server
|
||||
|
||||
/**
|
||||
* @param \Swoole\Server $server
|
||||
* @throws ReflectionException
|
||||
*/
|
||||
public function onManagerStop(\Swoole\Server $server)
|
||||
{
|
||||
|
||||
@@ -1,11 +1,11 @@
|
||||
<?php
|
||||
|
||||
namespace Server\Handler;
|
||||
namespace Kiri\Server\Handler;
|
||||
|
||||
use Annotation\Inject;
|
||||
use Kiri\Annotation\Inject;
|
||||
use Kiri\Events\EventDispatch;
|
||||
use Server\Events\OnAfterReload;
|
||||
use Server\Events\OnBeforeReload;
|
||||
use Kiri\Server\Events\OnAfterReload;
|
||||
use Kiri\Server\Events\OnBeforeReload;
|
||||
use Swoole\Server;
|
||||
|
||||
|
||||
@@ -25,6 +25,7 @@ class OnServerReload
|
||||
|
||||
/**
|
||||
* @param Server $server
|
||||
* @throws \ReflectionException
|
||||
*/
|
||||
public function onBeforeReload(Server $server)
|
||||
{
|
||||
@@ -34,6 +35,7 @@ class OnServerReload
|
||||
|
||||
/**
|
||||
* @param Server $server
|
||||
* @throws \ReflectionException
|
||||
*/
|
||||
public function onAfterReload(Server $server)
|
||||
{
|
||||
|
||||
+31
-32
@@ -1,21 +1,21 @@
|
||||
<?php
|
||||
|
||||
namespace Server\Handler;
|
||||
namespace Kiri\Server\Handler;
|
||||
|
||||
use Annotation\Inject;
|
||||
use Exception;
|
||||
use Kiri;
|
||||
use Kiri\Abstracts\Config;
|
||||
use Kiri\Annotation\Inject;
|
||||
use Kiri\Core\Help;
|
||||
use Kiri\Events\EventDispatch;
|
||||
use Kiri\Runtime;
|
||||
use Server\Events\OnAfterWorkerStart;
|
||||
use Server\Events\OnBeforeWorkerStart;
|
||||
use Server\Events\OnTaskerStart as OnTaskStart;
|
||||
use Server\Events\OnWorkerError;
|
||||
use Server\Events\OnWorkerExit;
|
||||
use Server\Events\OnWorkerStart;
|
||||
use Server\Events\OnWorkerStop;
|
||||
use Server\ServerManager;
|
||||
use Kiri\Message\Handler\Router;
|
||||
use Kiri\Server\Events\OnAfterWorkerStart;
|
||||
use Kiri\Server\Events\OnBeforeWorkerStart;
|
||||
use Kiri\Server\Events\OnTaskerStart as OnTaskStart;
|
||||
use Kiri\Server\Events\OnWorkerError;
|
||||
use Kiri\Server\Events\OnWorkerExit;
|
||||
use Kiri\Server\Events\OnWorkerStart;
|
||||
use Kiri\Server\Events\OnWorkerStop;
|
||||
use Swoole\Server;
|
||||
use Swoole\Timer;
|
||||
|
||||
@@ -24,7 +24,7 @@ use Swoole\Timer;
|
||||
* Class OnServerWorker
|
||||
* @package Server\Worker
|
||||
*/
|
||||
class OnServerWorker extends \Server\Abstracts\Server
|
||||
class OnServerWorker extends \Kiri\Server\Abstracts\Server
|
||||
{
|
||||
|
||||
|
||||
@@ -35,6 +35,18 @@ class OnServerWorker extends \Server\Abstracts\Server
|
||||
public EventDispatch $eventDispatch;
|
||||
|
||||
|
||||
public Router $collector;
|
||||
|
||||
|
||||
/**
|
||||
* @return void
|
||||
*/
|
||||
public function init()
|
||||
{
|
||||
$this->collector = Kiri::getDi()->get(Router::class);
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param Server $server
|
||||
* @param int $workerId
|
||||
@@ -43,31 +55,21 @@ class OnServerWorker extends \Server\Abstracts\Server
|
||||
public function onWorkerStart(Server $server, int $workerId)
|
||||
{
|
||||
$this->eventDispatch->dispatch(new OnBeforeWorkerStart($workerId));
|
||||
set_env('environmental_workerId', $workerId);
|
||||
if ($workerId < $server->setting['worker_num']) {
|
||||
$this->eventDispatch->dispatch(new OnWorkerStart($server, $workerId));
|
||||
$this->setProcessName(sprintf('Worker[%d].%d', $server->worker_pid, $workerId));
|
||||
$this->collector->scan_build_route();
|
||||
$this->eventDispatch->dispatch(new OnWorkerStart($server, $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 +77,8 @@ class OnServerWorker extends \Server\Abstracts\Server
|
||||
*/
|
||||
public function onWorkerStop(Server $server, int $workerId)
|
||||
{
|
||||
$this->eventDispatch->dispatch(new OnWorkerStop($server, $workerId));
|
||||
|
||||
Timer::clearAll();
|
||||
$this->eventDispatch->dispatch(new OnWorkerStop($server, $workerId));
|
||||
}
|
||||
|
||||
|
||||
@@ -89,8 +90,6 @@ class OnServerWorker extends \Server\Abstracts\Server
|
||||
public function onWorkerExit(Server $server, int $workerId)
|
||||
{
|
||||
$this->eventDispatch->dispatch(new OnWorkerExit($server, $workerId));
|
||||
|
||||
ServerManager::setEnv('state', 'exit');
|
||||
}
|
||||
|
||||
|
||||
@@ -123,7 +122,7 @@ class OnServerWorker extends \Server\Abstracts\Server
|
||||
protected function system_mail($messageContent)
|
||||
{
|
||||
try {
|
||||
$email = Config::get('email');
|
||||
$email = Config::get('email', ['enable' => false]);
|
||||
if (!empty($email) && ($email['enable'] ?? false) == true) {
|
||||
Help::sendEmail($email, 'Service Error', $messageContent);
|
||||
}
|
||||
|
||||
@@ -0,0 +1,114 @@
|
||||
<?php
|
||||
|
||||
namespace Kiri\Server;
|
||||
|
||||
use Kiri\Abstracts\Config;
|
||||
use Kiri\Annotation\Inject;
|
||||
use Kiri\Context;
|
||||
use Kiri\Exception\ConfigException;
|
||||
use Kiri;
|
||||
use Kiri\Server\Abstracts\BaseProcess;
|
||||
use Kiri\Server\Broadcast\Message;
|
||||
use Kiri\Server\Contract\OnProcessInterface;
|
||||
use Psr\Log\LoggerInterface;
|
||||
use Swoole\Coroutine;
|
||||
use Swoole\Process;
|
||||
|
||||
class ProcessManager
|
||||
{
|
||||
|
||||
|
||||
/** @var array<string, Process> */
|
||||
private array $_process = [];
|
||||
|
||||
|
||||
#[Inject(LoggerInterface::class)]
|
||||
public LoggerInterface $logger;
|
||||
|
||||
/**
|
||||
* @param string|OnProcessInterface|BaseProcess $customProcess
|
||||
* @return void
|
||||
* @throws ConfigException
|
||||
*/
|
||||
public function add(string|OnProcessInterface|BaseProcess $customProcess)
|
||||
{
|
||||
$server = Kiri::getDi()->get(SwooleServerInterface::class);
|
||||
if (is_string($customProcess)) {
|
||||
$customProcess = Kiri::getDi()->get($customProcess);
|
||||
}
|
||||
|
||||
$system = sprintf('[%s].process', Config::get('id', 'system-service'));
|
||||
|
||||
$this->logger->debug($system . ' ' . $customProcess->getName() . ' start.');
|
||||
|
||||
$server->addProcess($process = $this->parse($customProcess, $system));
|
||||
$this->_process[$customProcess->getName()] = $process;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param $customProcess
|
||||
* @param $system
|
||||
* @return Process
|
||||
*/
|
||||
private function parse($customProcess, $system): Process
|
||||
{
|
||||
return new Process(function (Process $process) use ($customProcess, $system) {
|
||||
if (Kiri::getPlatform()->isLinux()) {
|
||||
$process->name($system . '(' . $customProcess->getName() . ')');
|
||||
}
|
||||
set_env('environmental', Kiri::PROCESS);
|
||||
$channel = Coroutine::create(function () use ($process, $customProcess) {
|
||||
while (!$customProcess->isStop()) {
|
||||
$message = $process->read();
|
||||
if (!empty($message)) {
|
||||
$message = unserialize($message);
|
||||
}
|
||||
if (is_null($message)) {
|
||||
continue;
|
||||
}
|
||||
$customProcess->onBroadcast($message);
|
||||
}
|
||||
});
|
||||
Context::setContext('waite:process:message', $channel);
|
||||
|
||||
$customProcess->onSigterm()->process($process);
|
||||
},
|
||||
$customProcess->getRedirectStdinAndStdout(),
|
||||
$customProcess->getPipeType(),
|
||||
$customProcess->isEnableCoroutine()
|
||||
);
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param array $processes
|
||||
* @return void
|
||||
* @throws ConfigException
|
||||
*/
|
||||
public function batch(array $processes)
|
||||
{
|
||||
foreach ($processes as $process) {
|
||||
$this->add($process);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param string $message
|
||||
* @param string $name
|
||||
* @return void
|
||||
*/
|
||||
public function push(string $message, string $name = '')
|
||||
{
|
||||
$processes = $this->_process;
|
||||
if (!empty($this->_process[$name])) {
|
||||
$processes = [$this->_process[$name]];
|
||||
}
|
||||
foreach ($processes as $process) {
|
||||
$process->write(serialize(new Message($message)));
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
@@ -1,22 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Server\SInterface;
|
||||
|
||||
use Swoole\Server;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
interface OnCloseInterface
|
||||
{
|
||||
|
||||
|
||||
/**
|
||||
* @param Server $server
|
||||
* @param int $fd
|
||||
*/
|
||||
public function onClose(Server $server, int $fd): void;
|
||||
|
||||
|
||||
}
|
||||
@@ -1,19 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Server\SInterface;
|
||||
|
||||
use Swoole\Server;
|
||||
|
||||
interface OnDisconnectInterface
|
||||
{
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* @param Server $server
|
||||
* @param int $fd
|
||||
*/
|
||||
public function onDisconnect(Server $server, int $fd): void;
|
||||
|
||||
|
||||
}
|
||||
@@ -1,12 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Server\SInterface;
|
||||
|
||||
use Swoole\Http\Response;
|
||||
|
||||
interface OnDownloadInterface
|
||||
{
|
||||
|
||||
public function dispatch(Response $response);
|
||||
|
||||
}
|
||||
@@ -1,19 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Server\SInterface;
|
||||
|
||||
use Swoole\Server;
|
||||
use Swoole\WebSocket\Frame;
|
||||
|
||||
interface OnMessageInterface
|
||||
{
|
||||
|
||||
|
||||
/**
|
||||
* @param Server $server
|
||||
* @param Frame $frame
|
||||
* @return void
|
||||
*/
|
||||
public function onMessage(Server $server, Frame $frame): void;
|
||||
|
||||
}
|
||||
@@ -1,18 +0,0 @@
|
||||
<?php
|
||||
|
||||
namespace Server\SInterface;
|
||||
|
||||
use Swoole\Http\Request;
|
||||
use Swoole\WebSocket\Server;
|
||||
|
||||
interface OnOpenInterface
|
||||
{
|
||||
|
||||
|
||||
/**
|
||||
* @param \Swoole\WebSocket\Server $server
|
||||
* @param \Swoole\Http\Request $request
|
||||
*/
|
||||
public function onOpen(Server $server, Request $request): void;
|
||||
|
||||
}
|
||||
@@ -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;
|
||||
|
||||
|
||||
}
|
||||
+48
-28
@@ -1,17 +1,22 @@
|
||||
<?php
|
||||
|
||||
|
||||
namespace Server;
|
||||
namespace Kiri\Server;
|
||||
|
||||
use Annotation\Inject;
|
||||
use Exception;
|
||||
use Http\Handler\Abstracts\HttpService;
|
||||
use JetBrains\PhpStorm\Pure;
|
||||
use Kiri;
|
||||
use Kiri\Abstracts\Config;
|
||||
use Kiri\Error\LoggerProcess;
|
||||
use Kiri\Annotation\Inject;
|
||||
use Kiri\Events\EventDispatch;
|
||||
use Kiri\Exception\ConfigException;
|
||||
use Server\Events\OnShutdown;
|
||||
use Kiri\Message\Handler\Abstracts\HttpService;
|
||||
use Kiri\Message\Handler\Router;
|
||||
use Kiri\Server\Events\OnShutdown;
|
||||
use Psr\Container\ContainerExceptionInterface;
|
||||
use Kiri\Server\Events\OnServerBeforeStart;
|
||||
use Psr\Container\NotFoundExceptionInterface;
|
||||
use Swoole\Coroutine;
|
||||
|
||||
|
||||
defined('PID_PATH') or define('PID_PATH', APP_PATH . 'storage/server.pid');
|
||||
@@ -24,23 +29,20 @@ class Server extends HttpService
|
||||
{
|
||||
|
||||
private array $process = [
|
||||
LoggerProcess::class
|
||||
];
|
||||
|
||||
|
||||
/**
|
||||
* @Inject ServerManager
|
||||
* @var null|ServerManager
|
||||
*/
|
||||
#[Inject(ServerManager::class)]
|
||||
public ?ServerManager $manager = null;
|
||||
|
||||
private mixed $daemon = 0;
|
||||
|
||||
|
||||
/** @var EventDispatch */
|
||||
#[Inject(EventDispatch::class)]
|
||||
public EventDispatch $eventDispatch;
|
||||
/**
|
||||
* @var State
|
||||
*/
|
||||
#[Inject(State::class)]
|
||||
public State $state;
|
||||
|
||||
|
||||
public ServerManager $manager;
|
||||
|
||||
|
||||
/**
|
||||
@@ -48,6 +50,19 @@ class Server extends HttpService
|
||||
*/
|
||||
public function init()
|
||||
{
|
||||
$this->manager = Kiri::getContainer()->get(ServerManager::class);
|
||||
$enable_coroutine = Config::get('servers.settings.enable_coroutine', false);
|
||||
Config::set('servers.settings.enable_coroutine', true);
|
||||
if ($enable_coroutine != true) {
|
||||
return;
|
||||
}
|
||||
Coroutine::set([
|
||||
'hook_flags' => SWOOLE_HOOK_ALL ^ SWOOLE_HOOK_BLOCKING_FUNCTION,
|
||||
'enable_deadlock_check' => FALSE,
|
||||
'exit_condition' => function () {
|
||||
return Coroutine::stats()['coroutine_num'] === 0;
|
||||
}
|
||||
]);
|
||||
}
|
||||
|
||||
|
||||
@@ -61,13 +76,14 @@ 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
|
||||
public function start(): mixed
|
||||
{
|
||||
$this->manager->initBaseServer(Config::get('server', [], true), $this->daemon);
|
||||
|
||||
@@ -78,9 +94,10 @@ class Server extends HttpService
|
||||
}
|
||||
|
||||
$processes = array_merge($this->process, Config::get('processes', []));
|
||||
foreach ($processes as $process) {
|
||||
$this->manager->addProcess($process);
|
||||
}
|
||||
|
||||
$this->container->get(ProcessManager::class)->batch($processes);
|
||||
|
||||
$this->eventDispatch->dispatch(new OnServerBeforeStart());
|
||||
|
||||
return $this->manager->getServer()->start();
|
||||
}
|
||||
@@ -88,27 +105,30 @@ class Server extends HttpService
|
||||
|
||||
/**
|
||||
* @return void
|
||||
*
|
||||
* start server
|
||||
* @throws ConfigException
|
||||
* @throws ContainerExceptionInterface
|
||||
* @throws NotFoundExceptionInterface
|
||||
* @throws \ReflectionException
|
||||
* @throws Exception
|
||||
*/
|
||||
public function shutdown()
|
||||
{
|
||||
$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());
|
||||
$this->container->get(EventDispatch::class)->dispatch(new OnShutdown());
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @return bool
|
||||
* @throws ConfigException
|
||||
* @throws Exception
|
||||
*/
|
||||
public function isRunner(): bool
|
||||
{
|
||||
return $this->manager->isRunner();
|
||||
return $this->state->isRunner();
|
||||
}
|
||||
|
||||
|
||||
|
||||
+30
-73
@@ -1,26 +1,17 @@
|
||||
<?php
|
||||
declare(strict_types=1);
|
||||
|
||||
namespace Server;
|
||||
namespace Kiri\Server;
|
||||
|
||||
|
||||
use Annotation\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 Kiri;
|
||||
use Kiri\Annotation\Inject;
|
||||
use Psr\Container\ContainerExceptionInterface;
|
||||
use Psr\Container\NotFoundExceptionInterface;
|
||||
use Swoole\Coroutine;
|
||||
use Symfony\Component\Console\Command\Command;
|
||||
use Symfony\Component\Console\Input\InputArgument;
|
||||
@@ -40,10 +31,10 @@ class ServerCommand extends Command
|
||||
|
||||
|
||||
/**
|
||||
* @var EventProvider
|
||||
* @var EventDispatch
|
||||
*/
|
||||
#[Inject(EventProvider::class)]
|
||||
public EventProvider $eventProvider;
|
||||
#[Inject(EventDispatch::class)]
|
||||
public EventDispatch $eventProvider;
|
||||
|
||||
|
||||
/**
|
||||
@@ -53,8 +44,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');
|
||||
}
|
||||
|
||||
|
||||
@@ -62,65 +53,31 @@ class ServerCommand extends Command
|
||||
* @param InputInterface $input
|
||||
* @param OutputInterface $output
|
||||
* @return int
|
||||
* @throws ConfigException
|
||||
* @throws ContainerExceptionInterface
|
||||
* @throws NotFoundExceptionInterface
|
||||
* @throws \ReflectionException
|
||||
* @throws Exception
|
||||
*/
|
||||
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 = Kiri::app()->getServer();
|
||||
$manager->setDaemon((int)!is_null($input->getOption('daemon')));
|
||||
|
||||
$action = $input->getArgument('action');
|
||||
if (is_null($action)) {
|
||||
throw new Exception('I don\'t know what I want to do.');
|
||||
}
|
||||
if (!in_array($action, self::ACTIONS)) {
|
||||
throw new Exception('I don\'t know what I want to do.');
|
||||
}
|
||||
if ($action == 'restart' || $action == 'stop') {
|
||||
$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;
|
||||
if ($action == 'stop') {
|
||||
return 1;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @throws ConfigException
|
||||
*/
|
||||
private function configure_set()
|
||||
{
|
||||
$enable_coroutine = Config::get('servers.settings.enable_coroutine', false);
|
||||
if ($enable_coroutine != true) {
|
||||
return;
|
||||
}
|
||||
Coroutine::set([
|
||||
'hook_flags' => SWOOLE_HOOK_ALL ^ SWOOLE_HOOK_BLOCKING_FUNCTION,
|
||||
'enable_deadlock_check' => FALSE,
|
||||
'exit_condition' => function () {
|
||||
return Coroutine::stats()['coroutine_num'] === 0;
|
||||
}
|
||||
]);
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param $manager
|
||||
* @throws ConfigException
|
||||
*/
|
||||
private function generate_runtime_builder($manager): void
|
||||
{
|
||||
$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']);
|
||||
$manager->start();
|
||||
return (int)$manager->start();
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
+88
-243
@@ -1,32 +1,29 @@
|
||||
<?php
|
||||
|
||||
namespace Server;
|
||||
namespace Kiri\Server;
|
||||
|
||||
use Annotation\Inject;
|
||||
use Closure;
|
||||
use Exception;
|
||||
use Kiri\Abstracts\Component;
|
||||
use Kiri\Abstracts\Config;
|
||||
use Kiri\Di\ContainerInterface;
|
||||
use Kiri\Annotation\Inject;
|
||||
use Kiri\Error\Logger;
|
||||
use Kiri\Exception\ConfigException;
|
||||
use Kiri\Kiri;
|
||||
use ReflectionException;
|
||||
|
||||
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 Kiri\Server\Contract\OnCloseInterface;
|
||||
use Kiri\Server\Contract\OnConnectInterface;
|
||||
use Kiri\Server\Contract\OnDisconnectInterface;
|
||||
use Kiri\Server\Contract\OnHandshakeInterface;
|
||||
use Kiri\Server\Contract\OnMessageInterface;
|
||||
use Kiri\Server\Contract\OnPacketInterface;
|
||||
use Kiri\Server\Contract\OnReceiveInterface;
|
||||
use Kiri\Server\Handler\OnPipeMessage;
|
||||
use Kiri\Server\Handler\OnServer;
|
||||
use Kiri\Server\Handler\OnServerManager;
|
||||
use Kiri\Server\Handler\OnServerReload;
|
||||
use Kiri\Server\Handler\OnServerWorker;
|
||||
use Kiri\Server\Tasker\OnServerTask;
|
||||
use Kiri\Websocket\WebSocketInterface;
|
||||
use Psr\Container\ContainerExceptionInterface;
|
||||
use Psr\Container\NotFoundExceptionInterface;
|
||||
use Swoole\Http\Server as HServer;
|
||||
use Swoole\Process;
|
||||
use Swoole\Server;
|
||||
@@ -38,15 +35,24 @@ use Swoole\WebSocket\Server as WServer;
|
||||
* Class OnServerManager
|
||||
* @package Http\Service
|
||||
*/
|
||||
class ServerManager
|
||||
class ServerManager extends Component
|
||||
{
|
||||
|
||||
|
||||
use TraitServer;
|
||||
|
||||
/** @var string */
|
||||
public string $host = '';
|
||||
|
||||
public int $port = 0;
|
||||
|
||||
|
||||
/**
|
||||
* @var Logger
|
||||
*/
|
||||
#[Inject(Logger::class)]
|
||||
public Logger $logger;
|
||||
|
||||
/** @var array<string,Port> */
|
||||
public array $ports = [];
|
||||
|
||||
@@ -56,11 +62,7 @@ class ServerManager
|
||||
private Server|null $server = null;
|
||||
|
||||
|
||||
/**
|
||||
* @var ContainerInterface
|
||||
*/
|
||||
#[Inject(ContainerInterface::class)]
|
||||
public ContainerInterface $container;
|
||||
protected array $initProcesses = [];
|
||||
|
||||
|
||||
const DEFAULT_EVENT = [
|
||||
@@ -78,6 +80,9 @@ class ServerManager
|
||||
];
|
||||
|
||||
|
||||
/**
|
||||
* @var array|string[]
|
||||
*/
|
||||
private array $eventInterface = [
|
||||
OnReceiveInterface::class => 'receive',
|
||||
OnPacketInterface::class => 'packet',
|
||||
@@ -104,13 +109,12 @@ class ServerManager
|
||||
* @param int $port
|
||||
* @param int $mode
|
||||
* @param array $settings
|
||||
* @throws ReflectionException
|
||||
* @throws ConfigException
|
||||
* @throws Exception
|
||||
* @throws ContainerExceptionInterface
|
||||
* @throws NotFoundExceptionInterface
|
||||
*/
|
||||
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 +127,11 @@ class ServerManager
|
||||
|
||||
|
||||
/**
|
||||
* @throws ReflectionException
|
||||
* @param $configs
|
||||
* @param int $daemon
|
||||
* @throws ConfigException
|
||||
* @throws ContainerExceptionInterface
|
||||
* @throws NotFoundExceptionInterface
|
||||
*/
|
||||
public function initBaseServer($configs, int $daemon = 0): void
|
||||
{
|
||||
@@ -132,79 +139,16 @@ 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
|
||||
* @throws Exception
|
||||
* @return array<string,Process>
|
||||
*/
|
||||
public function isRunner(): bool
|
||||
public function getProcesses(): array
|
||||
{
|
||||
$configs = Config::get('server', [], true);
|
||||
foreach ($this->sortService($configs['ports']) as $config) {
|
||||
if ($this->checkPortIsAlready($config['port'])) {
|
||||
return true;
|
||||
}
|
||||
}
|
||||
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);
|
||||
if (Kiri::getPlatform()->isLinux()) {
|
||||
$soloProcess->name($system . '.' . $name . ' start.');
|
||||
}
|
||||
$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
|
||||
);
|
||||
return $this->initProcesses;
|
||||
}
|
||||
|
||||
|
||||
@@ -217,46 +161,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 ReflectionException
|
||||
* @throws ContainerExceptionInterface
|
||||
* @throws NotFoundExceptionInterface
|
||||
* @throws Exception
|
||||
*/
|
||||
private function startListenerHandler(ServerManager $context, array $config, int $daemon = 0)
|
||||
@@ -279,13 +190,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 +207,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 +237,32 @@ 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 Exception
|
||||
*
|
||||
*
|
||||
*
|
||||
* $data = new Table($this->container->get(OutputInterface::class));
|
||||
* $data->setHeaders(['key', 'value']);
|
||||
*
|
||||
* $array = [];
|
||||
* foreach ($this->server->setting as $key => $value) {
|
||||
* $array[] = [$key, $value];
|
||||
* $array[] = new TableSeparator();
|
||||
* }
|
||||
*
|
||||
* array_pop($array);
|
||||
*
|
||||
* $data->setStyle('box-double');
|
||||
* $data->setRows($array);
|
||||
*/
|
||||
private function createBaseServer(string $type, string $host, int $port, int $mode, array $settings = [])
|
||||
{
|
||||
@@ -359,68 +275,26 @@ class ServerManager
|
||||
$this->server = new $match($host, $port, SWOOLE_PROCESS, $mode);
|
||||
$this->server->set(array_merge(Config::get('server.settings', []), $settings['settings']));
|
||||
|
||||
$this->container->setBindings(SwooleServerInterface::class, $this->server);
|
||||
|
||||
$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 ReflectionException
|
||||
* @throws Exception
|
||||
* @throws ContainerExceptionInterface
|
||||
* @throws NotFoundExceptionInterface
|
||||
*/
|
||||
private function addDefaultListener(array $settings): void
|
||||
{
|
||||
if (($this->server->setting['task_worker_num'] ?? 0) > 0) {
|
||||
$this->addTaskListener($settings['events']);
|
||||
}
|
||||
$this->container->setBindings(SwooleServerInterface::class, $this->server);
|
||||
$this->addServiceEvents(ServerManager::DEFAULT_EVENT, $this->server);
|
||||
if (!empty($settings['events']) && is_array($settings['events'])) {
|
||||
$this->addServiceEvents($settings['events'], $this->server);
|
||||
@@ -431,6 +305,8 @@ class ServerManager
|
||||
/**
|
||||
* @param array $events
|
||||
* @param Server|Port $server
|
||||
* @throws ContainerExceptionInterface
|
||||
* @throws NotFoundExceptionInterface
|
||||
*/
|
||||
private function addServiceEvents(array $events, Server|Port $server)
|
||||
{
|
||||
@@ -452,40 +328,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 +341,31 @@ class ServerManager
|
||||
|
||||
/**
|
||||
* @param array $events
|
||||
* @throws ReflectionException
|
||||
* @return void
|
||||
* @throws ContainerExceptionInterface
|
||||
* @throws NotFoundExceptionInterface
|
||||
*/
|
||||
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
|
||||
* @return void
|
||||
* @throws ContainerExceptionInterface
|
||||
* @throws NotFoundExceptionInterface
|
||||
*/
|
||||
public function bindCallback(Port|Server $server, ?array $settings = [])
|
||||
public function bindCallback(?array $settings = [])
|
||||
{
|
||||
// TODO: Implement bindCallback() method.
|
||||
if (count($settings) < 1) {
|
||||
return;
|
||||
}
|
||||
|
||||
+2
-4
@@ -1,13 +1,13 @@
|
||||
<?php
|
||||
declare(strict_types=1);
|
||||
|
||||
namespace Server;
|
||||
namespace Kiri\Server;
|
||||
|
||||
|
||||
use Exception;
|
||||
use Kiri\Abstracts\Providers;
|
||||
use Kiri\Application;
|
||||
use Kiri\Kiri;
|
||||
use Kiri;
|
||||
|
||||
/**
|
||||
* Class DatabasesProviders
|
||||
@@ -23,8 +23,6 @@ class ServerProviders extends Providers
|
||||
*/
|
||||
public function onImport(Application $application)
|
||||
{
|
||||
$application->set('server', ['class' => Server::class]);
|
||||
|
||||
$container = Kiri::getDi();
|
||||
|
||||
$console = $container->get(\Symfony\Component\Console\Application::class);
|
||||
|
||||
@@ -0,0 +1,56 @@
|
||||
<?php
|
||||
|
||||
namespace Kiri\Server;
|
||||
|
||||
use Exception;
|
||||
use Kiri\Abstracts\Component;
|
||||
use Kiri\Abstracts\Config;
|
||||
use Swoole\Process;
|
||||
|
||||
class State extends Component
|
||||
{
|
||||
|
||||
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);
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
@@ -1,6 +1,6 @@
|
||||
<?php
|
||||
|
||||
namespace Server;
|
||||
namespace Kiri\Server;
|
||||
|
||||
|
||||
use Swoole\Server;
|
||||
|
||||
@@ -0,0 +1,91 @@
|
||||
<?php
|
||||
|
||||
namespace Kiri\Server\Tasker;
|
||||
|
||||
use Exception;
|
||||
use Kiri\Abstracts\Component;
|
||||
use Kiri\Core\HashMap;
|
||||
use Kiri;
|
||||
use ReflectionException;
|
||||
use Kiri\Server\Contract\OnTaskInterface;
|
||||
use Kiri\Server\SwooleServerInterface;
|
||||
use Swoole\Server;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
class AsyncTaskExecute extends Component
|
||||
{
|
||||
|
||||
|
||||
/**
|
||||
* @var Server|\Swoole\WebSocket\Server|\Swoole\Http\Server
|
||||
*/
|
||||
public mixed $server = null;
|
||||
|
||||
|
||||
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 $workerId
|
||||
* @throws Exception
|
||||
*/
|
||||
public function execute(OnTaskInterface|string $handler, array $params = [], int $workerId = -1)
|
||||
{
|
||||
if (!$this->server) {
|
||||
$this->server = Kiri::getDi()->get(SwooleServerInterface::class);
|
||||
}
|
||||
if ($workerId < 0 || $workerId > $this->server->setting['task_worker_num']) {
|
||||
$workerId = random_int(0, $this->server->setting['task_worker_num'] - 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,13 @@
|
||||
<?php
|
||||
|
||||
|
||||
namespace Server\Handler;
|
||||
namespace Kiri\Server\Tasker;
|
||||
|
||||
|
||||
use Annotation\Inject;
|
||||
use Kiri\Annotation\Inject;
|
||||
use Kiri\Abstracts\Logger;
|
||||
use Kiri\Exception\ConfigException;
|
||||
use Kiri\Kiri;
|
||||
use ReflectionException;
|
||||
use Server\SInterface\OnTaskInterface;
|
||||
use Kiri\Server\Contract\OnTaskInterface;
|
||||
use Swoole\Server;
|
||||
|
||||
|
||||
@@ -39,7 +37,7 @@ class OnServerTask
|
||||
} catch (\Throwable $exception) {
|
||||
$data = jTraceEx($exception);
|
||||
|
||||
$this->logger->error('task', [$data]);
|
||||
$this->logger->error('task', [error_trigger_format($exception)]);
|
||||
} finally {
|
||||
$server->finish($data);
|
||||
}
|
||||
@@ -58,9 +56,9 @@ class OnServerTask
|
||||
} catch (\Throwable $exception) {
|
||||
$data = jTraceEx($exception);
|
||||
|
||||
$this->logger->error('task', [$data]);
|
||||
$this->logger->error('task', [error_trigger_format($exception)]);
|
||||
} finally {
|
||||
$server->finish($data);
|
||||
$task->finish($data);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -68,19 +66,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 Kiri\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;
|
||||
}
|
||||
|
||||
}
|
||||
+3
-4
@@ -1,7 +1,6 @@
|
||||
{
|
||||
"name": "game-worker/http-server",
|
||||
"name": "game-worker/kiri-http-server",
|
||||
"description": "http-server",
|
||||
"type": "composer-plugin",
|
||||
"license": "MIT",
|
||||
"authors": [
|
||||
{
|
||||
@@ -16,11 +15,11 @@
|
||||
"psr/http-server-middleware": "^1.0",
|
||||
"psr/http-message": "^1.0",
|
||||
"psr/event-dispatcher": "^1.0",
|
||||
"game-worker/kiri-http-message": "dev-master"
|
||||
"game-worker/kiri-http-message": "~v2.0"
|
||||
},
|
||||
"autoload": {
|
||||
"psr-4": {
|
||||
"Server\\": "./"
|
||||
"Kiri\\Server\\": "./"
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user