eee

Handler/OnPipeMessage.php

@@ -2,6 +2,7 @@
 
 namespace Kiri\Server\Handler;
 
+use Kiri;
 use Kiri\Server\Abstracts\Server;
 use Kiri\Server\Contract\OnPipeMessageInterface;
 
@@ -20,6 +21,7 @@ class OnPipeMessage extends Server
      */
     public function onPipeMessage(\Swoole\Server $server, int $src_worker_id, mixed $message): void
     {
+        try {
             if (is_string($message)) {
                 $message = unserialize($message);
             }
@@ -27,6 +29,9 @@ class OnPipeMessage extends Server
                 return;
             }
             call_user_func([$message, 'process'], $server, $src_worker_id);
+        } catch (\Throwable $throwable) {
+            Kiri::getLogger()->error(throwable($throwable));
+        }
     }