1

Abstracts/BaseProcess.php

@@ -80,64 +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
-	{
-	}
-
-
-	/**
-	 *
-	 */
-	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->enable_coroutine) {
-			Coroutine::sleep(0.1);
-		} else {
-			usleep(100);
-		}
-	}
-
 }

Contract/OnDownloadInterface.php

@@ -1,12 +0,0 @@
-<?php
-
-namespace Server\Contract;
-
-use Swoole\Http\Response;
-
-interface OnDownloadInterface
-{
-
-	public function dispatch(Response $response);
-
-}

Contract/OnProcessInterface.php

@@ -17,27 +17,9 @@ interface OnProcessInterface
 
 	/**
 	 * @param Process $process
-	 * @return string
 	 */
-	public function getProcessName(Process $process): string;
+	public function process(Process $process): void;
 
 
-	/**
-	 * @param Process $process
-	 */
-	public function signListen(Process $process): void;
-
-
-	/**
-	 * @param Process $process
-	 */
-	public function onHandler(Process $process): void;
-
-
-	/**
-	 *
-	 */
-	public function onProcessStop(): void;
-
 
 }

Events/OnServerBeforeStart.php

@@ -0,0 +1,8 @@
+<?php
+
+namespace Server\Events;
+
+class OnServerBeforeStart
+{
+
+}

Handler/OnServerWorker.php

@@ -8,7 +8,6 @@ use Kiri\Abstracts\Config;
 use Kiri\Core\Help;
 use Kiri\Events\EventDispatch;
 use Kiri\Kiri;
-use Kiri\Runtime;
 use Server\Events\OnAfterWorkerStart;
 use Server\Events\OnBeforeWorkerStart;
 use Server\Events\OnTaskerStart as OnTaskStart;
@@ -16,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;
 

Server.php

@@ -8,7 +8,6 @@ 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 Server\Events\OnShutdown;

ServerCommand.php

@@ -7,9 +7,10 @@ namespace Server;
 use Annotation\Inject;
 use Exception;
 use Kiri\Abstracts\Config;
-use Kiri\Events\EventProvider;
+use Kiri\Events\EventDispatch;
 use Kiri\Exception\ConfigException;
 use Kiri\Kiri;
+use Server\Events\OnServerBeforeStart;
 use Swoole\Coroutine;
 use Symfony\Component\Console\Command\Command;
 use Symfony\Component\Console\Input\InputArgument;
@@ -29,10 +30,10 @@ class ServerCommand extends Command
 
 
 	/**
-	 * @var EventProvider
+	 * @var EventDispatch
 	 */
-	#[Inject(EventProvider::class)]
-	public EventProvider $eventProvider;
+	#[Inject(EventDispatch::class)]
+	public EventDispatch $eventProvider;
 
 
 	/**
@@ -68,7 +69,7 @@ class ServerCommand extends Command
 		}
 		$manager->shutdown();
 		if ($input->getArgument('action') == 'stop') {
-			throw new Exception('shutdown success');
+			return 0;
 		}
 		return $this->generate_runtime_builder($manager);
 	}
@@ -105,6 +106,8 @@ class ServerCommand extends Command
 
 		Kiri::app()->getRouter()->read_files();
 
+		$this->eventProvider->dispatch(new OnServerBeforeStart());
+
 		$manager->start();
 
 		return 1;

ServerManager.php

@@ -3,21 +3,16 @@
 namespace Server;
 
 use Annotation\Inject;
-use Closure;
 use Exception;
 use Kiri\Abstracts\Config;
-use Kiri\Di\ContainerInterface;
+use Psr\Container\ContainerInterface;
 use Kiri\Error\Logger;
 use Kiri\Exception\ConfigException;
 use Kiri\Kiri;
+use Psr\Container\ContainerExceptionInterface;
+use Psr\Container\NotFoundExceptionInterface;
 use ReflectionException;
 use Server\Abstracts\BaseProcess;
-use Server\Handler\OnPipeMessage;
-use Server\Handler\OnServer;
-use Server\Handler\OnServerManager;
-use Server\Handler\OnServerReload;
-use Server\Handler\OnServerTask;
-use Server\Handler\OnServerWorker;
 use Server\Contract\OnCloseInterface;
 use Server\Contract\OnConnectInterface;
 use Server\Contract\OnDisconnectInterface;
@@ -27,6 +22,12 @@ use Server\Contract\OnPacketInterface;
 use Server\Contract\OnProcessInterface;
 use Server\Contract\OnReceiveInterface;
 use Server\Contract\OnTaskInterface;
+use Server\Handler\OnPipeMessage;
+use Server\Handler\OnServer;
+use Server\Handler\OnServerManager;
+use Server\Handler\OnServerReload;
+use Server\Handler\OnServerTask;
+use Server\Handler\OnServerWorker;
 use Swoole\Http\Server as HServer;
 use Swoole\Process;
 use Swoole\Server;
@@ -168,19 +169,14 @@ class ServerManager
 		if (is_string($customProcess)) {
 			$customProcess = Kiri::getDi()->get($customProcess);
 		}
-		$process = new Process(function (Process $soloProcess) use ($customProcess) {
-			$system = sprintf('[%s].process', Config::get('id', 'system-service'));
+		$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 . '(' . $customProcess->getName() . ')');
+				$process->name($system . '(' . $customProcess->getName() . ')');
 			}
-			$this->logger->debug($system . $customProcess->getName() . ' start.');
-			$customProcess->signListen($soloProcess);
-			$customProcess->onHandler($soloProcess);
-		},
-			$customProcess->getRedirectStdinAndStdout(),
-			$customProcess->getPipeType(),
-			$customProcess->isEnableCoroutine()
-		);
+			$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);
 	}
@@ -238,6 +234,7 @@ class ServerManager
 			$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;
 	}
@@ -339,10 +336,12 @@ class ServerManager
 	}
 
 
-	/**
-	 * @param array $events
-	 * @param Server|Port $server
-	 */
+    /**
+     * @param array $events
+     * @param Server|Port $server
+     * @throws ContainerExceptionInterface
+     * @throws NotFoundExceptionInterface
+     */
 	private function addServiceEvents(array $events, Server|Port $server)
 	{
 		foreach ($events as $name => $event) {