Mure 6 сар өмнө
parent
commit
cb592243e4

+ 1 - 2
src/main/java/com/backendsys/modules/sse/utils/SseUtil.java

@@ -19,8 +19,6 @@ public class SseUtil {
     @Value("${spring.application.name}")
     private String APPLICATION_NAME;
 
-    private Long user_id = SecurityUtil.getUserId();
-
     // [SSE] 发送消息 (单个)
     public void send(String emitterKey, Object data) {
         SseEmitterManager manager = SseEmitterManager.getInstance();
@@ -37,6 +35,7 @@ public class SseUtil {
 
     // [SSE] 发送消息 (单个) (自己)
     public void send(Object data) {
+        Long user_id = SecurityUtil.getUserId();
         SseEmitterManager manager = SseEmitterManager.getInstance();
         SseEmitterUTF8 emitter = manager.getEmitter(APPLICATION_NAME + "-userid-" + Convert.toStr(user_id));
         if (emitter != null) {