From 500e41206b2ff32b2ea3d91cb8a09324fcf42a50 Mon Sep 17 00:00:00 2001 From: lilinxiang <970259858@qq.com> Date: Sat, 18 Oct 2025 22:04:05 +0800 Subject: [PATCH] =?UTF-8?q?update=20=E4=BC=98=E5=8C=96=20sse=20=E5=BF=83?= =?UTF-8?q?=E8=B7=B3=E5=AE=9A=E6=97=B6=E5=99=A8=E6=89=A7=E8=A1=8C=E6=96=B9?= =?UTF-8?q?=E5=BC=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/org/dromara/common/sse/core/SseEmitterManager.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/ruoyi-common/ruoyi-common-sse/src/main/java/org/dromara/common/sse/core/SseEmitterManager.java b/ruoyi-common/ruoyi-common-sse/src/main/java/org/dromara/common/sse/core/SseEmitterManager.java index e00c5930f..313f0291a 100644 --- a/ruoyi-common/ruoyi-common-sse/src/main/java/org/dromara/common/sse/core/SseEmitterManager.java +++ b/ruoyi-common/ruoyi-common-sse/src/main/java/org/dromara/common/sse/core/SseEmitterManager.java @@ -30,9 +30,9 @@ public class SseEmitterManager { private final static Map> USER_TOKEN_EMITTERS = new ConcurrentHashMap<>(); public SseEmitterManager() { - // 定时执行 SSE 心跳检测,每分钟执行一次 + // 定时执行 SSE 心跳检测 SpringUtils.getBean(ScheduledExecutorService.class) - .scheduleAtFixedRate(this::sseMonitor, 60L, 60L, TimeUnit.SECONDS); + .scheduleWithFixedDelay(this::sseMonitor, 60L, 60L, TimeUnit.SECONDS); } /**