Spring Boot 实战：RabbitMQ延迟队列

在Spring Boot应用中实现RabbitMQ的延迟队列，可以通过RabbitMQ的Dead Letter Exchanges (DLX)特性配合TTL（Time To Live）来模拟实现。延迟队列允许消息在特定时间后才被消费，这对于定时任务、消息重试等场景非常有用。以下是具体步骤：

1. 添加依赖

确保你的项目中已经添加了RabbitMQ的Spring Boot Starter依赖，如之前所述，这在pom.xml中完成。

2. 配置普通队列与死信队列

首先，你需要配置一个常规的消息队列，并为其设置消息的TTL。然后，配置一个死信交换器（DLX）和死信队列，让过期的消息被重新路由到这个死信队列中，实现延迟的效果。

@Configuration
public class RabbitMQConfig {

    public static final String QUEUE_NAME = "normal.queue";
    public static final String DL_QUEUE_NAME = "delay.queue";
    public static final String EXCHANGE_NAME = "delay.exchange";
    public static final String ROUTING_KEY = "delay.routingKey";

    @Bean
    Queue normalQueue() {
        return QueueBuilder.durable(QUEUE_NAME)
                .ttl(10000) // 设置队列中消息的TTL为10秒
                .deadLetterExchange(EXCHANGE_NAME) // 设置死信交换器
                .deadLetterRoutingKey(ROUTING_KEY) // 设置死信路由键
                .build();
    }

    @Bean
    Queue delayQueue() {
        return QueueBuilder.durable(DL_QUEUE_NAME).build();
    }

    @Bean
    DirectExchange delayExchange() {
        return new DirectExchange(EXCHANGE_NAME);
    }

    @Bean
    Binding binding() {
        return BindingBuilder.bind(delayQueue()).to(delayExchange()).with(ROUTING_KEY);
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

3. 发送消息到普通队列

创建一个服务来发送消息到配置好的普通队列，由于设置了TTL，消息将在指定时间后变为死信。

@Service
public class RabbitMQSender {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void sendMessage(String message) {
        rabbitTemplate.convertAndSend(RabbitMQConfig.QUEUE_NAME, message);
    }
}
1
2
3
4
5
6
7
8
9
10

4. 接收延迟消息

创建一个监听器来接收从死信队列中重新路由过来的消息，即延迟后的消息。

@Component
public class DelayedMessageReceiver {

    @RabbitListener(queues = RabbitMQConfig.DL_QUEUE_NAME)
    public void receiveMessage(String message) {
        System.out.println("Received delayed message: " + message);
    }
}
1
2
3
4
5
6
7
8

5. 启动应用并测试

启动Spring Boot应用后，通过调用RabbitMQSender的sendMessage方法发送消息，然后观察DelayedMessageReceiver是否在指定延迟时间后收到了消息。

注意事项

• TTL可以设置在队列级别或消息级别。队列级别的TTL意味着队列中所有消息都会在指定时间后变为死信；消息级别的TTL允许为每条消息单独设置存活时间。
• 死信队列可以配置多个消费者来并行处理延迟消息。
• 在生产环境中，应适当调整TTL和队列的配置以满足实际业务需求，同时考虑消息丢失和重试策略。

通过上述步骤，你就可以在Spring Boot应用中利用RabbitMQ实现延迟队列的功能了。