优化cos

src/main/java/com/backendsys/modules/sdk/tencent/cos/service/TencentCosService.java

@@ -1,6 +1,5 @@
 package com.backendsys.modules.sdk.tencent.cos.service;
 
-import com.backendsys.entity.Tencent.TencentCos.MultipartUploadRespDTO;
 import com.qcloud.cos.model.UploadResult;
 import org.springframework.web.multipart.MultipartFile;
 

src/main/java/com/backendsys/modules/sse/utils/SseUtil.java

@@ -25,7 +25,7 @@ public class SseUtil {
         }
     }
 
-    // 如果存在，则关闭
+    // 如果存在，则关闭 (此操作会完全关闭未连接的监听)
     public void closeIfExist(String userId) {
         // 如果用户ID已经存在对应的连接，则关闭旧的连接
         SseEmitterManager manager = SseEmitterManager.getInstance();

src/main/java/com/backendsys/modules/upload/controller/SysUploadController.java

@@ -42,7 +42,7 @@ public class SysUploadController {
     }
 
     /**
-     * [SSE] 消息监听 (上传进度)
+     * [SSE] 上传进度监听
      */
     @GetMapping(value = "/api/sse/stream/upload", produces = "text/event-stream;charset=UTF-8")
     public SseEmitter streamUpload() {
@@ -56,10 +56,7 @@ public class SysUploadController {
             emitter.send(SseEmitter.event().data("Connected successfully! (连接成功)"));
         } catch (IOException e) {
             // 关闭连接
-            // emitter.complete();
             manager.emitters.remove(emitter);
-            // 如果存在，则关闭
-            sseUtil.closeIfExist(userId);
         }
         return emitter;
     }