java实现Rabbitmq延迟队列和惰性队列

更新时间：2023年12月25日 08:29:08 作者：kk变色龙13

本文主要介绍了java实现Rabbitmq延迟队列和惰性队列，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧

延迟队列

当一个队列中的消息满足下列情况之一，可以成为死信：
（1）消费者使用basic.reject或basic.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();
    }

到此这篇关于java实现Rabbitmq延迟队列和惰性队列的文章就介绍到这了,更多相关java Rabbitmq延迟队列和惰性队列内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

Java中RabbitMQ延迟队列实现详解

java读取html文件,并获取body中所有的标签及内容的案例
这篇文章主要介绍了java读取html文件,并获取body中所有的标签及内容的案例，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2020-08-08
Spring MVC之@RequestMapping注解详解
本篇文章主要介绍了Spring MVC之@RequestMapping 详解，RequestMapping是一个用来处理请求地址映射的注解，可用于类或方法上。有兴趣的可以了解一下。
2017-01-01
SpringBoot Druid配置过程图解
这篇文章主要介绍了SpringBoot Druid配置过程图解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2020-03-03
JavaWeb 实现验证码功能(demo)
在 WEB-APP 中一般应用于：登录、注册、买某票、秒杀等场景，大家都接触过这个验证码操作，今天小编通过实例代码给大家讲解javaweb实现验证码功能，需要的朋友参考下
2017-02-02
关于Intellij IDEA中的Version Control问题
这篇文章主要介绍了Intellij IDEA中的Version Control问题,本文通过图文并茂的形式给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2021-11-11
深入了解Java 脚本化api编程
Java 脚本 API 是一种独立于框架的脚本语言，使用来自于Java代码的脚本引擎。可以使用Java语言编写定制/可扩展的应用程序并将自定义脚本语言选择留给最终用户。下面我们来详细了解一下吧
2019-06-06
SpringCloud灰度发布的设计与实现详解
这篇文章主要介绍了SpringCloud灰度发布的设计与实现详解,灰度从字面意思理解就是存在于黑与白之间的一个平滑过渡的区域,所以说对于互联网产品来说,上线和未上线就是黑与白之分,而实现未上线功能平稳过渡的一种方式就叫做灰度发布,需要的朋友可以参考下
2023-09-09
从架构思维角度分析高并发下幂等性解决方案
幂等（idempotent、idempotence）是一个数学与计算机学概念，常见于抽象代数中。在编程中.一个幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同。幂等函数，或幂等方法，是指可以使用相同参数重复执行，并能获得相同结果的函数
2022-01-01
Maven项目无法加载jdbc.properties的问题解决
本文主要介绍了Maven项目无法加载jdbc.properties的问题解决,文章首先分析了问题的原因,然后提供了解决方法,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
2023-08-08
Spring Boot Admin 动态修改日志级别的方法步骤
这篇文章主要介绍了Spring Boot Admin 动态修改日志级别的方法步骤，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2020-08-08