Support prefix

Author: krissss

src/Redis.php

@@ -50,7 +50,7 @@ protected static function connect($config)
         if (!extension_loaded('redis')) {
             throw new \RuntimeException('Please make sure the PHP Redis extension is installed and enabled.');
         }
-        
+
         $redis = new RedisConnection();
         $address = $config['host'];
         $config = [
@@ -60,6 +60,7 @@ protected static function connect($config)
             'auth' => $config['options']['auth'] ?? '',
             'timeout' => $config['options']['timeout'] ?? 2,
             'ping' => $config['options']['ping'] ?? 55,
+            'prefix' => $config['options']['prefix'] ?? '',
         ];
         $redis->connectWithConfig($config);
         return $redis;

src/RedisConnection.php

@@ -19,7 +19,7 @@
 class RedisConnection extends \Redis
 {
     /**
-     * @var array 
+     * @var array
      */
     protected $config = [];
 
@@ -42,6 +42,9 @@ public function connectWithConfig(array $config = [])
         if (!empty($this->config['db'])) {
             $this->select($this->config['db']);
         }
+        if (!empty($this->config['prefix'])) {
+            $this->setOption(\Redis::OPT_PREFIX, $this->config['prefix']);
+        }
         if (Worker::getAllWorkers() && !$timer) {
             $timer = Timer::add($this->config['ping'] ?? 55, function ()  {
                 $this->execCommand('ping');

src/config/plugin/webman/redis-queue/redis.php

@@ -5,6 +5,7 @@
         'options' => [
             'auth' => null,       // 密码，字符串类型，可选参数
             'db' => 0,            // 数据库
+            'prefix' => '',       // key 前缀
             'max_attempts'  => 5, // 消费失败后，重试次数
             'retry_seconds' => 5, // 重试间隔，单位秒
         ]