Rabbit MQ消息队列原理(2)

简介: Rabbit MQ消息队列原理(2)

五,实现订单延迟关闭


业务场景:超过30分钟未付款的订单自动关闭,这个功能应该怎么实现?


RabbitMQ本身不支持延迟投递,总的来说有2种实现方案:


1,先存储到数据库,用定时任务扫描


(定时任务比较容易实现,比如每搁1分钟扫描一次,查出30分钟之前未付款的订单,把状态改为关闭。但是如果数据量过大,比如:10万条,把这些全部的数据查询到内存中逐条处理,也会给服务器带来很大的压力,影响正常的业务运行)


2,利用RabbitMQ的死信队列(Dead Letter Queue)实现

(借助RabbitMQ消息的特性),

(1)队列有一个消息过期属性,这个属性叫x-messge-ttl,所有队列中的消息超过时间未被消费时,都会过期。TTL(Time To Live)。


image.png


(2)RabbitMQ中消息的单独的过期时间

在发送消息的时候通过MessageProperities指定消息属性


image.png


问题:如果同时指定了msg TTL和Queue TTL,则小的那个时间生效。有了过期时间还不够,这个消息不能直接丢弃,不然就没办法消费了。最好是丢到一个容器里边,这样就可以实现延迟消费了。还需要用到死信队列


死信:消息过期以后,如果没有任何配置,是会直接丢弃的。我们可以通过配置让这样的消息变成死信(Dead Letter),在别的地方存储。

队列在创建的时候可以指定一个死信交换机DLX(Dead Letter Exchange)。死信交换机绑定的队列被称为死信队列DLQ(Dead Letter Queue),DLX实际上也是普通的交换机,DLQ也是普通的交换机(例如替补球员也是普通球员)。


image.png


也就是说如果消息过期了,队列制定了DLX,就会发送到DLX,如果DLX绑定了DLQ,就会路由到DLQ,路由到DLQ之后,我们就可以消费了。


死信队列的使用步骤:

image.png


image.png


image.png


总结一下:利用过期时间,过期之后投递到DLX ,路由到DLQ,监听DLQ,实现了延迟队列。

消息的流转流程:

生产者-原交换机-原队列(超过TTL之后)——死信交换机——死信队列——最终消费者。


Message消息在什么情况会变成死信?

(1)消息的时间过期

(1)消息被消费者拒绝并且未设置重回队列:(NACK||Reject)&&requeue==false

(2)队列达到最大长度,超过了Max Length(消息数)或者Max Length bytes(字节数) ,最先入队的消息会被发送到DLX。


image.png


3.用插件rabbitmq-delayed-messge-exchange


六,RabbitMQ的流量控制——控制服务端消息数量

服务端限流:


(1)内存控制


image.png


(2)磁盘控制


image.png


消费端限流:


image.png


六,消息可靠性


微信图片_20220128123521.png


1代表消息从生产者发送到Broker? 如何确认?


image.png


Confirm确认模式


image.png


image.png


image.png


image.png

相关实践学习
消息队列RocketMQ版:基础消息收发功能体验
本实验场景介绍消息队列RocketMQ版的基础消息收发功能,涵盖实例创建、Topic、Group资源创建以及消息收发体验等基础功能模块。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
目录
相关文章
|
27天前
|
消息中间件 存储 数据库
深入学习RocketMQ的底层存储设计原理
文章深入探讨了RocketMQ的底层存储设计原理,分析了其如何通过将数据和索引映射到内存、异步刷新磁盘以及消息内容的混合存储来实现高性能的读写操作,从而保证了RocketMQ作为一款低延迟消息队列的读写性能。
|
24天前
|
消息中间件 存储 Java
【揭秘】RocketMQ内部运作大揭秘:一探究竟,原来消息队列是这样工作的!
【8月更文挑战第19天】RocketMQ是一款高性能、高可用的消息中间件,在分布式系统中至关重要。它采用发布/订阅模式,支持高吞吐量的消息传递。核心组件包括管理元数据的NameServer、存储消息的Broker以及Producer和Consumer。RocketMQ支持发布/订阅与点对点两种模型,并具备复杂的消息持久化和路由机制。通过Java API示例,可轻松实现消息的发送与接收。RocketMQ凭借其出色的特性和可靠性,成为大型分布式系统首选的消息解决方案。
45 5
|
27天前
|
消息中间件 负载均衡 API
RocketMQ生产者负载均衡(轮询机制)核心原理
文章深入分析了RocketMQ生产者的负载均衡机制,特别是轮询机制的实现原理,揭示了如何通过`ThreadLocal`技术和消息队列的选播策略来确保消息在多个队列之间均衡发送,以及如何通过灵活的API支持自定义负载均衡策略。
|
27天前
|
消息中间件 存储 负载均衡
RocketMQ消费者消费消息核心原理(含长轮询机制)
这篇文章深入探讨了Apache RocketMQ消息队列中消费者消费消息的核心原理,特别是长轮询机制。文章从消费者和Broker的交互流程出发,详细分析了Push和Pull两种消费模式的内部实现,以及它们是如何通过长轮询机制来优化消息消费的效率。文章还对RocketMQ的消费者启动流程、消息拉取请求的发起、Broker端处理消息拉取请求的流程进行了深入的源码分析,并总结了RocketMQ在设计上的优点,如单一职责化和线程池的使用等。
RocketMQ消费者消费消息核心原理(含长轮询机制)
|
27天前
|
消息中间件 存储 RocketMQ
2分钟看懂RocketMQ延迟消息核心原理
本文从源码层面解析了RocketMQ延迟消息的实现原理,包括延迟消息的使用、Broker端处理机制以及定时任务对延迟消息的处理流程。
2分钟看懂RocketMQ延迟消息核心原理
|
27天前
|
消息中间件 存储 缓存
RocketMQ发送消息原理(含事务消息)
本文深入探讨了RocketMQ发送消息的原理,包括生产者端的发送流程、Broker端接收和处理消息的流程,以及事务消息的特殊处理机制,提供了对RocketMQ消息发送机制全面的理解。
RocketMQ发送消息原理(含事务消息)
|
1月前
|
消息中间件 存储 缓存
一个用过消息队列的人,竟不知为何要用 MQ?
一个用过消息队列的人,竟不知为何要用 MQ?
64 1
|
27天前
|
消息中间件 网络架构
RabbitMQ消息队列常见面试题
这篇文章总结了RabbitMQ的常见面试题,涵盖了消息模型、使用场景、实现功能、消息幂等性、顺序性、堆积和丢失的避免方法,以及推模式和拉模式的区别。
38 0
|
28天前
|
消息中间件 Kafka Apache
RocketMQ - 生产者原理
RocketMQ - 生产者原理
25 0
|
28天前
|
消息中间件 Java Kafka
MQ 消息队列 比较
MQ 消息队列 比较
28 0

相关产品

  • 云消息队列 MQ