一、前言 在前面我们通过以下章节对RocketMQ有了基础的了解: docker-compose 搭建RocketMQ 5.1.0 集群(双主双从模式) | Spring Cloud ...
一、死信队列 1.1 相关概念 死信,顾名思义就是无法被消费的消息,字面意思可以这样理解,一般来说,producer 将消息投递到 broker...
文章目录 一、消息确认机制 🎉1.1 消息发送确认(生产者) 🔹confirm 确认模式 🔹return 回退模式 🚩1.2 消息接收确认...
1、扫表轮循 定时任务 => 获取数据 => 数据层 => 筛选出过期的数据 => 批量关闭超时订单 优点:实现简单、适用于小...
正常的Rabbitmq流程是生产者把消息先到交换机,交换机分发到队列,然后消费者从队列中取出消息 死信交换机就是给消息设置过期时间TTL,然后将正常的队列绑定死...
一、消息可靠投递 生产端的 在使用 RabbitMQ的时候,作为消息发送方希望杜绝任何消息丢失或者投递失败场景。 RabbitMQ 为我们提供了两种方式用来控制...
目录 一、死信队列 1.过期时间代码实现 2.长度限制代码实现 3.测试消息拒收 4.死信队列小结 二、延迟队列 1.代码实现 1.1 生产者 1.2 生产者 ...
这篇文章,主要介绍消息队列RabbitMQ之死信队列。 目录 一、RabbitMQ死信队列 1.1、什么是死信队列 1.2、设置过期时间TTL 1.3、配置死信交换机和死...