SpringCloud Stream 整合 RabbitMQ-DLQ队列

妖狐艹你老母 2023-06-27 08:44 41阅读 0赞

前两篇介绍了SpringCloud Stream整合RabbitMQ、消费失败后重试maxAttempts属性：

*  [SpringCloud Stream 整合RabbitMQ][SpringCloud Stream _RabbitMQ]
 *  [SpringCloud Stream 整合 RabbitMQ-消费失败后重试][SpringCloud Stream _ RabbitMQ-]  
    上篇提到，如果消费者出现代码bug,又没有做额外的拯救措施，又希望消息不丢失且正常消费，这篇将介绍使用死信队列(DLQ队列)进行处理，使代码修复完成后，消息可以正常被消费。

# 一、属性-autoBindDlq #

根据SpringCloud官方文档上，RabbitMQ消费者相关属性部分可以找到autoBindDlq：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3_size_16_color_FFFFFF_t_70]  
可以看到其默认值为false。  
接下来实际试验一下：

# 二、项目 #

本次就接着上次的项目继续使用，项目完整代码：[https://github.com/zrk333/mq-service][https_github.com_zrk333_mq-service]  
只是在上一篇[SpringCloud Stream 整合 RabbitMQ-消费失败后重试][SpringCloud Stream _ RabbitMQ-]的基础上进行修改，并沿用消费者消费方法中的异常int i = 1 / 0;

# 三、修改消费者 #

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

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

另外分组之前添加过，没有添加的需要添加一下，为了添加dlq队列时更好的分组，下面有截图可以看到

spring.cloud.stream.bindings.message-center-input.group=${spring.application.name}

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

重启消费者，并调用生产者接口发送消息  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3_size_16_color_FFFFFF_t_70 1]  
依然抛出异常，现在看一下RabbitMQ网页页面：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3_size_16_color_FFFFFF_t_70 2]  
可以发现多了一个dlp队列，并且Ready Messages 的值为1，多尝试几次还会增加：  
![在这里插入图片描述][202001051633255.png]

#### 3、查看dlq队列 ####

点击页面队列名**message-center.mq-service-consumer.dlq**进入：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3_size_16_color_FFFFFF_t_70 3]  
Get messages 部分可以查看当前在dlq队列中存放的消息，可以输入数量(相当于查看几条)，点击按钮：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3_size_16_color_FFFFFF_t_70 4]  
可以看到消息原封不动保存，现在将代码修复好，并手动尝试重新消费：

#### 4、解决bug并重新验证 ####

注释掉抛异常的代码，重启消费者，页面向下看到Move messages部分：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3_size_16_color_FFFFFF_t_70 5]  
可以再输入框中填入目标队列名称(可以从**Get messages** 部分的*Routing Key*进行**复制**)，点击按钮，查看页面  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3_size_16_color_FFFFFF_t_70 6]  
![在这里插入图片描述][20200105165216751.png]  
消费者日志：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3_size_16_color_FFFFFF_t_70 7]  
可以看到消费被重新放回**message-center.mq-service-consumer**队列，并重新消费。

# 四、补充-插件 #

假如未装插件，页面如下，此时没有Move Messages按钮  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3_size_16_color_FFFFFF_t_70 8]  
![在这里插入图片描述][2020010517022986.png]  
按提示需要执行下面命令开启插件，*不需要重启rabbitmq*

rabbitmq-plugins enable rabbitmq_shovel rabbitmq_shovel_management

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3_size_16_color_FFFFFF_t_70 9]  
![在这里插入图片描述][20200105170315554.png]

*  查看插件命令

rabbitmq-plugins list

*  启动插件命令

rabbitmq-plugins enable xxx

*  关闭插件命令

rabbitmq-plugins disable xxx

# 五、参考链接 #

*  [SpringCloud官方文档][SpringCloud]
 *  [Spring Cloud Stream消费失败后的处理策略（三）：使用DLQ队列（RabbitMQ）][Spring Cloud Stream_DLQ_RabbitMQ]

[SpringCloud Stream _RabbitMQ]: https://blog.csdn.net/qq_21067307/article/details/103839356
[SpringCloud Stream _ RabbitMQ-]: https://blog.csdn.net/qq_21067307/article/details/103843884
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200105162408816.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3,size_16,color_FFFFFF,t_70
[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 1]: https://img-blog.csdnimg.cn/20200105163034646.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20200105163148414.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3,size_16,color_FFFFFF,t_70
[202001051633255.png]: https://img-blog.csdnimg.cn/202001051633255.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/2020010516410447.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3_size_16_color_FFFFFF_t_70 4]: https://img-blog.csdnimg.cn/20200105164305632.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3_size_16_color_FFFFFF_t_70 5]: https://img-blog.csdnimg.cn/20200105164629938.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3_size_16_color_FFFFFF_t_70 6]: https://img-blog.csdnimg.cn/20200105165140406.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3,size_16,color_FFFFFF,t_70
[20200105165216751.png]: https://img-blog.csdnimg.cn/20200105165216751.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3_size_16_color_FFFFFF_t_70 7]: https://img-blog.csdnimg.cn/20200105165238418.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3_size_16_color_FFFFFF_t_70 8]: https://img-blog.csdnimg.cn/20200105170032542.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3,size_16,color_FFFFFF,t_70
[2020010517022986.png]: https://img-blog.csdnimg.cn/2020010517022986.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3_size_16_color_FFFFFF_t_70 9]: https://img-blog.csdnimg.cn/2020010517033451.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIxMDY3MzA3,size_16,color_FFFFFF,t_70
[20200105170315554.png]: https://img-blog.csdnimg.cn/20200105170315554.png
[SpringCloud]: https://cloud.spring.io/spring-cloud-static/Finchley.SR4/single/spring-cloud.html
[Spring Cloud Stream_DLQ_RabbitMQ]: https://www.cnblogs.com/didispace/p/10134621.html