背景：生产上的服务有时会被注册中心(eureka)踢掉，故而需要重启服务器上的某个服务。

    2. @Slf4j
    3. @Service
    4. public class CellShellBusiness {
    6.     public int runRestartApplication(CellSellArg arg) throws Exception {
    7.         File file = new File("/data/work/" + arg.getServerName());
    8.         if (!file.exists() && !file.isDirectory()) {
    9.             throw new BusinessException(-1, "文件夹不存在!");
    10.         }
    11.         return this.runCommand(file, "./run.sh");
    12.     }
    14.     public int runCommand(File workDirector, String... cmd) throws IOException {
    16.         ProcessBuilder processBuilder = new ProcessBuilder(cmd);
    17.         processBuilder.directory(workDirector);
    19.         log.info("processBuilder.environment:");
    20.         log.info("env:{}", processBuilder.environment());
    21.         log.info("工作目录 pwd:{}", processBuilder.directory());
    23.         Process shellProcess = processBuilder.start();
    24.         BufferedReader stdInput = new BufferedReader(new InputStreamReader(shellProcess.getInputStream(), StandardCharsets.UTF_8));
    25.         BufferedReader stdError = new BufferedReader(new InputStreamReader(shellProcess.getErrorStream(), StandardCharsets.UTF_8));
    27.         //返回值，0为正确执行
    28.         int runningStatus = 0;
    29.         try {
    30.             //等待命令执行
    31. //            taskExecutor.execute(());
    32.             runningStatus = shellProcess.waitFor();
    33.         } catch (InterruptedException e) {
    34.             log.error("命令执行失败， error：" + e);
    35.         } finally {
    36.             log.info("running status:{}", runningStatus);
    37.         }
    38.         /*显示日志*/
    39.         String resultString;
    40.         while (null != (resultString = stdError.readLine())) {
    41.             //问题，fabric的info输出，这里需要getErrorStream获取到
    42.             log.info("stdError {}", resultString);
    43.         }
    44.         while (null != (resultString = stdInput.readLine())) {
    45.             log.info("stdInput {}", resultString);
    46.         }
    47.         // 销毁进程
    48.         if (shellProcess.isAlive()) {
    49.             shellProcess.destroy();
    50.         }
    51.         this.closeStream(stdInput);
    52.         this.closeStream(stdError);
    53.         return runningStatus;
    54.     }
    56.     private void closeStream(Closeable stream) {
    57.         if (stream != null) {
    58.             try {
    59.                 stream.close();
    60.             } catch (Exception e) {
    61.                 log.error("关闭连接失败，error : " + e);
    62.             }
    63.         }
    64.     }
    65. }
    68. @Data
    69. public class CellSellArg {
    70.     private String serverName;
    71. }