文档首页/ 分布式消息服务RabbitMQ版/ 用户指南 (阿布扎比区域)/ 配置高级特性/ 配置RabbitMQ TTL
更新时间：2024-10-29 GMT+08:00
查看PDF
分享

配置RabbitMQ TTL

TTL（Time To Live）即过期时间。消息在队列中的生存时间超过了TTL后，消息会被丢弃，如果队列设置了死信交换机，丢弃的消息会被转发到死信交换机，由死信交换机将其路由到死信队列。更多关于TTL的说明，请参考TTL。

RabbitMQ支持设置消息和队列的TTL，消息的TTL可以通过以下两种方法设置：

  • 通过队列属性设置：队列中所有消息的具有相同的过期时间。
  • 对消息本身单独设置：每条消息可以设置不同的TTL。

如果两种方法同时使用，以较小的TTL为准。

TTL是RabbitMQ中需要慎用的特性，它可能会对性能产生负面影响。

设置队列TTL

通过channel.queueDeclare方法中的“x-expires”参数控制队列被自动删除前处于未使用状态的时间。未使用是指队列中没有任何消费者，也没有被重新声明，并且在过期时间前也未调用过Basic.Get命令。“x-expires”参数的值必须为非零整数，单位为毫秒。

以下示例演示在Java客户端设置队列TTL。

Map<String, Object> args = new HashMap<String, Object>();
args.put("x-expires", 1800000);   //设置队列TTL为1800000毫秒
channel.queueDeclare("myqueue", false, false, false, args);

设置消息TTL

  • 通过队列属性设置消息TTL：

    在channel.queueDeclare方法中加入“x-message-ttl”参数，此参数的值必须为非零整数，单位为毫秒。

    以下示例演示在Java客户端通过队列属性设置消息TTL。

    Map<String,Object> arg = new HashMap<String, Object>();
arg.put("x-message-ttl",6000);   //设置队列的消息TTL为6000毫秒
channel.queueDeclare("normalQueue",true,false,false,arg);
  • 对消息本身单独设置TTL：

    在channel.basicPublish方法中加入“expiration”参数，此参数的值必须为非零整数，单位为毫秒。

    以下示例演示在Java客户端对消息本身单独设置TTL。

    byte[] messageBodyBytes = "Hello, world!".getBytes();
AMQP.BasicProperties properties = new AMQP.BasicProperties.Builder()
                                   .expiration("60000")   //设置消息的TTL为60000毫秒
                                   .build();
channel.basicPublish("my-exchange", "routing-key", properties, messageBodyBytes);
父主题： 配置高级特性