[Optimized ]Optimized sse connect (DataLinkDC#3193)

Co-authored-by: gaoyan1998 <[email protected]>
Zzm0809 · Feb 28, 2024 · daf59c7 · daf59c7
1 parent 51b9c0c
commit daf59c7
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/dinky-admin/src/main/java/org/dinky/context/SseSessionContextHolder.java b/dinky-admin/src/main/java/org/dinky/context/SseSessionContextHolder.java
@@ -67,10 +67,8 @@ public static Set<String> subscribeTopic(String sessionId, List<String> topics)
      */
     public static SseEmitter connectSession(String sessionKey) {
         log.debug("New session wants to connect: {}", sessionKey);
-        if (exists(sessionKey)) {
-            log.warn("Session key already exists: {}", sessionKey);
-            closeSse(sessionKey);
-        }
+        log.warn("Session key already exists: {}，replace it", sessionKey);
+
         SseEmitter sseEmitter = new SseEmitter(60 * 1000L * 10);
         sseEmitter.onError(err -> onError(sessionKey, err));
         sseEmitter.onTimeout(() -> onTimeout(sessionKey));