队列设置过期时间
@Configuration
public class TTLRabbitmqConfiguration {
@Bean
public DirectExchange ttlDirectExchange(){
return new DirectExchange("ttl_order_exchange",true,false);
}
@Bean
public Queue directTTLQueue(){
Map<String,Object> map = new HashMap<>();
map.put("x-message-ttl",5000);
return new Queue("ttl.direct.queue",true,false,false,map);
}
@Bean
public Binding directTTLBinding(){
return BindingBuilder.bind(directTTLQueue()).to(ttlDirectExchange()).with("ttl");
}
}
@Test
void contextLoads3() {
orderService.makeOrderTTL("1","1",12);
}

- 打开rabbitmq
可以看到ttl的队列已经生成,点进去队列可以看到Details中关于ttl过期时间的设置,然后再5s之后,该条消息自动消失



具体的消息设置过期时间
@Configuration
public class TTLRabbitmqConfiguration {
@Bean
public DirectExchange ttlDirectExchange(){
return new DirectExchange("ttl_order_exchange",true,false);
}
@Bean
public Queue directTTLQueue(){
Map<String,Object> map = new HashMap<>();
map.put("x-message-ttl",5000);
return new Queue("ttl.direct.queue",true,false,false,map);
}
@Bean
public Queue directTTLMessageQueue(){
return new Queue("ttl.message.direct.queue",true);
}
@Bean
public Binding directTTLBinding(){
return BindingBuilder.bind(directTTLQueue()).to(ttlDirectExchange()).with("ttl");
}
@Bean
public Binding directMsgBinding(){
return BindingBuilder.bind(directTTLMessageQueue()).to(ttlDirectExchange()).with("ttlmessage");
}
}
public void makeOrderMessageTTL(String userId,String productId,int num){
String orderId = UUID.randomUUID().toString();
System.out.println("订单生成成功:" + orderId);
String exchangeName = "ttl_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 contextLoads4() {
orderService.makeOrderMessageTTL("1","1",12);
}

- 打开rabbitmq服务,可以看到队列生成,以及消息产生

- 5s后,消息自动消失,即移除
