Merge branch 'monitor-socket' of https://github.com/roman-yepishev-enoc/zkui into roman-yepishev-enoc-monitor-socket

Author: gitorko

src/main/java/com/deem/zkui/controller/Monitor.java

@@ -58,7 +58,7 @@ protected void doGet(HttpServletRequest request, HttpServletResponse response) t
             templateParam.put("stats", stats);
             ServletUtil.INSTANCE.renderHtml(request, response, templateParam, "monitor.ftl.html");
 
-        } catch (IOException | InterruptedException | TemplateException ex) {
+        } catch (IOException | TemplateException ex) {
             logger.error(Arrays.toString(ex.getStackTrace()));
             ServletUtil.INSTANCE.renderError(request, response, ex.getMessage());
         }

src/main/java/com/deem/zkui/utils/CmdUtil.java

@@ -17,9 +17,11 @@
  */
 package com.deem.zkui.utils;
 
+import java.net.Socket;
 import java.io.BufferedReader;
 import java.io.IOException;
 import java.io.InputStreamReader;
+import java.io.PrintWriter;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -28,18 +30,21 @@ public enum CmdUtil {
     INSTANCE;
     private final static Logger logger = LoggerFactory.getLogger(CmdUtil.class);
 
-    public String executeCmd(String cmd, String zkServer, String zkPort) throws IOException, InterruptedException {
-        String[] cmdArr = {"/bin/sh", "-c", "echo " + cmd + " | nc -q5 " + zkServer + " " + zkPort};
-        Process p = Runtime.getRuntime().exec(cmdArr);
-        p.waitFor();
-        BufferedReader reader = new BufferedReader(new InputStreamReader(p.getInputStream()));
+    public String executeCmd(String cmd, String zkServer, String zkPort) throws IOException {
+        Socket s = new Socket(zkServer, Integer.parseInt(zkPort));
+        PrintWriter out = new PrintWriter(s.getOutputStream(), true);
+        BufferedReader reader = new BufferedReader(new InputStreamReader(s.getInputStream()));
+        out.println(cmd);
         String line = reader.readLine();
         StringBuilder sb = new StringBuilder();
         while (line != null) {
             sb.append(line);
             sb.append("<br/>");
             line = reader.readLine();
         }
+        reader.close();
+        out.close();
+        s.close();
         return sb.toString();
     }
 }