RabbitMQ学习-延迟队列-Toy模板网

这篇具有很好参考价值的文章主要介绍了RabbitMQ学习-延迟队列。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

延迟队列

背：也就是给队列设置个过期时间，然后到时间消息变成死信，消费死信队列中的消息就行，再没什么玩意，演示队列优化就是不给队列这只TTL，再生产者代码中消息里面设置消息TTL，因为 RabbitMQ 只会检查第一个消息是否过期，如果过期则丢到死信队列， 如果第一个消息的延时时长很长，而第二个消息的延时时长很短，第二个消息并不会优先得到执行。所以就是消费顺序问题要安装个插件

延迟队列中的元素是希望在指定时间到了以后或之前取出和处理，简单来说，延时队列就是用来存放需要在指定是按处理的元素的队列

延迟队列使用场景

1. 订单在十分钟之内未支付则自动取消

2. 新创建的店铺，如果在十天内都没有上传过商品，则自动发送消息提醒。

3. 用户注册成功后，如果三天内没有登陆则进行短信提醒。

4. 用户发起退款，如果三天内没有得到处理则通知相关运营人员。

5. 预定会议后，需要在预定的时间点前十分钟通知各个与会人员参加会议

设置TTL的两种方式：

1.队列设置TTL

在创建对别的收设置队列的x-message-ttl属性，例如

Map<String, Object> map = new HashMap<>();
//设置队列有效期为10秒
map.put("x-message-ttl",10000);
channel.queueDeclare(queueName,durable,exclusive,autoDelete,map);

消息设置TTL
对每条消息设置TTL
AMQP.BasicProperties properties = new AMQP.BasicProperties().builder().expiration("10000").build();
channel.basicPublish(exchangeName,routingKey,mandatory,properties,"msg body".getBytes());
两者之间的区别：
1.如果设置了队列的TTL属性，那么一旦消息过期，就会被队列的丢弃
2.如果是消息设置了TTL属性，那么即使消息过期，也不一定会马上丢弃，因为消息是否过期是在即将投递到消费者之前判定的，如果当前队列有严重的消息挤压情况，那么已
经过期的消息也许还能存活较长时间
3.如果我们没有设置TTL，就表示消息永远不会过期，如果TTL设置为0，则表示除非此时可以直接投递到消费者，否则该消息会被丢弃

整合springboot

RabbitMQ学习-延迟队列

添加依赖文章来源地址https://www.toymoban.com/news/detail-466760.html

 <!--RabbitMQ 依赖-->
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-amqp</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-web</artifactId>
 <

到了这里，关于RabbitMQ学习-延迟队列的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！