chat

src/main/java/com/sxtvs/open/api/review/service/impl/SSEService.java

@@ -4,6 +4,7 @@ import com.sxtvs.open.core.advice.BizException;
 import com.sxtvs.open.core.auth.AESUtil;
 import com.sxtvs.open.core.auth.HttpContextUtil;
 import jakarta.annotation.Resource;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.http.util.TextUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
@@ -16,6 +17,7 @@ import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ThreadPoolExecutor;
 
 @Service
+@Slf4j
 public class SSEService {
 
     private Map<Long, SseEmitter>  sseMap = new ConcurrentHashMap<>();
@@ -68,6 +70,7 @@ public class SSEService {
         if (sseDataMap.containsKey(gid)){
             SseEmitter sseEmitter = sseDataMap.get(gid);
             sseEmitter.complete();
+            log.info("关闭连接");
             sseDataMap.remove(gid);
         }
     }