Support docker cluster

Author: tai1030

publish/redis.php

@@ -15,6 +15,7 @@
         'host' => env('REDIS_HOST', 'localhost'),
         'auth' => env('REDIS_AUTH', null),
         'port' => (int) env('REDIS_PORT', 6379),
+        'cluster' => env('REDIS_CLUSTER', false),
         'db' => (int) env('REDIS_DB', 0),
         'timeout' => 0.0,
         'reserved' => null,

src/RedisConnection.php

@@ -32,6 +32,7 @@ class RedisConnection extends BaseConnection implements ConnectionInterface
         'host' => 'localhost',
         'port' => 6379,
         'auth' => null,
+        'cluster' => false,
         'db' => 0,
         'timeout' => 0.0,
         'options' => [],
@@ -74,12 +75,24 @@ public function reconnect(): bool
         $host = $this->config['host'];
         $port = $this->config['port'];
         $auth = $this->config['auth'];
+        $cluster = $this->config['cluster'];
         $db = $this->config['db'];
         $timeout = $this->config['timeout'];
 
-        $redis = new \Redis();
-        if (! $redis->connect($host, $port, $timeout)) {
-            throw new ConnectionException('Connection reconnect failed.');
+        $redis = null;
+        if ($cluster !== true) {
+            // Normal Redis (Non-cluster)
+            $redis = new \Redis();
+            if (! $redis->connect($host, $port, $timeout)) {
+                throw new ConnectionException('Connection reconnect failed.');
+            }
+        } else {
+            // Redis Cluster 
+            try {
+                $redis = new \RedisCluster(null, [$host . ':' . $port], $timeout);
+            } catch (\Throwable $e) {
+                throw new ConnectionException('Connection reconnect failed. ' . $e->getMessage());
+            }
         }
 
         $options = $this->config['options'] ?? [];