eee

2026-04-04 10:53:46 +08:00
parent e819fe9ba4
commit 2d4951b0dd
1 changed files with 0 additions and 38 deletions
@@ -1,38 +0,0 @@
 <?php
 namespace Kiri\Server\Handler;
 use Kiri;
 use Kiri\Server\Abstracts\Server;
 use Kiri\Server\Contract\OnPipeMessageInterface;
 /**
 *
 */
 class OnPipeMessage extends Server
 {
    /**
     * @param \Swoole\Server $server
     * @param int $src_worker_id
     * @param mixed $message
     * @throws
     */
    public function onPipeMessage(\Swoole\Server $server, int $src_worker_id, mixed $message): void
    {
        try {
            if (is_string($message)) {
                $message = unserialize($message);
            }
            if (!is_object($message) || !($message instanceof OnPipeMessageInterface)) {
                return;
            }
            call_user_func([$message, 'process'], $server, $src_worker_id);
        } catch (\Throwable $throwable) {
 			\Kiri::getLogger()->json_log($throwable, ['src_worker_id' => $src_worker_id, 'message' => $message]);
        }
    }
 }