From 85d62459a6ba6fed1e478caabd616ac518572c0e Mon Sep 17 00:00:00 2001 From: Ziin Date: Wed, 27 Aug 2025 21:27:16 +0800 Subject: [PATCH] =?UTF-8?q?1.=E4=BF=AE=E6=94=B9=E5=88=A4=E6=96=AD=E5=8F=91?= =?UTF-8?q?=E9=80=81AI=E6=B6=88=E6=81=AF=E9=98=9F=E5=88=97=E9=80=BB?= =?UTF-8?q?=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../springbootinit/service/impl/HostInfoServiceImpl.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/yupi/springbootinit/service/impl/HostInfoServiceImpl.java b/src/main/java/com/yupi/springbootinit/service/impl/HostInfoServiceImpl.java index 8f02de6..3dd990f 100644 --- a/src/main/java/com/yupi/springbootinit/service/impl/HostInfoServiceImpl.java +++ b/src/main/java/com/yupi/springbootinit/service/impl/HostInfoServiceImpl.java @@ -19,6 +19,7 @@ import org.springframework.web.servlet.mvc.method.annotation.SseEmitter; import javax.annotation.Resource; import java.util.List; +import java.util.Set; import java.util.concurrent.CompletableFuture; @@ -70,8 +71,9 @@ public class HostInfoServiceImpl extends ServiceImpl i }); } - Boolean o = (Boolean) redisTemplate.opsForValue().get("ai_login:"+newHosts.get(0).getTenantId()); - if (Boolean.TRUE.equals(o)) { +// Boolean o = (Boolean) redisTemplate.opsForValue().get("ai_login:"+newHosts.get(0).getTenantId()); + Set keys = redisTemplate.keys("ai_login:"+newHosts.get(0).getTenantId()+":*"); + if (!keys.isEmpty()) { newHosts.forEach(newHost -> { mqSender.send(newHost.getTenantId(),newHost); });