RabbitMQ 延迟消息实现：两种方案全解析（TTL+死信 / 延迟插件）实战教程

RabbitMQ 延迟消息实现两种方案全解析TTL死信 / 延迟插件实战教程前言一、延迟消息基础认知延迟消息是什么1.1 定义1.2 典型业务场景1.3 延迟消息流程图通用二、RabbitMQ 实现延迟消息的两种方案方案一TTL 死信队列DLX【原生方案无需插件】方案二RabbitMQ Delayed Message Plugin【官方插件更强大】三、方案一TTL 死信队列 实现延迟消息原生3.1 实现原理最经典3.2 完整流程图3.3 SpringBoot 实战代码1. 配置类核心2. 消费者监听死信队列3. 生产者发送消息3.4 优点与缺点四、方案二延迟插件实现官方推荐最灵活4.1 实现原理4.2 插件版流程图4.3 插件安装步骤4.4 SpringBoot 插件版实战代码1. 配置类2. 生产者动态设置延迟时间3. 消费者4.5 优点与缺点五、两种延迟方案对比面试/生产必看六、生产环境最佳实践七、总结延迟消息实现核心总结文末说明The Begin点点关注收藏不迷路前言在实际业务开发中延迟消息是非常高频的需求订单超时未支付自动取消、用户注册30分钟未完善资料提醒、外卖超时自动退款、预约任务定时执行等。RabbitMQ本身不直接提供延迟队列但可以通过两种成熟方案实现延迟消息本文会详细讲解原理、流程图、代码实战、优缺点对比让你在生产环境中快速落地。一、延迟消息基础认知延迟消息是什么1.1 定义延迟消息消息发送后不立即被消费等待指定延迟时间如15分钟后才会被消费者接收并处理。1.2 典型业务场景订单15分钟未支付 → 自动取消红包24小时未领取 → 自动退回预约服务到期提醒超时未评价自动好评外卖超时自动取消1.3 延迟消息流程图通用生产者发送延迟消息等待延迟时间延迟时间结束消息进入可消费队列消费者接收并处理二、RabbitMQ 实现延迟消息的两种方案RabbitMQ 实现延迟消息有两种标准方案方案一TTL 死信队列DLX【原生方案无需插件】方案二RabbitMQ Delayed Message Plugin【官方插件更强大】下面分别详细讲解。三、方案一TTL 死信队列 实现延迟消息原生3.1 实现原理最经典给队列/消息设置TTL 过期时间延迟时间消息过期后变成死信死信被转发到死信队列消费者监听死信队列→ 实现延迟执行3.2 完整流程图发送消息正常队列设置TTL等待TTL延迟时间消息过期 → 成为死信转发到死信交换机DLX进入死信队列DLQ消费者监听死信队列执行逻辑3.3 SpringBoot 实战代码1. 配置类核心ConfigurationpublicclassTtlDlxConfig{// 正常交换机 队列publicstaticfinalStringNORMAL_EXnormal.exchange;publicstaticfinalStringNORMAL_QUEUEnormal.queue;publicstaticfinalStringNORMAL_RKnormal.rk;// 死信交换机 队列publicstaticfinalStringDLX_EXdlx.exchange;publicstaticfinalStringDLX_QUEUEdlx.queue;publicstaticfinalStringDLX_RKdlx.rk;// 正常队列设置TTL死信BeanpublicQueuenormalQueue(){MapString,ObjectargsnewHashMap();args.put(x-message-ttl,10000);// 延迟10秒args.put(x-dead-letter-exchange,DLX_EX);args.put(x-dead-letter-routing-key,DLX_RK);returnnewQueue(NORMAL_QUEUE,true,false,false,args);}BeanpublicDirectExchangenormalExchange(){returnnewDirectExchange(NORMAL_EX);}BeanpublicBindingnormalBinding(){returnBindingBuilder.bind(normalQueue()).to(normalExchange()).with(NORMAL_RK);}// 死信队列 BeanpublicQueuedlxQueue(){returnnewQueue(DLX_QUEUE);}BeanpublicDirectExchangedlxExchange(){returnnewDirectExchange(DLX_EX);}BeanpublicBindingdlxBinding(){returnBindingBuilder.bind(dlxQueue()).to(dlxExchange()).with(DLX_RK);}}2. 消费者监听死信队列ComponentpublicclassDelayConsumer{// 监听死信队列RabbitListener(queuesTtlDlxConfig.DLX_QUEUE)publicvoidreceive(Stringmsg){System.out.println(延迟消息已消费msg);// 执行取消订单、超时任务...}}3. 生产者发送消息ServicepublicclassDelayProducer{AutowiredprivateRabbitTemplaterabbitTemplate;publicvoidsend(Stringmsg){rabbitTemplate.convertAndSend(TtlDlxConfig.NORMAL_EX,TtlDlxConfig.NORMAL_RK,msg);System.out.println(延迟消息已发送);}}3.4 优点与缺点✅优点无需安装插件原生支持稳定可靠适合固定延迟时间业务❌缺点每一种延迟时间都要创建一个队列10s、30s、60s…消息 TTL 存在懒检查问题会导致延迟不准灵活性差四、方案二延迟插件实现官方推荐最灵活4.1 实现原理安装 RabbitMQ 官方延迟消息插件rabbitmq_delayed_message_exchange创建x-delayed-message 类型交换机发送消息时指定x-delay延迟时间插件内部延迟调度时间到后再路由到队列4.2 插件版流程图发送消息携带x-delay延迟交换机插件内部延迟计时时间到 → 路由到队列消费者正常消费4.3 插件安装步骤下载对应版本插件https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/releases放到 RabbitMQ 插件目录plugins启用插件rabbitmq-pluginsenablerabbitmq_delayed_message_exchange重启 RabbitMQ4.4 SpringBoot 插件版实战代码1. 配置类ConfigurationpublicclassPluginDelayConfig{publicstaticfinalStringDELAY_EXplugin.delay.exchange;publicstaticfinalStringDELAY_QUEUEplugin.delay.queue;publicstaticfinalStringDELAY_RKplugin.delay.rk;// 声明延迟交换机关键x-delayed-messageBeanpublicCustomExchangedelayExchange(){MapString,ObjectargsnewHashMap();args.put(x-delayed-type,direct);returnnewCustomExchange(DELAY_EX,x-delayed-message,true,false,args);}BeanpublicQueuedelayQueue(){returnnewQueue(DELAY_QUEUE);}BeanpublicBindingdelayBinding(){returnBindingBuilder.bind(delayQueue()).to(delayExchange()).with(DELAY_RK).noargs();}}2. 生产者动态设置延迟时间ServicepublicclassPluginProducer{AutowiredprivateRabbitTemplaterabbitTemplate;publicvoidsend(Stringmsg,IntegerdelayTime){rabbitTemplate.convertAndSend(PluginDelayConfig.DELAY_EX,PluginDelayConfig.DELAY_RK,msg,message-{// 设置延迟时间毫秒message.getMessageProperties().setDelay(delayTime);returnmessage;});}}3. 消费者ComponentpublicclassPluginConsumer{RabbitListener(queuesPluginDelayConfig.DELAY_QUEUE)publicvoidreceive(Stringmsg){System.out.println(插件版延迟消息消费msg);}}4.5 优点与缺点✅优点一个交换机支持任意延迟时间动态设置延迟无需创建多个队列延迟精准无懒检查问题生产环境首选方案❌缺点需要安装插件旧版 RabbitMQ 不支持五、两种延迟方案对比面试/生产必看方案实现方式灵活性延迟精度生产推荐TTL死信原生低固定时间一般有懒检查简单固定场景延迟插件官方插件极高动态时间精准⭐⭐⭐⭐⭐ 强烈推荐六、生产环境最佳实践动态延迟任务优先使用插件版固定延迟如15分钟订单可使用 TTL死信延迟消息必须持久化避免宕机丢失消费者必须手动ACK保证消息可靠消费延迟时间单位毫秒ms七、总结延迟消息实现核心总结RabbitMQ无原生延迟队列必须通过方案实现方案一TTL 死信队列 → 固定延迟、无需插件方案二延迟消息插件 →动态延迟、精准、推荐使用核心用途订单超时取消、任务定时执行生产环境优先选择延迟插件方案掌握延迟消息你就能解决 RabbitMQ 中90%的超时/定时业务场景文末说明本文属于 RabbitMQ 高级实战核心篇后续将更新消息幂等性、高可用集群、流量削峰、消息堆积排查等内容欢迎点赞、收藏、关注The End点点关注收藏不迷路