|
|
|
@ -39,7 +39,7 @@ public class SseEmitterManager {
|
|
|
|
Map<String, SseEmitter> emitters = USER_TOKEN_EMITTERS.computeIfAbsent(userId, k -> new ConcurrentHashMap<>());
|
|
|
|
Map<String, SseEmitter> emitters = USER_TOKEN_EMITTERS.computeIfAbsent(userId, k -> new ConcurrentHashMap<>());
|
|
|
|
|
|
|
|
|
|
|
|
// 创建一个新的 SseEmitter 实例,超时时间设置为 0 表示无限制
|
|
|
|
// 创建一个新的 SseEmitter 实例,超时时间设置为 0 表示无限制
|
|
|
|
SseEmitter emitter = new SseEmitter(0L);
|
|
|
|
SseEmitter emitter = new SseEmitter(86400L);
|
|
|
|
|
|
|
|
|
|
|
|
emitters.put(token, emitter);
|
|
|
|
emitters.put(token, emitter);
|
|
|
|
|
|
|
|
|
|
|
|
|