Spring rabbit重试以传递被拒绝的消息..可以吗？

您必须将重试策略配置为不针对该异常重试。

您无法使用属性来执行此操作，必须自己配置重试建议。

如果您需要帮助，稍后再举一个例子。

requeue-rejected

编辑

@SpringBootApplicationpublic class So39853762Application {    public static void main(String[] args) throws Exception {        ConfigurableApplicationContext context = SpringApplication.run(So39853762Application.class, args);        Thread.sleep(60000);        context.close();    }    @RabbitListener(queues = "foo")    public void foo(String foo) {        System.out.println(foo);        if ("foo".equals(foo)) { throw new AmqpRejectAndDontRequeueException("foo"); // won't be retried.        }        else { throw new IllegalStateException("bar"); // will be retried        }    }    @Bean    public ListenerRetryAdviceCustomizer retryCustomizer(SimpleRabbitListenerContainerFactory containerFactory, RabbitProperties rabbitPropeties) {        return new ListenerRetryAdviceCustomizer(containerFactory, rabbitPropeties);    }    public static class ListenerRetryAdviceCustomizer implements InitializingBean {        private final SimpleRabbitListenerContainerFactory containerFactory;        private final RabbitProperties rabbitPropeties;        public ListenerRetryAdviceCustomizer(SimpleRabbitListenerContainerFactory containerFactory,     RabbitProperties rabbitPropeties) { this.containerFactory = containerFactory; this.rabbitPropeties = rabbitPropeties;        }        @Override        public void afterPropertiesSet() throws Exception { ListenerRetry retryConfig = this.rabbitPropeties.getListener().getRetry(); if (retryConfig.isEnabled()) {     RetryInterceptorBuilder<?> builder = (retryConfig.isStateless()  ? RetryInterceptorBuilder.stateless()  : RetryInterceptorBuilder.stateful());     Map<Class<? extends Throwable>, Boolean> retryableExceptions = new HashMap<>();     retryableExceptions.put(AmqpRejectAndDontRequeueException.class, false);     retryableExceptions.put(IllegalStateException.class, true);     SimpleRetryPolicy policy =  new SimpleRetryPolicy(retryConfig.getMaxAttempts(), retryableExceptions, true);     ExponentialBackOffPolicy backOff = new ExponentialBackOffPolicy();     backOff.setInitialInterval(retryConfig.getInitialInterval());     backOff.setMultiplier(retryConfig.getMultiplier());     backOff.setMaxInterval(retryConfig.getMaxInterval());     builder.retryPolicy(policy)         .backOffPolicy(backOff)         .recoverer(new RejectAndDontRequeueRecoverer());     this.containerFactory.setAdviceChain(builder.build()); }        }    }}

注意： 当前，您无法将策略配置为重试所有例外，“例外”除外-
您必须对要重试的所有例外进行分类（它们不能是的超类

AmqpRejectAndDontRequeueException