SpringCloud Stream 整合 RabbitMQ-DLQ队列(2)

﹏ヽ暗。殇╰゛Y 2023-06-27 08:46 13阅读 0赞

前几篇介绍了SpringCloud Stream整合RabbitMQ、消费失败后重试maxAttempts属性、死信队列(DLQ队列)

*  [SpringCloud Stream 整合RabbitMQ][SpringCloud Stream _RabbitMQ]
 *  [SpringCloud Stream 整合 RabbitMQ-消费失败后重试][SpringCloud Stream _ RabbitMQ-]
 *  [SpringCloud Stream 整合 RabbitMQ-DLQ队列][SpringCloud Stream _ RabbitMQ-DLQ]

本篇为了方便消息放入死信队列后排查问题，将异常信息显示在messages列表，将使用republishToDlq

# 一、属性-republishToDlq #

根据SpringCloud官方文档上，RabbitMQ消费者相关属性部分可以找到republishToDlq：  
![在这里插入图片描述][20200105173230788.png]  
可以看到，默认是false,如果设置为true,将会把消息的头信息(包括异常消息和stack trace)一起加入到dlq队列中  
接下来实际试验一下：

# 一、项目 #

本次就接着上次的项目继续使用，项目完整代码：[https://github.com/zrk333/mq-service][https_github.com_zrk333_mq-service]

# 二、修改消费者 #

#### 1、添加配置 ####

spring.cloud.stream.rabbit.bindings.message-center-input.consumer.republishToDlq=true

#### 2、验证 ####

保留消费方法继续抛异常，重启消费者，并调用生产者发送消息，看dlq队列messages信息：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3_size_16_color_FFFFFF_t_70]  
可以看到新加入的包含了异常等信息，对排查问题解决bug有很大帮助。

# 三、补充 #

**dlqTtl**属性是设置死信队列消息存放时间，默认没有限制，如果设置，可能发生消息丢失

spring.cloud.stream.rabbit.bindings.message-center-input.consumer.dlqTtl=86400000

[SpringCloud Stream _RabbitMQ]: https://blog.csdn.net/qq_21067307/article/details/103839356
[SpringCloud Stream _ RabbitMQ-]: https://blog.csdn.net/qq_21067307/article/details/103843884
[SpringCloud Stream _ RabbitMQ-DLQ]: https://blog.csdn.net/qq_21067307/article/details/103844330
[20200105173230788.png]: https://img-blog.csdnimg.cn/20200105173230788.png
[https_github.com_zrk333_mq-service]: https://github.com/zrk333/mq-service
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200105173938705.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3,size_16,color_FFFFFF,t_70