Springboot 集成Rabbitmq之延时队列-阿里云开发者社区

Springboot 集成Rabbitmq之延时队列

2024-05-10 7

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： Springboot 集成Rabbitmq之延时队列

1.首先确保已经引入了Spring AMQP和RabbitMQ的相关依赖：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

2. 创建一个普通队列并设置TTL（消息过期时间），同时声明一个死信交换机和死信队列，当普通队列中的消息过期后会自动转发到死信队列：

@Bean
Queue normalQueue() {
    Map<String, Object> args = new HashMap<>();
    args.put("x-message-ttl", 60000); // 消息有效期为60秒
    args.put("x-dead-letter-exchange", "delayExchange"); // 设置死信交换机
    args.put("x-dead-letter-routing-key", "delayQueue"); // 设置死信路由键
    return new Queue("normalQueue", true, false, false, args);
}
 
@Bean
Queue delayQueue() {
    return new Queue("delayQueue", true, false, false);
}
 
@Bean
DirectExchange delayExchange() {
    return new DirectExchange("delayExchange");
}
 
@Bean
Binding delayBinding(DirectExchange delayExchange, Queue delayQueue) {
    return BindingBuilder.bind(delayQueue).to(delayExchange).with("delayQueue");
}

3.在delayQueue上监听消息，这样当消息从normalQueue过期转移到delayQueue后，消费者就会接收到这条消息：

@RabbitListener(queues = "delayQueue")
public void processDelayMessage(String message) {
    System.out.println("Processing delayed message: " + message);
    // 在这里处理延时后的消息
}

4.发送消息到normalQueue：

@Autowired
private RabbitTemplate rabbitTemplate;
 
public void sendMessage(String message) {
    rabbitTemplate.convertAndSend("normalQueue", message);
}