浅谈RabbitMQ的延迟队列-CSDN博客

Part 01、  延迟队列是什么 

延迟队列代表了一种强大的消息传递机制允许我们在将消息发送至RabbitMQ时规定它们只能在未来某个预定的时间点被消费。这种特殊类型的消息被简称为"延迟消息"。

以RabbitMQ为例它允许我们通过延迟队列实现这种消息的延迟传递和消费。通过将消息放入延迟队列我们可以确保消息在特定时间之后才会被传递给消费者从而实现了对消息传递的精确控制。这对于构建高效的异步任务调度、定时提醒和实现时间敏感性业务逻辑非常有价值。

Part 02、延迟队列的实现 

延迟队列的实现原理实际上是将消息投递到一个普通队列中不过该队列具有一项特殊属性消息的消费被推迟了一段时间。这个延迟时间可以是灵活设定的也可以是固定的。一旦消息进入队列一个定时器开始计时一旦计时器到达设定的时间消息就会被移送到等待消费的队列中准备被消费。在RabbitMQ中提供了x-delayed-message插件为开发者快速实现延迟队列主要包含以下几步

1.安装插件 确保安装了 RabbitMQ。然后通过执行命令安装并启用 x-delayed-message 插件

代码段

rabbitmq-plugins enable rabbitmq_delayed_message_exchange

2.创建交换器 使用 x-delayed-message 插件创建一个延迟交换器Delayed Message Exchange。这个交换器将用于处理延迟消息。

代码段

rabbitmqadmin declare exchange name=delayed_exchange type=x-delayed-message arguments='{"x-delayed-type":"direct"}'

3.发送延迟消息 当需要发送延迟消息时将消息发送到刚创建的延迟交换器并设置消息的延迟时间。这可以通过在消息头中添加 x-delayed-message 属性来实现。

代码段

AMQP.BasicProperties.Builder builder = new AMQP.BasicProperties.Builder();
builder.deliveryMode(2);
builder.headers(new HashMap<String, Object>(){{put("x-delay", 1000);}});
AMQP.BasicProperties properties = builder.build();
channel.basicPublish("delayed_exchange", "delayed_routing_key", properties, message.getBytes());

4.创建队列和绑定 创建一个普通的队列并将其绑定到延迟交换器上。这样延迟交换器会根据消息的延迟时间将消息传递给队列。

代码段

# 创建普通队列
rabbitmqadmin declare queue name=delayed_queue
# 将队列绑定到延迟交换器
rabbitmqadmin declare binding source=delayed_exchange destination_type=queue destination=delayed_queue routing_key=delayed_queu

5.消费消息 启动一个消费者来从队列中获取延迟消息。一旦延迟时间过去消息会被传递给消费者。

代码段

channel.exchangeDeclare("delayed_exchange", "x-delayed-message", true, false, arguments);
channel.queueDeclare("delayed_queue", true, false, false, null);
channel.queueBind("delayed_queue", "delayed_exchange", "delayed_routing_key");
channel.basicConsume(queue=queue_name, on_message_callback=callback, auto_ack=True)
channel.startConsuming()

总的来说x-delayed-message 插件使得在 RabbitMQ 中实现延迟队列变得更加直观和方便它允许将消息的延迟时间嵌入消息本身无需使用TTL和死信队列来处理延迟消息。

Part 03、延迟队列的应用场景 

延迟队列在现代分布式系统中具有广泛的应用场景下面列举了一些常见的应用场景

1.红包定时抢夺在红包抢夺场景中用户发起红包活动后可能希望在一段时间后才开始抢夺而非立即开启。在这种情况下我们可以将红包信息发送至一个延迟队列。经过预定时间后系统会自动触发红包的开启这时用户才能实际参与抢红包活动。这种方式能够更好地掌控红包活动的时间为用户提供更灵活的体验。

图1红包定时抢夺流程

2.商品预售在商品预售流程中订单需要在未来特定时间点进行处理如在一段时间后才能进行发货。在这种情况下我们可以将这类订单置于延迟队列中待预定时间一到再进行相应的处理操作。这种方法能够有效地处理那些需要时机掌握的订单确保在合适的时间点完成相应的任务。

图2商品预售发货流程

3.优惠券定时生效在优惠券管理系统中存在一些优惠券需要在未来特定时间点才能生效。在这种情况下我们可以将这些待激活的优惠券置于延迟队列中待预定时间到达时再进行激活处理。通过这种方式我们能够灵活地控制优惠券的生效时间确保在合适的时机为用户提供优惠服务。

图3优惠券生效流程

Part 04、 延迟队列的注意事项  

1.延迟队列不要使用太多使用延迟队列可以在一定程度上减少系统的负载但是使用过多的延迟队列会导致系统变得更加复杂维护起来也更加困难。

2.延迟队列可能会导致消息丢失在RabbitMQ中当一个带有TTL消息被发送到队列中时如果队列中的消息太多或者队列的消费者速度太慢就会导致消息失效如果没有使用死信机制消息就会被丢失。为了避免这种情况发生我们需要对队列进行监控及时发现问题并进行处理。

3.设置合适的延迟时间在使用延迟队列时需要根据实际需求设置合适的延迟时间。如果延迟时间太短可能会导致消息延迟效果不明显如果延迟时间太长可能会导致系统累积大量的消息导致负载过高。

Part 05、 总结 

RabbitMQ的延迟队列是一项极具实用性的功能能够协助我们有效实现定时任务、流量控制以及峰值平滑等关键功能。然而在利用延迟队列时必须以谨慎态度对待。必须根据具体需求来设定延迟时间并且要时刻监测队列内的消息以避免可能的消息丢失情况。希望今天的技术分享能为大家带来启发。

最后推荐一款应用开发神器

关于目前低代码在技术领域很活跃

低代码是什么一组数字技术工具平台能基于图形化拖拽、参数化配置等更为高效的方式实现快速构建、数据编排、连接生态、中台服务等。通过少量代码或不用代码实现数字化转型中的场景应用创新。它能缓解甚至解决庞大的市场需求与传统的开发生产力引发的供需关系矛盾问题是数字化转型过程中降本增效趋势下的产物。

这边介绍一款好用的低代码平台——JNPF快速开发平台。近年在市场表现和产品竞争力方面表现较为突出采用的是最新主流前后分离框架SpringBoot+Mybatis-plus+Ant-Design+Vue3。代码生成器依赖性低灵活的扩展能力可灵活实现二次开发。

以JNPF为代表的企业级低代码平台为了支撑更高技术要求的应用开发从数据库建模、Web API构建到页面设计与传统软件开发几乎没有差异只是通过低代码可视化模式减少了构建“增删改查”功能的重复劳动还没有了解过低代码的伙伴可以尝试了解一下。

应用https://www.jnpfsoft.com/?csdn

有了它开发人员在开发过程中就可以轻松上手充分利用传统开发模式下积累的经验。所以低代码平台对于程序员来说有着很大帮助。