From faff485006584ebb22f54c68bc8587f7a3b5bd38 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=90=91=E6=9E=97?= <as2252258@163.com>
Date: Fri, 27 Dec 2024 17:59:52 +0800
Subject: [PATCH] eee

---
 Handler/OnPipeMessage.php | 17 +++++++++++------
 1 file changed, 11 insertions(+), 6 deletions(-)

diff --git a/Handler/OnPipeMessage.php b/Handler/OnPipeMessage.php
index aa606e0..dc1fcc3 100644
--- a/Handler/OnPipeMessage.php
+++ b/Handler/OnPipeMessage.php
@@ -2,6 +2,7 @@
 
 namespace Kiri\Server\Handler;
 
+use Kiri;
 use Kiri\Server\Abstracts\Server;
 use Kiri\Server\Contract\OnPipeMessageInterface;
 
@@ -20,13 +21,17 @@ class OnPipeMessage extends Server
      */
     public function onPipeMessage(\Swoole\Server $server, int $src_worker_id, mixed $message): void
     {
-        if (is_string($message)) {
-            $message = unserialize($message);
+        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()->error(throwable($throwable));
         }
-        if (!is_object($message) || !($message instanceof OnPipeMessageInterface)) {
-            return;
-        }
-        call_user_func([$message, 'process'], $server, $src_worker_id);
     }