SpringBoot容器中ProcessBuilder执行Liquibase更新频繁挂起

核心问题根源 #

你的代码中同时使用了redirectErrorStream(true)和inheritIO()，这两个配置是冲突的：

• inheritIO()会让子进程的标准输入、输出、错误流直接继承当前JVM进程的IO，此时子进程的输出会直接打印到控制台，process.getInputStream()会返回空流或无法读取有效数据。
• 你后续又尝试手动读取getInputStream()，导致readLine()因没有可读取的数据而无限阻塞，这就是随机挂起的原因。

另外，在@Component的构造函数中执行耗时的外部命令，可能会阻塞Spring应用的启动流程，也是不推荐的做法。

修复方案 #

方案1：保留流读取，移除inheritIO()

只使用redirectErrorStream(true)合并错误流到输入流，然后正常读取并处理输出，同时添加超时机制避免无限阻塞。

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.TimeUnit;
import org.springframework.stereotype.Component;
import javax.annotation.PostConstruct;

@Component
public class MyComponent {

    @PostConstruct
    public void runLiquibaseUpdates() throws Exception {
        System.out.println("RB");

        List<String> tenants = Arrays.asList("001", "002schema", "003_schema");

        for (String tenant : tenants) {
            ProcessBuilder processBuilder = new ProcessBuilder();
            // 合并错误流到输入流，便于统一读取
            processBuilder.redirectErrorStream(true);

            System.out.println("Liquibase update: " + tenant);

            processBuilder.command(
                "/home/liquibase/liquibase",
                "--url=jdbc:postgresql://localhost:5432/postgres?currentSchema=" + tenant,
                "--changeLogFile=config/liquibase/changelog/root-changelog.xml",
                "--username=postgres",
                "--password=password",
                "--search-path=/home/",
                "--liquibase-schema-name=" + tenant,
                "--preserveSchemaCase=true",
                "update");

            System.out.println(processBuilder);

            Process process = processBuilder.start();
            System.out.println("Started");

            StringBuilder output = new StringBuilder();
            // 使用try-with-resources自动关闭流
            try (BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream()))) {
                System.out.println("Buffer created");

                String line;
                // 实时读取并打印输出，同时记录到字符串
                while ((line = reader.readLine()) != null) {
                    output.append(line).append("\n");
                    System.out.println(line);
                }
                System.out.println("Read lines from buffer");
            }

            // 设置5分钟超时，避免无限阻塞
            boolean isFinished = process.waitFor(5, TimeUnit.MINUTES);
            if (!isFinished) {
                System.out.println("Liquibase update timed out for tenant: " + tenant);
                process.destroyForcibly();
                continue;
            }

            int exitVal = process.exitValue();
            System.out.println("Waited for process");
            if (exitVal == 0) {
                System.out.println("Success!");
            } else {
                System.out.println("Error!");
                System.out.println(output);
            }

            process.destroy();
        }
    }
}

方案2：使用inheritIO()，移除手动流读取

如果不需要捕获子进程的输出内容，直接用inheritIO()让子进程输出打印到控制台，无需手动读取流：

import java.util.Arrays;
import java.util.List;
import java.util.concurrent.TimeUnit;
import org.springframework.stereotype.Component;
import javax.annotation.PostConstruct;

@Component
public class MyComponent {

    @PostConstruct
    public void runLiquibaseUpdates() throws Exception {
        System.out.println("RB");

        List<String> tenants = Arrays.asList("001", "002schema", "003_schema");

        for (String tenant : tenants) {
            ProcessBuilder processBuilder = new ProcessBuilder();
            // 子进程IO直接继承当前进程，输出直接打印到控制台
            processBuilder.inheritIO();

            System.out.println("Liquibase update: " + tenant);

            processBuilder.command(
                "/home/liquibase/liquibase",
                "--url=jdbc:postgresql://localhost:5432/postgres?currentSchema=" + tenant,
                "--changeLogFile=config/liquibase/changelog/root-changelog.xml",
                "--username=postgres",
                "--password=password",
                "--search-path=/home/",
                "--liquibase-schema-name=" + tenant,
                "--preserveSchemaCase=true",
                "update");

            System.out.println(processBuilder);

            Process process = processBuilder.start();
            System.out.println("Started");

            // 设置超时时间
            boolean isFinished = process.waitFor(5, TimeUnit.MINUTES);
            if (!isFinished) {
                System.out.println("Liquibase update timed out for tenant: " + tenant);
                process.destroyForcibly();
                continue;
            }

            int exitVal = process.exitValue();
            System.out.println("Waited for process");
            if (exitVal == 0) {
                System.out.println("Success!");
            } else {
                System.out.println("Error!");
            }

            process.destroy();
        }
    }
}

额外建议 #

1. 避免硬编码敏感信息：数据库密码等敏感内容应通过环境变量或Spring配置文件注入，不要直接写在代码里。
2. 优先使用Liquibase Java API：直接调用Liquibase的Java API执行更新，比调用外部进程更可靠，也更容易集成到Spring应用的生命周期中，无需处理ProcessBuilder的IO问题。
3. 异步执行耗时任务：如果Liquibase更新耗时较长，可以用@Async注解异步执行，避免阻塞应用启动。

内容的提问来源于stack exchange，提问作者bobbyrne01