[agent][executor]- bug - 11

agent/src/main/java/io/wdd/agent/executor/thread/CommandExecLogCache.java

@@ -34,15 +34,15 @@ public class CommandExecLogCache {
      */
     private static final ArrayList<String> EmptyCommandLog = new ArrayList<>();
     // 存储命令执行缓存日志
-    private static HashMap<String, ArrayList<String>> CachedCommandLogMap = new HashMap<>();
+    private static final HashMap<String, ArrayList<String>> CachedCommandLogMap = new HashMap<>();
     /**
      * 存储每一个任务对应的 日志读取BufferedReader
      */
-    private static HashMap<String, BufferedReader> CommandLogBufferedReaderMap = new HashMap<>();
+    private static final HashMap<String, BufferedReader> CommandLogBufferedReaderMap = new HashMap<>();
     /**
      * 存储每一个任务对应的 日志读取 InputStream Reader
      */
-    private static HashMap<String, InputStreamReader> CommandLogInputReaderMap = new HashMap<>();
+    private static final HashMap<String, InputStreamReader> CommandLogInputReaderMap = new HashMap<>();
 
     @Resource
     SimpleStreamSender simpleStreamSender;
@@ -132,8 +132,10 @@ public class CommandExecLogCache {
                 streamKey,
                 bufferedReader
         );
-        CommandLogInputReaderMap.put(streamKey,
+        CommandLogInputReaderMap.put(
-                                     inputStreamReader);
+                streamKey,
+                inputStreamReader
+        );
 
         log.debug("开始获取bufferedReader中每一行的内容");
         // !! 此处会阻塞
@@ -167,21 +169,24 @@ public class CommandExecLogCache {
                 inputStreamReader
         );
 
-
         try {
+            // 关闭command的输出流
+            process
+                    .getInputStream()
+                    .close();
 
-                // 关闭command的输出流
+            inputStreamReader.close();
-                process
-                        .getInputStream()
-                        .close();
 
-                inputStreamReader.close();
+            bufferedReader.close();
 
-                bufferedReader.close();
+        } catch (IOException e) {
+            throw new RuntimeException(e);
+        } finally {
 
-            } catch (IOException e) {
+            CommandLogBufferedReaderMap.remove(streamKey);
-                throw new RuntimeException(e);
+            CommandLogInputReaderMap.remove(streamKey);
-            }
+
+        }
 
 
     }
@@ -203,8 +208,7 @@ public class CommandExecLogCache {
                     .writerWithDefaultPrettyPrinter()
                     .writeValueAsString(cachedCommandLog);
 
-            System.out.println("s = " + s);
+            System.out.println(s);
-
 
         } catch (JsonProcessingException e) {
             throw new RuntimeException(e);