Debug emitter close

src/main/java/com/backendsys/modules/log/controller/LogStreamController.java

@@ -66,29 +66,23 @@ public class LogStreamController {
 
             new Thread(() -> {
                 try {
-
                     // Window 使用 GBK 字符
                     Process process = Runtime.getRuntime().exec(exec);  // "ping 127.0.0.1" | "docker logs -f backendsys";
                     BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream(), charset));
                     String line;
                     while ((line = reader.readLine()) != null) {
-                        // 将日志发送到客户端
-                        // System.out.println(line);
-                        // log.info(line);
                         emitter.send(SseEmitter.event().data(line));
                     }
-
-//                    // 完成后关闭连接
-//                    emitter.complete();
-
+                    // emitter.complete();  // 完成后关闭连接
                 } catch (IOException e) {
-                    emitter.completeWithError(e);
+                    System.out.println(e.getMessage());
+                    // 不关闭，一直监听
+                    // emitter.completeWithError(e);
                 }
             }).start();
 
         } catch (IOException e) {
-            // 关闭连接
-            // emitter.complete();
+            // emitter.complete();  // 关闭连接
             manager.emitters.remove(emitter);
         }
         return emitter;