【中间件】RabbitMQ 自定义重试次数（针对同一模块不同消费者）

在RabbitMQ中，可以通过设置消费者的spring.rabbitmq.listener.simple.retry.enabled为false来禁用默认的重试逻辑，然后通过RecoveryCallback来实现自定义的重试逻辑。

以下是一个简单的示例，展示如何在Spring Boot应用程序中为不同的消费者设置自定义的重试次数：

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer;
import org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
 
@Configuration
public class RabbitMQConfig {
 
    @Bean
    public SimpleMessageListenerContainer messageListenerContainer(ConnectionFactory connectionFactory) {
        SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        container.setQueueNames("yourQueueName");
        container.setMessageListener(yourMessageListener());
        // 设置为false禁用默认的重试逻辑
        container.setRetryEnabled(false);
        return container;
    }
 
    @Bean
    public ChannelAwareMessageListener yourMessageListener() {
        return (message, channel) -> {
            // 在这里实现你的消息处理逻辑，并使用RecoveryCallback来实现自定义重试
            // 假设你有一个自定义的重试逻辑方法 customRetryLogic(message, channel)
            boolean messageProcessedSuccessfully = customRetryLogic(message, channel);
            if (messageProcessedSuccessfully) {
                // 如果消息处理成功，确认消息
                channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
            } else {
                // 如果消息处理失败，可以选择重新发布到队列或者拒绝等
                channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true);
            }
        };
    }
 
    private boolean customRetryLogic(Message message, Channel channel) {
        // 实现你的自定义重试逻辑，比如重试几次后依然失败则返回false
        // 这里只是一个简单的示例，你可以根据需要设计更复杂的逻辑
        try {
            // 你的处理逻辑
            return true;
        } catch (Exception e) {
            // 在这里实现重试逻辑，比如使用消息重试前缀重新发布消息到队列等
            try {
                // 重试逻辑
                return false; // 如果重试失败则返回false
            } catch (Exception retryException) {
                // 处理重试失败的情况
                return false;
            }
        }
    }
}

在这个配置中，我们创建了一个\`