RabbitMQ 高级特性：消息与队列 TTL 设置详解 | 极客日志

Javajava

RabbitMQ 高级特性：消息与队列 TTL 设置详解

RabbitMQ 的高级特性 TTL（过期时间）。RabbitMQ 支持为消息和队列分别设置 TTL。消息 TTL 在投递前判定，队列 TTL 定期扫描队头。通过 Spring AMQP 示例演示了如何配置交换机、队列及绑定关系。对比发现，当两者同时存在时取最小值；消息级 TTL 不会立即删除过期消息，而队列级 TTL 会直接清理。该机制适用于订单超时取消等场景。

追风少年发布于 2026/3/29更新于 2026/4/183 浏览

RabbitMQ 高级特性：消息与队列 TTL 设置详解

TTL

TTL（Time to Live，过期时间）即过期时间。RabbitMQ 可以对消息和队列设置 TTL。当消息到达存活时间之后，还没有被消费，就会被自动清除。

在业务场景中，例如网上购物下单超过 24 小时未付款订单会自动取消，或申请退款后超过 7 天未被处理则自动退款，均可利用此机制实现。

添加配置

spring:
  application:
    name: rabbit-extensions-demo
  rabbitmq:
    addresses: amqp://study:[email protected]:5672/extension

常量类

public class Constants {
    // ttl
    public static final String TTL_QUEUE = "ttl.queue";
    public static final String TTL_QUEUE2 = "ttl2.queue";
    public static final String TTL_EXCHANGE = "ttl.exchange";
}

消息的 TTL

声明队列和交换机并绑定二者关系

import org.springframework.amqp.core.*;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import rabbitextensionsdemo.constant.Constants;

@Configuration
public   {
    
     Queue  {
         QueueBuilder.durable(Constants.TTL_QUEUE).build();
    }

    
     DirectExchange  {
         ExchangeBuilder.directExchange(Constants.TTL_EXCHANGE).build();
    }

    
     Binding  {
         BindingBuilder.bind(queue).to(exchange).with().noargs();
    }
}

极客日志微信公众号二维码

更多推荐文章

相关免费在线工具

Keycode 信息
查找任何按下的键的javascript键代码、代码、位置和修饰符。在线工具，Keycode 信息在线工具，online
Escape 与 Native 编解码
JavaScript 字符串转义/反转义；Java 风格 \uXXXX（Native2Ascii）编码与解码。在线工具，Escape 与 Native 编解码在线工具，online
JavaScript / HTML 格式化
使用 Prettier 在浏览器内格式化 JavaScript 或 HTML 片段。在线工具，JavaScript / HTML 格式化在线工具，online
JavaScript 压缩与混淆
Terser 压缩、变量名混淆，或 javascript-obfuscator 高强度混淆（体积会增大）。在线工具，JavaScript 压缩与混淆在线工具，online
Base64 字符串编码/解码
将字符串编码和解码为其 Base64 格式表示形式即可。在线工具，Base64 字符串编码/解码在线工具，online
Base64 文件转换器
将字符串、文件或图像转换为其 Base64 表示形式。在线工具，Base64 文件转换器在线工具，online

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import rabbitextensionsdemo.constant.Constants;

@RequestMapping("/producer")
@RestController
public class ProducerController {
    @Resource(name = "rabbitTemplate")
    private RabbitTemplate rabbitTemplate;

    @RequestMapping("/ttl")
    public String ttl() {
        System.out.println("ttl...");
        rabbitTemplate.convertAndSend(Constants.TTL_EXCHANGE, "ttl", "ttl test 30s...", message -> {
            message.getMessageProperties().setExpiration("30000"); // 单位：毫秒，过期时间为 30s
            return message;
        });
        rabbitTemplate.convertAndSend(Constants.TTL_EXCHANGE, "ttl", "ttl test 10s...", message -> {
            message.getMessageProperties().setExpiration("10000"); // 单位：毫秒，过期时间为 10s
            return message;
        });
        return "消息发送成功";
    }
}

import org.springframework.amqp.core.*;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import rabbitextensionsdemo.constant.Constants;

@Configuration
public class RabbitMQConfig {
    @Bean("ttlQueue2")
    public Queue ttlQueue2() {
        return QueueBuilder.durable(Constants.TTL_QUEUE2).ttl(20000).build(); // 设置队列的 ttl 为 20s
    }

    @Bean("ttlExchange")
    public DirectExchange ttlExchange() {
        return ExchangeBuilder.directExchange(Constants.TTL_EXCHANGE).build();
    }

    @Bean("ttlBinding2")
    public Binding ttlBinding2(@Qualifier("ttlQueue2") Queue queue, @Qualifier("ttlExchange") Exchange exchange) {
        return BindingBuilder.bind(queue).to(exchange).with("ttl").noargs();
    }
}

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import rabbitextensionsdemo.constant.Constants;

@RequestMapping("/producer")
@RestController
public class ProducerController {
    @Resource(name = "rabbitTemplate")
    private RabbitTemplate rabbitTemplate;

    @RequestMapping("/ttl")
    public String ttl() {
        System.out.println("ttl...");
        rabbitTemplate.convertAndSend(Constants.TTL_EXCHANGE, "ttl", "ttl test 30s...", message -> {
            message.getMessageProperties().setExpiration("30000"); // 单位：毫秒，过期时间为 30s
            return message;
        });
        return "消息发送成功";
    }

    @RequestMapping("/ttl2")
    public String ttl2() {
        System.out.println("ttl2...");
        // 发送普通消息
        rabbitTemplate.convertAndSend(Constants.TTL_EXCHANGE, "ttl", "ttl test...");
        return "消息发送成功";
    }
}