改名

HttpServer/Events/OnPipeMessage.php

@@ -19,20 +19,19 @@ use Swoole\Server;
 class OnPipeMessage extends Callback
 {
 
-    /**
-     * @param Server $server
-     * @param int $src_worker_id
-     * @param $message
-     * @throws Exception
-     */
-    public function onHandler(Server $server, int $src_worker_id, $message)
+	/**
+	 * @param Server $server
+	 * @param int $src_worker_id
+	 * @param $swollen_universalize
+	 * @throws Exception
+	 */
+    public function onHandler(Server $server, int $src_worker_id, $swollen_universalize)
     {
         try {
-            $swollen_universalize = swoole_unserialize($message);
             match ($swollen_universalize['action'] ?? null) {
                 'kafka' => $this->onKafkaWorker($swollen_universalize),
                 'crontab' => $this->onCrontabWorker($swollen_universalize),
-                default => $this->onMessageWorker($server, $src_worker_id, $message)
+                default => $this->onMessageWorker($server, $src_worker_id, $swollen_universalize)
             };
         } catch (\Throwable $exception) {
             $this->addError($exception);

System/Crontab/Zookeeper.php

@@ -65,10 +65,9 @@ class Zookeeper extends Process
 	 */
     private function dispatch($server, Redis|\Redis $redis, int $setting, $value)
     {
-        $server->sendMessage(swoole_serialize([
+        $server->sendMessage([
             'action' => 'crontab', 'handler' => swoole_unserialize($redis->get('crontab:' . $value))
-        ]), random_int(0, $setting - 1));
-        $redis->del('crontab:' . $value);
+        ], random_int(0, $setting - 1));
     }