diff --git a/HttpServer/Events/OnPipeMessage.php b/HttpServer/Events/OnPipeMessage.php index 98b4544b..1629335b 100644 --- a/HttpServer/Events/OnPipeMessage.php +++ b/HttpServer/Events/OnPipeMessage.php @@ -47,7 +47,7 @@ class OnPipeMessage extends Callback throw new Exception('unknown handler'); } /** @var Crontab $handler */ - $handler = swoole_unserialize($message['handler']); + $handler = $message['handler']; defer(function () use ($handler) { if ($handler->isRecover() !== 999) { return; diff --git a/System/Crontab/Zookeeper.php b/System/Crontab/Zookeeper.php index 6b774ec9..d626f0b1 100644 --- a/System/Crontab/Zookeeper.php +++ b/System/Crontab/Zookeeper.php @@ -86,7 +86,7 @@ class Zookeeper extends Process if (empty($handler = $redis->get('crontab:' . $value))) { return; } - $params['handler'] = $handler; + $params['handler'] = swoole_unserialize($handler); $this->server->sendMessage($params, $this->getWorker()); } catch (Throwable $exception) {