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一站式入门使用
从源码编译、部署broker、部署namesrv,使用java客户端首发消息等一站式入门RocketMQ。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
目录
相关文章
|
9天前
|
消息中间件 存储 网络协议
手写消息队列(基于RabbitMQ)
手写消息队列(基于RabbitMQ)
|
15天前
|
消息中间件 数据采集 Serverless
云消息队列 RocketMQ 版-消息集成-概述
消息集成是助力企业数字化转型的全栈式消息与数据集成平台,简化流程,支持云上云下、跨区域集成。它提供低代码的事件流服务,具备数据源集成、数据清洗、Serverless自定义处理等功能,支持丰富的数据源和跨端连接。然而,使用时存在如单个任务数据限制、任务名称长度等约束。消息流入(Source)负责从各种数据源获取数据,消息流出(Sink)将数据分发到目标,数据处理(Transform)允许数据转换和分析,而任务(Task)则结合这些组件执行实际的集成操作。
31 3
|
23天前
|
消息中间件 存储 运维
为什么选择云消息队列 RocketMQ 版
为什么选择云消息队列 RocketMQ 版
23 1
|
23天前
|
消息中间件 存储 运维
深入理解MQ消息队列的高可用与可靠性策略
深入理解MQ消息队列的高可用与可靠性策略
1011 3
|
23天前
|
消息中间件 存储 传感器
Kafka消息队列原理及应用详解
【5月更文挑战第6天】Apache Kafka是高性能的分布式消息队列,常用于实时数据管道和流应用。它提供高性能、持久化、分布式和可伸缩的消息处理,支持解耦、异步通信和流量控制。Kafka的核心概念包括Broker、Topic、Partition、Producer、Consumer和Consumer Group。其特点是高吞吐、低延迟、数据持久化、分布式架构和容错性。常见应用包括实时数据流处理、日志收集、消息传递和系统间数据交换。
|
23天前
|
消息中间件 大数据 Java
消息队列 MQ
消息队列 MQ
41 3
|
23天前
|
消息中间件 存储 监控
RabbitMQ:分布式系统中的高效消息队列
RabbitMQ:分布式系统中的高效消息队列
|
23天前
|
消息中间件 分布式计算 监控
Python面试:消息队列(RabbitMQ、Kafka)基础知识与应用
【4月更文挑战第18天】本文探讨了Python面试中RabbitMQ与Kafka的常见问题和易错点,包括两者的基础概念、特性对比、Python客户端使用、消息队列应用场景及消息可靠性保证。重点讲解了消息丢失与重复的避免策略,并提供了实战代码示例,帮助读者提升在分布式系统中使用消息队列的能力。
48 2
|
23天前
|
消息中间件 Java
springboot整合消息队列——RabbitMQ
springboot整合消息队列——RabbitMQ
88 0
|
23天前
|
消息中间件 JSON Java
RabbitMQ消息队列
RabbitMQ消息队列
48 0

热门文章

最新文章

相关产品

  • 云消息队列 MQ