过期时间TTL表示可以对消息设置预期的时间，在这个时间内都可以被消费者接收获取；过了之后消息将自动被删除。RabbitMQ可以对消息和队列设置TTL。目前有两种方法可以设置。
- 第一种方法是通过队列属性设置，队列中所有消息都有相同的过期时间。
- 第二种方法是对消息进行单独设置，每条消息TTL可以不同。
注意：
如果上述两种方法同时使用，则消息的过期时间以两者之间TTL较小的那个数值为准。消息在队列的生存时间一旦超过设置的TTL值，就称为dead message被投递到死信队列， 消费者将无法再收到该消息。
界面具体设置如下图所示：
1.2.TTL简单实现
①基于队列属性进行设置：
www.hontupt2.cn
www.xingqipt.cn
www.xinwus2zc.cn
www.fengtengpt.cc
这里在springBoot-order-rabbitmq-producer项目中config目录新建一个TTLRabbitMqConfiguration，声明ttl交换机与ttlQueue，代码如下：
@Configuration
public class TTLRabbitMqConfiguration {
//声明交换机，不同的交换机类型不同：DirectExchange/FanoutExchange/TopicExchange/HeadersExchange
@Bean
public DirectExchange ttldirectOrderExchange() {
return new DirectExchange("ttl_direct_exchange", true, false);
}
//定义队列的过期时间
@Bean
public Queue directttlQueue() {
Map<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 ttlBingding(){
return BindingBuilder.bind(directttlQueue()).to(ttldirectOrderExchange()).with("ttl");
}
}在OrderService中进行消息发送至消息队列：
@Service
public class OrderService {
@Autowired
private RabbitTemplate rabbitTemplate;
// 1: 定义交换机
private String exchangeName = "";
// 2: 路由key
private String routeKey = "";
//ttl--死信队列
public void makeOrderTTLQueue(Long userId, Long productId, int num) {
exchangeName = "ttl_direct_exchange";
routeKey = "ttl";
// 1： 模拟用户下单
String orderNumer = UUID.randomUUID().toString();
// 2: 根据商品id productId 去查询商品的库存
// int numstore = productSerivce.getProductNum(productId);
// 3:判断库存是否充足
// if(num > numstore ){ return "商品库存不足..."; }
// 4: 下单逻辑
// orderService.saveOrder(order);
// 5: 下单成功要扣减库存
// 6: 下单完成以后
System.out.println("用户 " userId ",订单编号是：" orderNumer);
// 发送订单信息给RabbitMQ fanout
rabbitTemplate.convertAndSend www.jintianxuesha.com/ exchangeName, routeKey, orderNumer);
}
}进行测试：
@SpringBootTest
class RabbitmqApplicationTests {
@Autowired
private OrderService orderService;
@Test
void ttlQueueTest() throws InterruptedException {
for (int i = 0; i < 5; i ) {
Thread.sleep(1000);
Long userId = 100L i;
Long productId = 10001L i;
int num = 1;
orderService.makeOrderTTLQueue(userId, productId, num);
}
}
}可以看到消息向队列中发送，但是5s之后消息会自动从队列中移除，这就是TTL消息过期移除。
②基于某个消息发送时单独设置过期时间：
这种方式不需要在队列与交换机绑定时设置Queue过期属性，只需要声明为普通队列即可。
@Configuration
public class TTLRabbitMqConfiguration {
//声明交换机，不同的交换机类型不同：DirectExchange/FanoutExchange/TopicExchange/HeadersExchange
@Bean
public DirectExchange ttldirectOrderExchange() {
return new DirectExchange("ttl_direct_exchange", true, false);
}
//定义队列的过期时间 --定义一个普通队列，在外面设置过期时间
@Bean
public Queue directttlMessageQueue() {
return new Queue("ttl.message.direct.queue", true, false, false);
}
@Bean
public Binding ttlMsgBingding(){
return BindingBuilder.bind(directttlMessageQueue()).to(ttldirectOrderExchange()).with("ttlmsg");
}
}在发送时进行单独消息过期时间属性设置：
@Service
public class OrderService {
@Autowired
private RabbitTemplate rabbitTemplate;
// 1: 定义交换机
private String exchangeName = "";
// 2: 路由key
private String routeKey = "";
//ttl--死信队列--普通队列设置
public void makeOrderTTLMsgQueue(Long userId, Long productId, int num) {
exchangeName = "ttl_direct_exchange";
routeKey = "ttlmsg";
String orderNumer = UUID.randomUUID().toString();
System.out.println("用户 " userId ",订单编号是：" orderNumer);
//给消息设置过期时间
MessagePostProcessor postProcessor = new MessagePostProcessor() {
@Override
public Message postProcessMessage(Message message) throws AmqpException {
message.getMessageProperties().setExpiration("5000"); //时间为5s
message.getMessageProperties().setContentEncoding("UTF-8");
return message;
}
};
// 发送订单信息给RabbitMQ fanout，指定消息的扩展信息
rabbitTemplate.convertAndSend(exchangeName, routeKey, orderNumer, postProcessor);
}
