从CRaC检查点启动Spring Boot应用时如何设置配置文件与路径？

当通过Jar包正常启动Spring Boot应用时，可通过环境变量指定激活的配置文件与路径：

SPRING_PROFILES_ACTIVE=p1 SPRING_CONFIG_LOCATION=file:runtime-configuration/application.yaml java -jar app.jar

但从CRaC检查点恢复应用时，上述环境变量会被忽略（检查点保存了创建时的上下文状态），恢复命令示例：

SPRING_PROFILES_ACTIVE=p1 SPRING_CONFIG_LOCATION=file:runtime-configuration/application.yaml java -XX:CRaCRestoreFrom=checkpoint

检查点创建命令：

java -Dspring.context.checkpoint=onRefresh -XX:CRaCCheckpointTo=checkpoint -jar app.jar

可以通过自定义代码实现恢复时重新加载配置 #

下面是具体实现方案：

1. 监听CRaC恢复事件，执行配置重载 #

通过实现org.crac.Resource接口，在应用从检查点恢复时触发自定义逻辑：

import org.crac.Context;
import org.crac.Resource;
import org.springframework.boot.SpringApplication;
import org.springframework.core.env.ConfigurableEnvironment;
import org.springframework.core.env.MutablePropertySources;
import org.springframework.core.env.PropertiesPropertySource;
import org.springframework.core.io.FileSystemResource;
import org.springframework.core.io.support.PropertiesLoaderUtils;
import org.springframework.stereotype.Component;

import java.io.File;
import java.io.IOException;
import java.util.Properties;

@Component
public class CracConfigReloader implements Resource {

    private final ConfigurableEnvironment environment;
    private final SpringApplication springApplication;

    public CracConfigReloader(ConfigurableEnvironment environment, SpringApplication springApplication) {
        this.environment = environment;
        this.springApplication = springApplication;
    }

    @Override
    public void beforeCheckpoint(Context<? extends Resource> context) throws Exception {
        // 检查点创建前的预处理逻辑（可选）
    }

    @Override
    public void afterRestore(Context<? extends Resource> context) throws Exception {
        // 读取环境变量中的配置参数
        String activeProfile = System.getenv("SPRING_PROFILES_ACTIVE");
        String configLocation = System.getenv("SPRING_CONFIG_LOCATION");

        // 重新加载指定路径的配置文件
        if (configLocation != null && !configLocation.isEmpty()) {
            String configPath = configLocation.replace("file:", "");
            File configFile = new File(configPath);
            if (configFile.exists()) {
                Properties properties = PropertiesLoaderUtils.loadProperties(new FileSystemResource(configFile));
                MutablePropertySources propertySources = environment.getPropertySources();
                // 将重载的配置添加到优先级最高的位置
                propertySources.addFirst(new PropertiesPropertySource("crac-reloaded-config", properties));
            }
        }

        // 设置激活的Profile并刷新上下文
        if (activeProfile != null && !activeProfile.isEmpty()) {
            environment.setActiveProfiles(activeProfile.split(","));
            springApplication.refreshContext(springApplication.run());
        }
    }
}

2. 可选：通过EnvironmentPostProcessor增强配置加载 #

如果需要更灵活的配置处理逻辑，可实现EnvironmentPostProcessor，在应用启动（含恢复阶段）时介入：

import org.springframework.boot.env.EnvironmentPostProcessor;
import org.springframework.core.env.ConfigurableEnvironment;
import org.springframework.core.env.MutablePropertySources;
import org.springframework.core.env.PropertiesPropertySource;
import org.springframework.core.io.FileSystemResource;
import org.springframework.core.io.support.PropertiesLoaderUtils;

import java.io.File;
import java.io.IOException;
import java.util.Properties;

public class CracEnvironmentPostProcessor implements EnvironmentPostProcessor {

    @Override
    public void postProcessEnvironment(ConfigurableEnvironment environment, org.springframework.boot.SpringApplication application) {
        // 仅在CRaC恢复阶段执行
        if (Boolean.getBoolean("org.crac.restore")) {
            String activeProfile = System.getenv("SPRING_PROFILES_ACTIVE");
            String configLocation = System.getenv("SPRING_CONFIG_LOCATION");

            if (configLocation != null && !configLocation.isEmpty()) {
                String configPath = configLocation.replace("file:", "");
                File configFile = new File(configPath);
                if (configFile.exists()) {
                    try {
                        Properties properties = PropertiesLoaderUtils.loadProperties(new FileSystemResource(configFile));
                        MutablePropertySources propertySources = environment.getPropertySources();
                        propertySources.addFirst(new PropertiesPropertySource("crac-reloaded-config", properties));
                    } catch (IOException e) {
                        throw new RuntimeException("加载重载配置文件失败", e);
                    }
                }
            }

            if (activeProfile != null && !activeProfile.isEmpty()) {
                environment.setActiveProfiles(activeProfile.split(","));
            }
        }
    }
}

然后在src/main/resources/META-INF/spring.factories中注册该处理器：

org.springframework.boot.env.EnvironmentPostProcessor=com.example.yourpackage.CracEnvironmentPostProcessor

3. 注意事项 #

• 项目需引入CRaC依赖：

<dependency>
    <groupId>org.crac</groupId>
    <artifactId>crac</artifactId>
    <version>0.1.3</version>
    <scope>provided</scope>
</dependency>

• 刷新上下文时需注意Bean的状态，避免重复初始化；若无需全量刷新，可针对特定配置Bean单独处理。
• 确保CRaC检查点创建与恢复使用的JDK版本一致，且使用支持CRaC的JDK（如带CRaC补丁的OpenJDK 17+）。

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