From 3b431b978a95680f20633e2422905ac0dd2ebd7f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=B0=8F=E8=82=A5=E7=BE=8A?= <1048382248@qq.com> Date: Fri, 6 Mar 2026 18:17:25 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=20Redis=20=E5=B0=86=20KEYS?= =?UTF-8?q?=20=E5=91=BD=E4=BB=A4=E6=9B=BF=E6=8D=A2=E4=B8=BA=E6=9B=B4?= =?UTF-8?q?=E5=AE=89=E5=85=A8=E7=9A=84=20SCAN=20=E5=91=BD=E4=BB=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- VideoAnalysisCore/Controllers/VideoTaskController.cs | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/VideoAnalysisCore/Controllers/VideoTaskController.cs b/VideoAnalysisCore/Controllers/VideoTaskController.cs index dcdaa49..d6f1202 100644 --- a/VideoAnalysisCore/Controllers/VideoTaskController.cs +++ b/VideoAnalysisCore/Controllers/VideoTaskController.cs @@ -463,7 +463,8 @@ namespace VideoAnalysisCore.Controllers public IActionResult OnlineDevices() { // 扫描 Heartbeat Key - var keys = redisManager.Redis.Keys(RedisExpandKey.DeviceHeartbeat("*")); + var pattern = RedisExpandKey.DeviceHeartbeat("*"); + var keys = redisManager.Redis.Scan(pattern, 1000).ToList(); var prefix = RedisExpandKey.DeviceHeartbeat(""); var devices = keys.Select(k => k.Replace(prefix, "")).ToList(); return Ok(devices); @@ -488,7 +489,8 @@ namespace VideoAnalysisCore.Controllers // 获取所有在线节点 oldTaskArr = new List(); // 直接扫描 Heartbeat Key 获取在线设备 - var keys = redisManager.Redis.Keys(RedisExpandKey.DeviceHeartbeat("*")); + var pattern = RedisExpandKey.DeviceHeartbeat("*"); + var keys = redisManager.Redis.Scan(pattern, 1000).ToList(); var prefix = RedisExpandKey.DeviceHeartbeat(""); var onlineDevices = keys.Select(k => k.Replace(prefix, "")).ToList();