526互联

RabbitMQ 延迟消息的实现——死信交换机（不推荐）

发布时间 2023-12-04 15:56:59作者: 嘎嘎鸭2

 

生产者给MQ发送 带过期时间的消息：

@GetMapping("/mq07")
public void sendTTLMessage(){
    //第四个参数：后置消息处理器。用后置消息处理器给消息加过期时间
    rabbitTemplate.convertAndSend("simple.direct", "red", "hello", new MessagePostProcessor() {
        @Override
        public Message postProcessMessage(Message message) throws AmqpException {
            message.getMessageProperties().setExpiration("1000");//1000ms
            return message;
        }
    });
}