使用Java API监控WildFly服务器重载完成状态

CliCommandBuilder cliCommandBuilder = ...;
cliCommandBuilder.setCommand("reload");
Process process = Launcher.of(cliCommandBuilder)
    .inherit()
    .setRedirectErrorStream(true)
    .launch();

Launcher.of(cliCommandBuilder)
    .inherit()
    .setRedirectErrorStream(true)
    .launch().waitFor();

import org.jboss.as.controller.client.ModelControllerClient;
import org.jboss.as.controller.client.helpers.ClientConstants;
import org.jboss.as.controller.client.helpers.Operations;
import org.jboss.dmr.ModelNode;
import org.wildfly.core.cli.CliCommandBuilder;
import org.wildfly.core.cli.Launcher;
import org.wildfly.plugins.core.ServerHelper; // 需要引入 wildfly-maven-plugin-core 依赖

import java.io.IOException;
import java.util.concurrent.TimeUnit;

public class WildFlyReloadWaiter {

    private static final String WILDFLY_HOME = "/opt/wildfly-27.0.0.Final"; // 替换为你的WildFly安装路径
    private static final String MANAGEMENT_HOST = "localhost";
    private static final int MANAGEMENT_PORT = 9990;

    public static void main(String[] args) throws IOException, InterruptedException {
        System.out.println("Initiating WildFly server reload...");

        // 1. 构建并执行reload命令
        final CliCommandBuilder commandBuilder = CliCommandBuilder.of(WILDFLY_HOME)
                .setConnection(MANAGEMENT_HOST + ":" + MANAGEMENT_PORT)
                .setCommand("reload");

        final Process process = Launcher.of(commandBuilder)
                .inherit() // 继承父进程的IO流，便于观察CLI输出
                .setRedirectErrorStream(true)
                .launch();

        // 2. 等待CLI进程终止
        // 设定一个合理的超时时间，防止CLI命令卡住
        if (!process.waitFor(60, TimeUnit.SECONDS)) { // 例如，等待60秒
            throw new RuntimeException("WildFly CLI reload command process failed to terminate within the timeout.");
        }
        System.out.println("WildFly CLI reload command process terminated.");

        // 3. 轮询服务器状态直到其运行
        waitForWildFlyServerToStart(MANAGEMENT_HOST, MANAGEMENT_PORT, 180, TimeUnit.SECONDS); // 设定服务器启动超时时间
        System.out.println("WildFly server has successfully reloaded and is running.");

        // 服务器已就绪，现在可以执行后续操作，例如部署
        // deployNewContent();
    }

    private static void waitForWildFlyServerToStart(String host, int port, long timeout, TimeUnit unit) throws IOException, InterruptedException {
        System.out.printf("Waiting for WildFly server to start at %s:%d...%n", host, port);
        long startTime = System.currentTimeMillis();
        long timeoutMillis = unit.toMillis(timeout);

        try (ModelControllerClient client = ModelControllerClient.Factory.create(host, port)) {
            while (!ServerHelper.isStandaloneRunning(client)) {
                if (System.currentTimeMillis() - startTime > timeoutMillis) {
                    throw new RuntimeException("WildFly server did not restart within the specified timeout (" + timeout + " " + unit.name() + ").");
                }
                TimeUnit.MILLISECONDS.sleep(500L); // 每隔500毫秒检查一次
            }

            // 服务器已运行，可选地读取其运行模式进行确认
            ModelNode op = Operations.createReadResourceOperation();
            op.get(ClientConstants.INCLUDE_RUNTIME).set(true);
            ModelNode result = client.execute(op);

            if (Operations.isSuccessfulOutcome(result)) {
                String runningMode = Operations.readResult(result).get("running-mode").asString();
                System.out.printf("WildFly Server is now confirmed running. Mode: %s%n", runningMode);
            } else {
                System.err.printf("Failed to read server running mode after restart: %s%n", Operations.getFailureDescription(result).asString());
            }
        }
    }
}

<dependencies>
    <!-- WildFly CLI Launcher -->
    <dependency>
        <groupId>org.wildfly.core</groupId>
        <artifactId>wildfly-cli-launcher</artifactId>
        <version>20.0.0.Final</version> <!-- 根据你的WildFly版本选择合适的版本 -->
    </dependency>
    <!-- WildFly Controller Client (for ModelControllerClient) -->
    <dependency>
        <groupId>org.wildfly.core</groupId>
        <artifactId>wildfly-controller-client</artifactId>
        <version>20.0.0.Final</version> <!-- 与wildfly-cli-launcher版本匹配 -->
    </dependency>
    <!-- WildFly Maven Plugin Core (for ServerHelper) -->
    <dependency>
        <groupId>org.wildfly.plugins</groupId>
        <artifactId>wildfly-maven-plugin-core</artifactId>
        <version>4.2.0.Final</version> <!-- 选择最新稳定版本 -->
    </dependency>
    <!-- JBoss DMR (for ModelNode operations) -->
    <dependency>
        <groupId>org.jboss</groupId>
        <artifactId>jboss-dmr</artifactId>
        <version>1.6.1.Final</version> <!-- 选择最新稳定版本 -->
    </dependency>
</dependencies>