[12.x] Redis cluster broadcaster (#56581)

vadimonus · taylorotwell · web-flow · commit 9bb82f7c1009 · 2025-08-08T09:46:15.000-05:00
* [12.x] RedisBroadcaster for RedisCuster

* formatting

---------

Co-authored-by: Taylor Otwell &lt;taylor@laravel.com&gt;
diff --git a/src/Illuminate/Broadcasting/Broadcasters/RedisBroadcaster.php b/src/Illuminate/Broadcasting/Broadcasters/RedisBroadcaster.php
@@ -4,7 +4,11 @@
 
 use Illuminate\Broadcasting\BroadcastException;
 use Illuminate\Contracts\Redis\Factory as Redis;
+use Illuminate\Redis\Connections\PhpRedisClusterConnection;
+use Illuminate\Redis\Connections\PredisClusterConnection;
+use Illuminate\Redis\Connections\PredisConnection;
 use Illuminate\Support\Arr;
+use Predis\Connection\Cluster\RedisCluster;
 use Predis\Connection\ConnectionException;
 use RedisException;
 use Symfony\Component\HttpKernel\Exception\AccessDeniedHttpException;
@@ -125,10 +129,30 @@ public function broadcast(array $channels, $event, array $payload = [])
         ]);
 
         try {
-            $connection->eval(
-                $this->broadcastMultipleChannelsScript(),
-                0, $payload, ...$this->formatChannels($channels)
-            );
+            if ($connection instanceof PhpRedisClusterConnection) {
+                foreach ($channels as $channel) {
+                    $connection->publish($channel, $payload);
+                }
+            } elseif ($connection instanceof PredisClusterConnection &&
+                $connection->client()->getConnection() instanceof RedisCluster) {
+                $randomClusterNodeConnection = new PredisConnection(
+                    $connection->client()->getClientBy('slot', mt_rand(0, 16383))
+                );
+
+                if ($events = $connection->getEventDispatcher()) {
+                    $randomClusterNodeConnection->setEventDispatcher($events);
+                }
+
+                $randomClusterNodeConnection->eval(
+                    $this->broadcastMultipleChannelsScript(),
+                    0, $payload, ...$this->formatChannels($channels)
+                );
+            } else {
+                $connection->eval(
+                    $this->broadcastMultipleChannelsScript(),
+                    0, $payload, ...$this->formatChannels($channels)
+                );
+            }
         } catch (ConnectionException|RedisException $e) {
             throw new BroadcastException(
                 sprintf('Redis error: %s.', $e->getMessage())
