咨询Maven重定位Spring Boot包及AxonServer多实例命令冲突解决方案

一、Maven打包时重定位包名 #

使用maven-shade-plugin可以在执行mvn install时完成包路径的重定位，具体配置如下：

在项目pom.xml的build/plugins节点下添加插件配置：

<plugin>
    <groupId>org.apache.maven.plugins</groupId>
    <artifactId>maven-shade-plugin</artifactId>
    <version>3.5.1</version> <!-- 建议使用最新稳定版本 -->
    <executions>
        <execution>
            <phase>package</phase>
            <goals>
                <goal>shade</goal>
            </goals>
            <configuration>
                <relocations>
                    <relocation>
                        <pattern>com.example.models</pattern>
                        <shadedPattern>com.example.mymodels</shadedPattern>
                    </relocation>
                </relocations>
            </configuration>
        </execution>
    </executions>
</plugin>

执行mvn install后，生成的jar包中com.example.models下的所有类会被自动重定位到com.example.mymodels路径下。注意：若项目中有其他依赖直接引用该包下的类，需确保这些引用能适配重定位后的路径，也可通过relocation下的includes/excludes节点控制重定位范围。

二、Axon Framework命令冲突的更优方案 #

修改包名虽能解决冲突，但并非最灵活的方案，推荐以下几种适配Axon生态的方式：

1. AxonServer Context隔离 #

AxonServer支持多Context机制，不同实例配置独立Context后，消息会在各自Context内分发，完全隔离互不干扰。
在application.properties中配置：

axon.axonserver.context=my-unique-instance-context

每个独立实例配置唯一的Context名称即可。

2. 自定义命令路由键 #

Axon默认基于命令全类名路由，可通过自定义CommandRoutingStrategy为路由键添加实例唯一标识，实现精准路由：

@Component
public class InstanceRoutingStrategy extends AnnotationCommandRoutingStrategy {
    @Value("${instance.id}")
    private String instanceId;

    @Override
    public String getRoutingKey(CommandMessage<?> command) {
        String originalKey = super.getRoutingKey(command);
        return instanceId + ":" + originalKey;
    }
}

为每个实例配置不同的instance.id，相同命令会根据实例ID路由到对应实例。

3. 命令元数据过滤 #

发送命令时添加实例标识元数据，在命令处理端通过拦截器过滤，只处理属于当前实例的命令：

• 发送命令时附加元数据：

commandGateway.send(new MyCommand(), MetaData.with("instanceId", "instance-001"));

• 实现命令拦截器：

@Component
public class InstanceCommandInterceptor implements MessageInterceptor<CommandMessage<?>> {
    @Value("${instance.id}")
    private String instanceId;

    @Override
    public Object handle(UnitOfWork<? extends CommandMessage<?>> unitOfWork, InterceptorChain interceptorChain) throws Exception {
        MetaData metaData = unitOfWork.getMessage().getMetaData();
        if (instanceId.equals(metaData.get("instanceId"))) {
            return interceptorChain.proceed();
        }
        throw new CommandExecutionException("Command not intended for this instance", null);
    }
}

4. 命令类名称差异化 #

直接修改命令类名称，为不同实例的命令添加专属前缀/后缀（如MyCommandInstanceA），但该方式需修改代码，灵活性较差。

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