Rabbitmq延迟队列和惰性队列

2023-12-25 06:00:33

延迟队列

当一个队列中的消息满足下列情况之一,可以成为死信
(1)消费者使用basic.rejectbasic.nack声明消费失败,并且消息的requeue参数设置为false
(2)消息是一个过期消息,超时无人消费
(3)要投递的队列消息堆积满了,最早的消息可能成为死信
如果该队列配置了dead-letter-exchange属性,指定了一个交换机,那么队列中的死信就会投递到这个交换机中,而这个交换机称为死信交换机。
如何给队列绑定死信交换机?
(1)给队列设置dead-letter-exchange属性,指定一个交换机
(2)给队列设置dead-letter-routing-key属性,设置死信交换机与死信队列的RoutingKey

TTL(Time-To-Live)。如果一个队列中的消息TTL结束仍未消费,则会变为死信,TTL超时分为两种情况:
(1)消息所在的队列设置了存活时间
(2)消息本身设置了存活时间

利用TTL结合死信交换机,实现了消息发出后,消费者延迟收到消息的效果。这种消息模式就称为延迟队列模式。
延迟队列的使用场景包括:
(1)延迟发送短信
(2)用户下单,如果用户在15 分钟内未支付,则自动取消
(3)预约工作会议,20分钟后自动通知所有参会人员

DelayExchange的本质还是官方的三种交换机,只是添加了延迟功能。因此使用时只需要声明一个交换机,交换机的类型可以是任意类型,然后设定delayed属性为true即可。
基于注解的方式:

@RabbitListener(bindings = @QueueBinding(value = @Queue(name = "DelayQueue",durable = "true"),exchange = @Exchange(name = "delay-mq-exchange_B",delayed = "true"),key = "routingKey_delay"))
@Component
@Slf4j
public class DirectConsumer {
	......
}

基于Java代码的方式:

	@Bean
    public Exchange orderExchange(){
        return ExchangeBuilder.topicExchange(RabbitMQExchanges.EXCHANGE_B.getExchange()).delayed().durable(true).build();

    }

向delay为true的交换机中发送消息,一定要给消息添加一个header:x-delay,值为延迟的时间,单位为毫秒:

Message message= MessageBuilder.withBody(String.valueOf(content).getBytes(StandardCharsets.UTF_8)).setHeader("delay-one",500000).build();

惰性队列

**消息堆积问题:**当生产者发送消息的速度超过了消费者处理消息的速度,就会导致队列中的消息堆积,直到队列存储消息达到上限。最早接收到的消息,可能就会成为死信,会被丢弃,这就是消息堆积问题。

惰性队列的特征如下:
(1)接收到消息后直接存入磁盘而非内存
(2)消费者要消费消息时才会从磁盘中读取并加载到内存
(3)支持数百万条的消息存储
而要设置一个队列为惰性队列,只需要在声明队列时,指定x-queue-mode属性为lazy即可。用SpringAMQP声明惰性队列分两种方式:
基于注解的方式:

@RabbitListener(bindings = @QueueBinding(value = @Queue(name = "DelayQueue",durable = "true",arguments = @Argument(name = "x-dead-letter-exchange",value = "lazy")),exchange = @Exchange(name = "delay-mq-exchange_B",delayed = "true"),key = "routingKey_delay"))

基于Java代码的方式:

	@Bean
    public Queue orderQueue(){
        return QueueBuilder.durable(RabbitMQQueue.RABBIT_MQ_QUEUE_A.getQueue()).lazy().build();
    }

文章来源:https://blog.csdn.net/weixin_42592415/article/details/135176977
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。