浏览代码

Debug sse

tsurumure 5 月之前
父节点
当前提交
d58a01eb7c
共有 1 个文件被更改,包括 2 次插入1 次删除
  1. 2 1
      src/main/java/com/backendsys/modules/sse/controller/SseController.java

+ 2 - 1
src/main/java/com/backendsys/modules/sse/controller/SseController.java

@@ -44,7 +44,7 @@ public class SseController {
         String emitterKey = APPLICATION_NAME + "-userid-" + Convert.toStr(SecurityUtil.getUserId() + "-" + browserWindowUUID);
         String emitterKey = APPLICATION_NAME + "-userid-" + Convert.toStr(SecurityUtil.getUserId() + "-" + browserWindowUUID);
 
 
         // 如果存在,则关闭
         // 如果存在,则关闭
-        // sseUtil.closeIfExist(emitterKey);
+        sseUtil.closeIfExist(emitterKey);
 
 
 //        System.out.println("browserWindowUUID = " + browserWindowUUID);
 //        System.out.println("browserWindowUUID = " + browserWindowUUID);
 //        System.out.println("emitterKey = " + emitterKey);
 //        System.out.println("emitterKey = " + emitterKey);
@@ -63,6 +63,7 @@ public class SseController {
         } catch (IOException e) {
         } catch (IOException e) {
             // 关闭连接
             // 关闭连接
             System.out.println("(listenStream):" + e.getMessage());
             System.out.println("(listenStream):" + e.getMessage());
+        } finally {
             manager.removeEmitter(emitter);
             manager.removeEmitter(emitter);
         }
         }
         return emitter;
         return emitter;