优化redis重复连接的问题

demo/controllers/ApiController.php

@@ -50,8 +50,8 @@ public function actionGetUsers()
     public function actionTask()
     {
         //Task::pushTask("var_dump", [time()]);
-        //Task::pushTask("time");
-        Task::pushTask('sleep', [10]);
+        Task::pushTask("time");
+        //Task::pushTask('sleep', [10]);
         return time();
     }
 }

src/Container.php

@@ -27,6 +27,7 @@ class Container extends \yii\di\Container
         'yii\log\FileTarget' => 'tourze\workerman\yii2\log\FileTarget',
         'yii\log\Logger' => 'tourze\workerman\yii2\log\Logger',
         'yii\swiftmailer\Mailer' => 'tourze\workerman\yii2\mailer\SwiftMailer',
+        'yii\redis\Connection' => 'tourze\workerman\yii2\redis\Connection',
         'yii\web\Request' => 'tourze\workerman\yii2\web\Request',
         'yii\web\Response' => 'tourze\workerman\yii2\web\Response',
         'yii\web\Session' => 'tourze\workerman\yii2\web\Session',
@@ -166,6 +167,7 @@ class Container extends \yii\di\Container
         'yii\rbac\Role',
         'yii\redis\Cache',
         'yii\redis\Connection',
+        'tourze\workerman\yii2\redis\Connection',
         'yii\redis\LuaScriptBuilder',
         'yii\redis\Session',
         'yii\rest\Serializer',

src/async/Task.php

@@ -23,12 +23,21 @@ class Task
      */
     public static $taskCountKey = 'task_count';
 
+    /**
+     * @var Connection
+     */
+    public static $redis;
+
     /**
      * @return Connection
      */
     public static function getRedis()
     {
-        return Yii::$app->get('redis');
+        if ( ! self::$redis)
+        {
+            self::$redis = Yii::$app->get('redis');
+        }
+        return self::$redis;
     }
 
     /**

src/redis/Connection.php

@@ -0,0 +1,36 @@
+<?php
+
+namespace tourze\workerman\yii2\redis;
+
+class Connection extends \yii\redis\Connection
+{
+
+    /**
+     * @inheritdoc
+     */
+    public function open()
+    {
+        // 链接还生效的话，就不重连了
+        if ($this->getIsActive())
+        {
+            return;
+        }
+        parent::open();
+    }
+
+    /**
+     * @inheritdoc
+     */
+    public function close()
+    {
+        // 不主动关闭redis连接
+    }
+
+    /**
+     * 真实关闭链接
+     */
+    public function realClose()
+    {
+        parent::close();
+    }
+}