修改单例Bean中「静态数据」应使用何种消息处理器？

针对你目前用header-enricher更新单例Map却生成无用header的问题，有几个更优雅的替代方案：

方案一：直接使用Service Activator执行更新 #

Spring Integration的<int:service-activator>可以直接执行表达式动作，不需要修改消息头或payload。替换原来的header-enricher配置即可：

<int:service-activator expression="@staticData.put('keyA', payload)" />

这个配置会直接调用单例Map的put方法完成更新，不会生成任何无用的消息头，改动最小且更直观。

方案二：封装静态数据到自定义Bean（推荐） #

直接操作Map不够面向对象，后续扩展维护成本高。可以把静态数据封装到一个自定义Bean中，封装更新逻辑：

1. 编写自定义数据持有类 #

@Component("staticDataHolder")
public class StaticDataHolder {
    // 用ConcurrentHashMap保证线程安全，适合多线程更新场景
    private final Map<String, Object> staticData = new ConcurrentHashMap<>();

    // 初始化预设key
    @PostConstruct
    public void init() {
        staticData.put("keyA", null);
        staticData.put("keyB", null);
    }

    // 封装keyA的更新方法
    public void updateKeyA(Object value) {
        staticData.put("keyA", value);
        // 可添加日志、校验等逻辑
    }

    // 封装keyB的更新方法
    public void updateKeyB(Object value) {
        staticData.put("keyB", value);
    }

    // 提供数据获取方法
    public Object get(String key) {
        return staticData.get(key);
    }
}

2. 配置Spring Integration调用更新方法 #

<int:service-activator expression="@staticDataHolder.updateKeyA(payload)" />

这种方式把数据操作逻辑封装在Bean内部，后续要加更新校验、缓存失效通知、日志监控等功能都非常方便，代码结构更清晰。

方案三：定时更新场景用Spring @Scheduled注解 #

如果你的静态数据是定期主动拉取更新，而非通过消息触发更新，可以直接在自定义Bean中使用Spring的定时任务注解，完全不需要Spring Integration的消息流：

@Component("staticDataHolder")
public class StaticDataHolder {
    private final Map<String, Object> staticData = new ConcurrentHashMap<>();
    // 注入数据获取服务，比如从DB/远程接口拉取数据
    @Autowired
    private DataFetchService dataFetchService;

    @PostConstruct
    public void init() {
        staticData.put("keyA", null);
        staticData.put("keyB", null);
        // 初始化时立即拉取一次数据
        refreshStaticData();
    }

    // 每小时执行一次更新（根据需求调整频率）
    @Scheduled(fixedRate = 3600000)
    public void refreshStaticData() {
        Object keyANewValue = dataFetchService.fetchKeyAData();
        staticData.put("keyA", keyANewValue);
        
        Object keyBNewValue = dataFetchService.fetchKeyBData();
        staticData.put("keyB", keyBNewValue);
    }

    public Object get(String key) {
        return staticData.get(key);
    }
}

这种方案更简洁，完全脱离消息流，适合定时更新的场景，减少不必要的组件依赖。

内容的提问来源于stack exchange，提问作者al.truisme