优化publish

workbunny · Apr 9, 2024 · f4caedc · f4caedc
1 parent f714bcd
commit f4caedc
Showing 1 changed file with 13 additions and 7 deletions.
diff --git a/src/Server.php b/src/Server.php
@@ -230,17 +230,23 @@ public function publish(array $data)
      */
     public function publishToClients(string $appKey, string $channel, string $event, $data, ?string $socketId = null)
     {
-        $timerId = Timer::add(0.1, function () use (
-            &$timerId, $appKey, $channel, $event, $data, $socketId
-        ) {
+        try {
             $res = ChannelClient::publish(self::PRIVATE_CHANNEL_PUBLISH_TO_CLIENT, [
                 $appKey, $channel, $event, $data, $socketId
             ]);
-            if ($res !== false) {
-                Timer::del($timerId);
+            if ($res === false) {
+                $timerId = Timer::add(0.1, function () use (
+                    &$timerId, $appKey, $channel, $event, $data, $socketId
+                ) {
+                    $res = ChannelClient::publish(self::PRIVATE_CHANNEL_PUBLISH_TO_CLIENT, [
+                        $appKey, $channel, $event, $data, $socketId
+                    ]);
+                    if ($res !== false) {
+                        Timer::del($timerId);
+                    }
+                });
             }
-        });
-
+        } catch (\Throwable $throwable) {}
     }
 
     /**