spring amqp 通过配置启用重试,并根据指定的异常阻止重试

2024-03-15

我有以下两种情况

  1. 的情况下例外AL:重试有限次数 最后当重试次数用尽时,消息被写入 死信队列
  2. 的情况下异常B:简单来说,消息应该写到 死信队列

我想在同一个侦听器容器工厂和同一个队列上支持这两种情况。

我已经有以下配置来支持case 1成功地:

@Bean
public RetryOperationsInterceptor workMessagesRetryInterceptor() {
        return RetryInterceptorBuilder.stateless()
                .maxAttempts(5)
                .backOffOptions(1000, 2, 10000)
                .recoverer(new RejectAndDontRequeueRecoverer())
                .build();
    }




@Bean
public SimpleRabbitListenerContainerFactory myRabbitListenerContainerFactory(ConnectionFactory connectionFactory) {
  SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
  factory.setConnectionFactory(connectionFactory);
  factory.setMaxConcurrentConsumers(8);
  factory.setAdviceChain(workMessagesRetryInterceptor());


  return factory;
}`

现在我想扩展之前的配置来支持情况 2。


编辑,感谢加里的快速回复。

这是我的新配置,但我仍然获得重审关于两个异常: ListenerExecutionFailedException 、 AmqpRejectAndDontRequeueException

@Bean
    public SimpleRetryPolicy rejectionRetryPolicy(){

        Map<Class<? extends Throwable> , Boolean> exceptionsMap = new HashMap<Class<? extends Throwable> , Boolean>();
        exceptionsMap.put(ListenerExecutionFailedException.class, true); //retriable
        exceptionsMap.put(AmqpRejectAndDontRequeueException.class, false);//not retriable


        SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy(5 , exceptionsMap );




        return retryPolicy;
    }

    @Bean
    public RetryOperationsInterceptor workMessagesRetryInterceptor() {
        return RetryInterceptorBuilder.stateless().retryPolicy(rejectionRetryPolicy())

                //.backOffOptions(1000, 2, 10000)
                //.recoverer(new RejectAndDontRequeueRecoverer())
                .build();
    }

提供一个SimpleRetryPolicy带有异常和布尔值的映射(是否重试)。您可以选择遍历异常原因树来查找特定的异常。请参阅SimpleRetryPolicy 的 Javadoc https://github.com/spring-projects/spring-retry/blob/master/src/main/java/org/springframework/retry/policy/SimpleRetryPolicy.java#L73.

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

spring amqp 通过配置启用重试,并根据指定的异常阻止重试 的相关文章

随机推荐