RabbitMQ 高级 - 过期时间 TTL

概述

过期时间 TTL 表示可以对消息设置预期的时间，在这个时间内都可以被消费者接收获取；过期后自动被删除；RabbitMQ 可以对消息和队列 设置 TTL。目前有两种方法可以设置

第一种方法是通过队列属性的设置，队列中所有消息多有相同的过期时间
第二种方法是对消息单独设置，每条消息 TTL 可以不同
这两种方式的区别在于通过队列属性设置的消息是移到死信队列中，而单独消息设置 TTL 是消息自动消失。

如果上述两种方法同时使用，则消息的过期时间可以两者之间 TTL 较小的哪个数值为准。消息在队列的生存时间一旦超过设置的 TTL 值，就称为 dead message 被投递到死信队列，消费者将无法再收到该消息。

设置队列 TTL

配置类配置如下

@Configuration
public class TTLRabbitMqConfiguration {
    @Bean
    public DirectExchange ttlDirectExchange() {
        return new DirectExchange("ttl_direct_order_exchange",true,false);
    }

    @Bean
    public Queue directTtlQueue() {
        // 设置过期时间
        HashMap<String, Object> args = new HashMap<>();
        args.put("x-message-ttl",5000); // 这里一定是一个int类型
        return new Queue("ttl.direct.queue",true,false,false,args);
    }

    @Bean
    public Binding ttlBinding() {
        return BindingBuilder.bind(directTtlQueue()).to(ttlDirectExchange()).with("ttl");
    }
}


public void makeOrderTtl(String userId,String productId,int num) {
  // 1:根据id查询商品是否充足
  // 2:保存订单
  String orderId = UUID.randomUUID().toString();
  System.out.println("订单生成成功："+orderId);
  // 3:通过 MQ 来完成消息的分发
  // 交换机，路由 key/queue 队列名称，消息内容
  String exchangeName = "ttl_direct_order_exchange";
  String routingKey = "ttl";
  rabbitTemplate.convertAndSend(exchangeName,routingKey,orderId);
}

测试代码

@Test
void testOrderTtl() {
    orderService.makeOrderTtl("1","1",12);
}

五秒过后数据自动消失

消息设置过期时间

config 配置代码

@Configuration
public class TTLRabbitMqConfiguration {
    @Bean
    public DirectExchange ttlDirectExchange() {
        return new DirectExchange("ttl_direct_order_exchange",true,false);
    }

    @Bean
    public Queue directTtlQueue() {
        // 设置过期时间
        HashMap<String, Object> args = new HashMap<>();
        args.put("x-message-ttl",5000); // 这里一定是一个int类型
        return new Queue("ttl.direct.queue",true,false,false,args);
    }

    @Bean
    public Queue directTtlMessageQueue() {
        return new Queue("ttl.message.direct.queue",true);
    }

    @Bean
    public Binding ttlBinding() {
        return BindingBuilder.bind(directTtlMessageQueue()).to(ttlDirectExchange()).with("ttlMessage");
    }

}

测试代码

public void makeOrderTtlMessage(String userId,String productId,int num) {
        // 1:根据id查询商品是否充足
        // 2:保存订单
        String orderId = UUID.randomUUID().toString();
        System.out.println("订单生成成功："+orderId);
        // 3:通过 MQ 来完成消息的分发
        // 交换机，路由 key/queue 队列名称，消息内容
        String exchangeName = "ttl_direct_order_exchange";
        String routingKey = "ttlMessage";
        // 给消息设置过期时间
        MessagePostProcessor messagePostProcessor = new MessagePostProcessor() {
            @Override
            public Message postProcessMessage(Message message) throws AmqpException {
                // 设置过期时间
                message.getMessageProperties().setExpiration("5000");
                message.getMessageProperties().setContentEncoding("UTF-8");
                return message;
            }
        };
        rabbitTemplate.convertAndSend(exchangeName,routingKey,orderId,messagePostProcessor);
    }

@Test
void testOrderTtlMessage() {
  orderService.makeOrderTtlMessage("1","1",12);
}

五秒之后消息自动过期消失

总结

如果既设置了消息ttl，又设置了队列 ttl，是以最短时间为准。队列 ttl 对比 消息 ttl 优势在于，之后会有死信队列队列，将这些过期的消息发送到死信队列。

本作品采用《CC 协议》，转载必须注明作者和本文链接