This commit is contained in:
2021-07-23 17:17:58 +08:00
parent d1877d78a7
commit b12ebb9c7e
2 changed files with 15 additions and 1 deletions
+11 -1
View File
@@ -2,9 +2,11 @@
namespace Server\Manager; namespace Server\Manager;
use Exception;
use Server\Abstracts\Server; use Server\Abstracts\Server;
use Server\Constant; use Server\Constant;
use Server\SInterface\PipeMessage; use Server\SInterface\PipeMessage;
use Snowflake\Event;
/** /**
@@ -37,6 +39,7 @@ class ServerDefaultEvent extends Server
* @param \Swoole\Server $server * @param \Swoole\Server $server
* @param int $src_worker_id * @param int $src_worker_id
* @param mixed $message * @param mixed $message
* @throws Exception
*/ */
public function onPipeMessage(\Swoole\Server $server, int $src_worker_id, mixed $message) public function onPipeMessage(\Swoole\Server $server, int $src_worker_id, mixed $message)
{ {
@@ -46,7 +49,14 @@ class ServerDefaultEvent extends Server
if (!is_object($message) || !($message instanceof PipeMessage)) { if (!is_object($message) || !($message instanceof PipeMessage)) {
return; return;
} }
$this->runEvent(Constant::PIPE_MESSAGE, null, [$server, $src_worker_id, $message]); defer(fn() => fire(Event::SYSTEM_RESOURCE_RELEASES));
$this->runEvent(Constant::PIPE_MESSAGE,
function (\Swoole\Server $server, $src_worker_id, $message) {
call_user_func([$message, 'process']);
}, [
$server, $src_worker_id, $message
]
);
} }
+4
View File
@@ -4,6 +4,10 @@
namespace Server\SInterface; namespace Server\SInterface;
/**
* Interface PipeMessage
* @package Server\SInterface
*/
interface PipeMessage interface PipeMessage
{ {