文件监听

src/main/java/com/miniframe/bisiness/mdo/MDO0039Service.java

@@ -139,13 +139,14 @@ public class MDO0039Service extends MDO0039BaseModel implements ExecProcessFlow
 			DockerExe.getDockerLogs(pid,new ResultCallback.Adapter<Frame>() {
 				@Override
 				public void onNext(Frame frame) {
-					if(con[0] <100){
-						line[0]+=new String(frame.getPayload());
-					}else{
-						LogService.addLog(pid, line[0]);
-						line[0]="";
-						con[0] =0;
-					}
+//					if(con[0] <100){
+//						line[0]+=new String(frame.getPayload());
+//					}else{
+//						LogService.addLog(pid, line[0]);
+//						line[0]="";
+//						con[0] =0;
+//					}
+					LogService.addLog(pid, new String(frame.getPayload()));
 					System.out.print(new String(frame.getPayload()));
 					super.onNext(frame);
 				}

src/main/java/com/miniframe/tools/file/SurromdaoFileListener.java

@@ -61,6 +61,7 @@ public class SurromdaoFileListener extends FileAlterationListenerAdaptor {
 
                         WebsocketEndPoint webs =  (WebsocketEndPoint) UtilTools.getBean("websocketEndPoint");
                         Gson gson = new Gson();
+                        webs.sendMessageToUser(String.valueOf(pid),gson.toJson(comval));
 
                     }
                     i++;