update 优化 sse 心跳定时器执行方式

This commit is contained in:
lilinxiang 2025-10-18 22:04:05 +08:00
parent 40e13ce136
commit 500e41206b

View File

@ -30,9 +30,9 @@ public class SseEmitterManager {
private final static Map<Long, Map<String, SseEmitter>> 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);
}
/**