由于 docker pull，Shell 脚本在通过 ProcessBuilder 运行时过早退出

Question

我有以下问题，这似乎是由我的 shell 脚本中的“docker pull”引起的，因为 pull 同时工作

#!/bin/bash   
#VARIABLES
    NAME="my-app"
    IMAGE="my-image:latest"
#DOCKER
    docker stop $NAME
    docker rm $NAME
    docker pull -q $IMAGE
    docker run --name $NAME -d -p 1234:8080 --log-opt fluentd-address=localhost:2233 $IMAGE

通过终端运行脚本工作正常，一切都按预期工作。但是当我使用 Java 的 ProcessBuilder 运行它时，脚本退出的速度要快得多，而且它似乎跳过了“docker pull”步骤。由于我不是 Java 开发人员，而且我对语言不是很熟悉，我感觉这与 docker pull 命令的多并发性质以及 Java Process Builder 如何执行 shell 脚本的方式有关

运行shell脚本的Java类是这个

try {

    Collection<Task> tasks = taskService.getProjectTasksByProjectKey(projectId);

    Task findTask = findTaskByTaskId(tasks, taskId);
    if (findTask.getTaskId() != null) {
        ProcessBuilder pb = new ProcessBuilder(findTask.getCmdPath());
        Process process = pb.start();

        String output;

        try (InputStream in = process.getInputStream();
             InputStream err = process.getErrorStream();
             OutputStream closeOnly = process.getOutputStream()) {
            while (process.isAlive()) {
                long skipped = in.skip(in.available())
                        + err.skip(err.available());
                if(skipped == 0L) {
                    process.waitFor(5L, TimeUnit.MILLISECONDS);
                }
            }
            output = loadStream(in);
        } finally {
            process.destroy();
        }

//                String error  = loadStream(process.getErrorStream());
//                int rc = process.waitFor();

//                log.debug("exit code ->>> " + rc);
//                StringBuilder output = new StringBuilder();
//                BufferedReader reader = new BufferedReader(
//                        new InputStreamReader(process.getInputStream()));
//
//                String line;
//
//                while ((line = reader.readLine()) != null) {
//                    output.append(line + "\n");
//                }
//
//                int exitVal = process.waitFor();
//                if (exitVal == 0) {
//                    System.out.println(output);
//
//                    return output.toString();
//                } else {
//                    //abnormal...
//                }

        return output;
    }
    else {
        throw new InvalidTaskModelException(taskId);
    }
} catch (InvalidModelException e) {
    throw new InvalidModelException(projectId);
} catch (IOException e) {
    e.printStackTrace();
} catch (InterruptedException e) {
    e.printStackTrace();
} catch (Exception e) {
    e.printStackTrace();
}

return null;
}

private static String loadStream(InputStream s) throws Exception
{
BufferedReader br = new BufferedReader(new InputStreamReader(s));
StringBuilder sb = new StringBuilder();
String line;
while((line=br.readLine()) != null)
    sb.append(line).append("\n");
return sb.toString();
}

注释行是我尝试这样做的不同方式。

如果有人遇到类似的问题，任何帮助将不胜感激！

Answer 1

很高兴您已经关心进程的 STDOUT 和 STDIN。但不要跳过将它们复制到 System.out，这样您就可以看到发生了什么。我怀疑事情没有按照你的期望进行。

查看您发布的 bash 脚本以及您正在尝试运行多个进程的事实：您的 java 代码是否可能逐行运行 bash 脚本？请注意，您的 java 程序不是 BASH 解释器，因此变量替换应该不起作用。