Axon框架只为某些命令实现IntervalRetryScheduler

Question

目前，我不会使用自定义CommandGateway，即使是不重试的命令

我使用了不同的CommandGateway bean方法

    @Bean
    public CommandGateway commandGateway(){
        Configurer configurer = DefaultConfigurer.defaultConfiguration();
        CommandBus commandBus = configurer.buildConfiguration().commandBus();
        CommandGateway commandGateway = DefaultCommandGateway.builder().commandBus(commandBus).build();
        return commandGateway;
    }

    @Bean
    public CommandGateway commandGatewayWithRetry(){
        Configurer configurer = DefaultConfigurer.defaultConfiguration();
        CommandBus commandBus = configurer.buildConfiguration().commandBus();
        ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1);
        RetryScheduler rs = IntervalRetrySchedulerImpl.builder().retryExecutor(scheduledExecutorService).maxRetryCount(5).retryInterval(1000).build();
        CommandGateway commandGateway = DefaultCommandGateway.builder().commandBus(commandBus).retryScheduler(rs).build();
        return commandGateway;
    }

Answer 1

从这里开始，你可以从几个角度出发。

如果设置为使用RetryScheduler/CommandGateway思想，则可以执行以下任一操作。

• 配置不同的commandgatewaybean，或者使用我们的bean，而不使用RetryScheduler
• 具体说明重试时从SAGA引发的异常类型，以便RetryScheduler可以调整为重试yes或No。
• 构建一个自定义命令网关（如本文所述）。从那以后，当涉及到某些命令的行为时，您可以想怎么具体就怎么具体。

但是，我认为在Axon Usergroup的这篇文章中建议的解决方案在您的情况下更值得遵循。总结一下建议的方法，这个想法是通过使用Axon提供的最后期限机制来安排Saga本身的重试。

这样，如果微服务不可用（我假设这就是您试图解决的问题），您就可以让命令失败，并在一定时间后让Saga本身重试操作。

希望这能帮到你！