消息队列MQ

RabbitMQ死信队列设置

本文主要是介绍RabbitMQ死信队列设置，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

死信消息：

  • 消息被拒绝（Basic.Reject或Basic.Nack）并且设置 requeue 参数的值为 false
  • 消息过期了
  • 队列达到最大的长度

设置死信队列
在RabbitMQ控制台的Queues设置
在这里插入图片描述
在这里插入图片描述
创建交换机，并绑定死信队列设置的路由
设置过期时间

  • 队列设置：在队列申明的时候使用 x-message-ttl 参数，单位为 毫秒
  • 单个消息设置：是设置消息属性的 expiration 参数的值，单位为 毫秒

监听死信队列

@RabbitListener(queues = "my.direct.queue.dlx.queue")
public void handleMessage(Message message){
        System.out.println("====消费消息===handleMessage(message)");
        System.out.println(message.getMessageProperties());
        System.out.println(new String(message.getBody()));
}
这篇关于RabbitMQ死信队列设置的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！
您可能喜欢
栏目导航