查看队列

application/api/controller/Queueinfo.php

@@ -33,7 +33,7 @@ class Queueinfo extends Base
         $redis->select($config['select']);
         
         // 获取不同队列类型的任务数
-        $aQueue = empty($aParam['queue_name']) ? ['ArticleAiCreateContent','RecommendReviewer','RelatedArticle','ReviewerScore','RevisionReviewer','SendRelatedArticleEmail','SendReviewEmail','WechatDraft','WechatDraftPublish','WechatMaterial','WechatQueryStatus'] : [$aParam['queue_name']];
+        $aQueue = empty($aParam['queue_name']) ? ['ArticleAiCreateContent','RecommendReviewer','RelatedArticle','ReviewerScore','RevisionReviewer','SendRelatedArticleEmail','SendReviewEmail','WechatDraft','WechatDraftPublish','WechatMaterial','WechatQueryStatus','createFieldForQueue','RecommendArticleField'] : [$aParam['queue_name']];
         foreach ($aQueue as $key => $value) {
             $types[$value] = [
                 'pending'  => 'queues:'.$value,
@@ -53,7 +53,8 @@ class Queueinfo extends Base
             } 
             
         }
-
+        // 关闭 Redis 连接（关键步骤）
+        $redis->close();
 echo '<pre>';var_dump($counts);
     }
     public function removeKey() {
@@ -99,7 +100,8 @@ echo '<pre>';var_dump($counts);
             } 
             
         }
-
+    // 关闭 Redis 连接（关键步骤）
+        $redis->close();
 echo '<pre>';var_dump($counts);
     }
     // Redis值删除
@@ -142,7 +144,8 @@ echo '<pre>';var_dump($counts);
         }
 
 echo '<pre>';var_dump($sQueueInfo,$sKey,$iNum);exit;
-
+        // 关闭 Redis 连接（关键步骤）
+        $redis->close();
     }
 
 
@@ -171,36 +174,56 @@ echo '<pre>';var_dump($sQueueInfo,$sKey,$iNum);exit;
 
         $sKey = $redis->get($aParam['key_name']);
         var_dump($sKey);
+        // 关闭 Redis 连接（关键步骤）
+        $redis->close();
     }
 
     public function removeKey1(){
 
+        // 获取请求参数
         $aParam = $this->request->post();
-        if(empty($aParam['key_name'])){
+        if (empty($aParam['key_name'])) {
             exit('非法操作');
         }
 
+        // 获取队列配置（Redis 配置）
         $config = \think\Config::get('queue');
 
+        // 队列名称默认值处理
         $sQueueName = empty($aParam['queue_name']) ? 'ArticleAiCreateContent' : $aParam['queue_name'];
+
+        // 初始化 Redis 连接
         $redis = new \Redis();
+        // 连接 Redis 服务器
         $redis->connect($config['host'], $config['port']);
-        
+
+        // 若有密码则认证
         if (!empty($config['password'])) {
             $redis->auth($config['password']);
         }
-        
+
+        // 选择数据库（默认 0）
         $redis->select($config['select']);
 
-        $sKey = $redis->hGetAll($aParam['key_name']);
+        // 操作示例：获取哈希表数据
         echo '我是HgetAll';
+        $sKey = $redis->hGetAll($aParam['key_name']);
         var_dump($sKey);
+
+        // 删除哈希表
         $result = $redis->del($aParam['key_name']);
         var_dump($result);
+
+        // 尝试获取字符串类型的键（验证是否删除）
         echo '我是get';
         $sKey = $redis->get($aParam['key_name']);
         var_dump($sKey);
+
+        // 再次删除（确保删除）
         $result = $redis->del($aParam['key_name']);
         var_dump($result);
+
+        // 关闭 Redis 连接（关键步骤）
+        $redis->close();
     }
 }