diff --git a/application/api/controller/Queueinfo.php b/application/api/controller/Queueinfo.php index 6144849..c007f33 100644 --- a/application/api/controller/Queueinfo.php +++ b/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 '
';var_dump($counts);
}
public function removeKey() {
@@ -99,7 +100,8 @@ echo '';var_dump($counts);
}
}
-
+ // 关闭 Redis 连接(关键步骤)
+ $redis->close();
echo '';var_dump($counts);
}
// Redis值删除
@@ -142,7 +144,8 @@ echo '';var_dump($counts);
}
echo '';var_dump($sQueueInfo,$sKey,$iNum);exit;
-
+ // 关闭 Redis 连接(关键步骤)
+ $redis->close();
}
@@ -171,36 +174,56 @@ echo '';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();
}
}