#98 新增支持 Redis 哨兵模式、集群模式 cache、lock、queue、rate-limit 改造兼容

Author: Yurunsoft

src/Driver/RedisQueueDriver.php

@@ -630,7 +630,17 @@ protected function parseTimeoutMessages(int $count = 100)
      */
     public function getMessageKeyPrefix(): string
     {
-        return $this->prefix . $this->name . ':message:';
+        $redis = RedisManager::getInstance($this->poolName);
+        if ($redis->isCluster())
+        {
+            $name = '{' . $this->name . '}';
+        }
+        else
+        {
+            $name = $this->name;
+        }
+
+        return $this->prefix . $name . ':message:';
     }
 
     /**
@@ -640,7 +650,17 @@ public function getMessageKeyPrefix(): string
      */
     public function getMessageIdKey(): string
     {
-        return $this->prefix . $this->name . ':message:id';
+        $redis = RedisManager::getInstance($this->poolName);
+        if ($redis->isCluster())
+        {
+            $name = '{' . $this->name . '}';
+        }
+        else
+        {
+            $name = $this->name;
+        }
+
+        return $this->prefix . $name . ':message:id';
     }
 
     /**
@@ -652,6 +672,16 @@ public function getMessageIdKey(): string
      */
     public function getQueueKey(int $queueType): string
     {
-        return $this->prefix . $this->name . ':' . strtolower(QueueType::getName($queueType));
+        $redis = RedisManager::getInstance($this->poolName);
+        if ($redis->isCluster())
+        {
+            $name = '{' . $this->name . '}';
+        }
+        else
+        {
+            $name = $this->name;
+        }
+
+        return $this->prefix . $name . ':' . strtolower(QueueType::getName($queueType));
     }
 }