配置延时消息

消息队列 RabbitMQ 版文档中心入门中心API 中心SDK 中心文档活动我的反馈文档反馈官招募中，报名立赚积分兑换代金券！> HOT文档中心>消息队列 RabbitMQ 版>操作指南>管理消息>配置延时消息配置延时消息最近更新时间：2025-12-04 17:58:52

微信扫一扫QQ新浪微博复制链接链接复制成功我的收藏本页目录：名词解释使用场景实现方式本文主要介绍消息队列 TDMQ RabbitMQ 版中延迟消息的概念、使用场景和实现方式。名词解释延时消息：消息在发送至服务端后，实际业务并不希望消费端马上收到这条消息，而是推迟一段时间后再被消费，这类消息统称为延时消息。使用场景场景 1：对于消息的生产消费时间有要求的场景。例如在电商系统中，若用户下单后 30 分钟不支付，自动取消订单。场景 2：通过消息触发延时任务的场景。用户登录 App 浏览特定商品 20 分钟后还没下单，自动推送商品评测信息的消息并发放商品相关优惠券。实现方式托管版集群Serverless 版集群约束与限制下方实现方式二中，开源托管版集群的延时消息能力需要依赖 rabbitmq_delayed_message_exchange 插件，请先在插件管理页面打开插件，具体请见管理插件。延时消息的时间值必须为非负整数，单位为毫秒。如果您的延时消息设置了消息存活时间，则 延时消息的实际存活时间 = min{消息存活时间, Queue存活时间} + 延时时间。 使用方式方式一：通过设置消息的过期时间和死信队列实现延时消息原理概述发送端通过设置消息过期时间，触发过期未消费的消息被投递到死信交换机下的死信队列。消费端通过消费死信队列中的消息，实现延时消息的消费。使用示例代码仅示例使用，交换机类型、routingKey 等参数请结合实际场景替换为业务预期的值。发送端代码示例如下，消费端订阅死信队列即可。// 声明死信交换机channel.exchangeDeclare("${dlxExchangeName}", "direct", true);// 声明用于发送延时消息的交换机channel.exchangeDeclare("${delayExchangeName}", "direct", true);// 声明用于发送延时消息的队列，并指定其死信交换机Map args = new HashMap<>();args.put("x-dead-letter-exchange", "${dlxExchangeName}");channel.queueDeclare("${delayQueueName}", true, false, false, args);channel.queueBind("${delayQueueName}", "${delayExchangeName}", "");// 声明死信队列channel.queueDeclare("${delayQueueName}", true, false, false, null);channel.queueBind("${dlxQueueName}", "${dlxExchangeName}", "");// 发送延时消息int delayInSeconds = 10; // 消息延时 10sAMQP.BasicProperties props = new AMQP.BasicProperties.Builder().expiration(String.valueOf(delayInSeconds * 1000));channel.basicPublish("${delayExchangeName}", "", props.build(), "delayed payload".getBytes());参数说明如下参数说明${dlxExchangeName}用于延迟消息的死信交换机名称，请替换为可在控制台 Exchange 列表查询到的名称。${delayExchangeName}实际发送延时消息的交换机名称，请替换为可在控制台 Exchange 列表查询到的名称。x-dead-letter-exchange队列参数 key，用于设置其对应的死信交换机。${dlxQueueName}用于延迟消息的死信队列名称${delayQueueName}实际发送延时消息的队列名称方式二：通过内置的 rabbitmq_delayed_message_exchange 插件实现延时消息使用限制说明：更多详细信息请参考 RabbitMQ 官方插件使用限制说明。当前插件的设计不适用于大量延迟消息（未调度的消息达数十万甚至数百万条）的场景，生产环境请谨慎评估消息量级，避免非预期的长时间延迟、消息丢失等问题。延时消息在每个节点上只有一个持久化副本，如果节点无法正常运行（例如由于消息堆积导致持续 OOM 后重启且无法恢复），则该节点上的延时消息无法被消费端消费。延时交换机不支持设置 mandatory ，生产者无法通过 basic.return 事件感知到无法路由的消息，因此发送延时消息前请务必保证对应的交换机、队列、路由关系存在。综上所述，我们强烈建议您不要使用这一插件，转而使用死信队列来间接实现延时消息。如果您在了解了这个插件的若干缺陷后仍然要使用，那我们强烈推荐您将延迟消息数量保持在一个尽可能低的水平，避免触发内存负载高的问题。使用示例TDMQ RabbitMQ 版延时消息的使用方式和 RabbitMQ 官方支持的延时插件的使用方式完全一致，方便业务进行无改造迁移。收发消息示例可以参考使用 SDK 收发消息，延时消息的相关改造可以参考下方示例：1. 声明 Exchange 并指定 Exchange 的路由类型。// 声明延时交换机Map args = new HashMap();args.put("x-delayed-type", "direct");channel.exchangeDeclare("${delayedExchangeName}", "x-delayed-message", true, false, args);参数说明如下：参数说明x-delayed-typeExchange 的类型，指定路由规则。取值说明如下：directfanouttopic具体说明请参见 Exchange。${delayedExchangeName}Exchange 的名称，请替换为可在控制台 Exchange 列表查询到的名称。x-delayed-message指定 Exchange 类型，以支持投递延时消息。2. 发送延时消息。在消息的 Header 属性中增加一个键为 x-delay，值为毫秒数的键值对，并且指定发送的目标 Exchange 为上一步已声明的 Exchange。byte[] messageBodyBytes = "delayed payload".getBytes("UTF-8");Map headers = new HashMap();headers.put("x-delay", 4000); // 消息延时 4sAMQP.BasicProperties.Builder props = new AMQP.BasicProperties.Builder().headers(headers);channel.basicPublish("${delayedExchangeName}", "", props.build(), messageBodyBytes);当消息到达 Exchange 后，会在4000毫秒后投递到对应的 Queue。约束与限制Serverless 集群支持延时消息，且不需要依赖打开开源延时消息插件。延时消息的时间值必须为非负整数，单位为毫秒。如果您的延时消息设置了消息存活时间，则 延时消息的实际存活时间 = min{消息存活时间, Queue存活时间} + 延时时间。 Serverless版集群的最大延时时间限制，请见使用限制。具体限制场景如下：消息只设置了延时时间，没有设置存活时间，且延时时间 > 集群最大延时时间限制，则消息会被当作普通消息处理，即消息生产后会被立即投递给消费者消费。消息设置了存活时间，且延时消息的实际存活时间 > 集群最大延时时间限制，则客户端会收到连接断开的报错，消息会生产失败。使用方式步骤生产消息时，在消息 header 属性中增加 X-delay 键，值为消息的延时时间（单位：毫秒）。示例byte[] messageBodyBytes = "delayed message".getBytes("UTF-8"); //定义消息主体Map headers = new HashMap(); //创建Map集合，存储消息的自定义Header信息headers.put("x-delay", 1000); //向Header添加延时消息键值对，指定消息的延时时间为1000毫秒。AMQP.BasicProperties.Builder props = new AMQP.BasicProperties.Builder().headers(headers); //将Header信息设置到消息属性中channel.basicPublish("ExchangeName", "Routing Key", props.build(), messageBodyBytes); //把消息发送到指定的Exchange上一篇: 查询消息下一篇: 配置死信消息Copyright © 2013-2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有深圳市腾讯计算机系统有限公司ICP备案/许可证号：粤B2-20090059粤公网安备44030502008569号腾讯云计算（北京）有限责任公司京ICP证150476号 | 京ICP备11018762号中国站中文International文档“捉虫”活动检视指定产品文档，发现和反馈有效问题，奖！API专项"捉虫"反馈API文档问题，代金券、周边好礼奖不停！文档建议，你提了吗快来使用腾讯云产品文档，提出有效建议，奖！在线咨询目录返回顶部