From 097145dfc60dca9d1beab1f9c4a439c9a38a67ff Mon Sep 17 00:00:00 2001 From: Ziin Date: Fri, 25 Jul 2025 20:38:41 +0800 Subject: [PATCH] =?UTF-8?q?1.=E5=A6=82=E6=9E=9CSse=E8=BF=9E=E6=8E=A5?= =?UTF-8?q?=E4=B8=8D=E5=AD=98=E5=9C=A8=E4=B8=8D=E5=8F=91=E9=80=81=E6=B6=88?= =?UTF-8?q?=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/HostInfoServiceImpl.java | 14 ++++++++++---- 1 file changed, 10 insertions(+), 4 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 3e7118c..0b7c431 100644 --- a/src/main/java/com/yupi/springbootinit/service/impl/HostInfoServiceImpl.java +++ b/src/main/java/com/yupi/springbootinit/service/impl/HostInfoServiceImpl.java @@ -18,12 +18,14 @@ import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.StopWatch; +import org.springframework.web.servlet.mvc.method.annotation.SseEmitter; import javax.annotation.Resource; import java.util.ArrayList; import java.util.List; import java.util.concurrent.CompletableFuture; + /* * @author: ziin * @date: 2025/6/10 19:04 @@ -56,10 +58,14 @@ public class HostInfoServiceImpl extends ServiceImpl i StopWatch stopWatch = new StopWatch(); stopWatch.start(); saveBatch(newHosts); - newHosts.forEach(newHost -> { - SseEmitterUtil.sendMessage(newHost.getTenantId().toString()+"-"+newHost.getUserId().toString(), - JsonUtils.toJsonString(newHost)); - }); + NewHosts sseConnectConfirmInfo = newHosts.get(0); + SseEmitter sseEmitter = SseEmitterUtil.getSseEmitter(sseConnectConfirmInfo.getTenantId().toString() + "-" + sseConnectConfirmInfo.getUserId().toString()); + if (sseEmitter != null) { + newHosts.forEach(newHost -> { + SseEmitterUtil.sendMessage(newHost.getTenantId().toString()+"-"+newHost.getUserId().toString(), + JsonUtils.toJsonString(newHost)); + }); + } stopWatch.stop(); long totalTimeMillis = stopWatch.getTotalTimeMillis(); log.info("当前存储数据量大小 {}, 存储花费: {}ms",newHosts.size(),totalTimeMillis);