RabbitMQ (三）高级特性实现死信队列 DLX TTL 消费端限流prefetch 消息可靠传递 confirm return 幂等性保障

r囧r小猫 2022-09-10 12:17 162阅读 0赞

本来想带过一下rabbit整合spring和spring-boot，我看网上很多相关文档，就没什么必要了，就来总结一下一些高级特性给自己看看。本章主要以理论为主，至于代码和使用，我在git上放了一套简单易懂的 [例程][Link 1]。可以下载下来，在advance（高级）中，有延时队列可供参考。如过需要其学习rabbitMq其他简单使用可以阅读 [RabbitMq (一）理论篇部分][RabbitMq][RabbitMQ（二）实践篇][RabbitMQ]

### 文章目录 ###

*  前言
 *  一、消息的可靠性传递
 *  二、消息的可靠性接收
 *  三、消费端限流
 *  四、TTL
 *  五、死信队列
 *  六、延时队列
 *  七、幂等性保障

--------------------

# 前言 #

--------------------

# 一、消息的可靠性传递 #

在使用RabbitMQ的时候，为了确保消息抵达Broker，Rabbit提供了两种方式供用户来控制消息投递的可靠性模式

*  confirm 确认模式
 *  return 退回模式

RabbitMQ消息的整个投递过程：

![在这里插入图片描述][052d4e77609648d6a626b57bd1ea3e03.png]

*  confirm 是判断消息是否被 exchange 收到。
 *  return 是消息被 exchange 收到，但是没有队列可以投递。

使用步骤大体是模式开启，写一下回调函数。做法不同的架构写的不太一样，但意思都是一样的，如果你发现你写的监听不起作用，八成就是模式没开启。

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAVF9BbnRyeQ_size_20_color_FFFFFF_t_70_g_se_x_16]

# 二、消息的可靠性接收 #

上面讲的可靠性传递，只是确定到了queue，那还需要确定消息到达消费端。

有三种确认方式：

*  自动确认 ： acknowledge = “none”  
    消息一旦被Consumer收到，则自动确认签收，并将相应的message从rabbitmq的消息缓存中移除。
 *  手动确认 ： acknowledge = “manual”  
    实际业务处理可能会出现异常，可以设置手动签收，如果正常处理chanel.basicAck()正常签收，若发生异常chanel.basicNack()拒绝签收，让消息重新发送。
 *  根据异常情况确认 ： acknowledge = “auto”

# 三、消费端限流 #

如果请求瞬间增多，超过最大处理请求，会导致系统奔溃。加以限制，让系统慢慢处理，就可以缓解请求突增的情况。  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAVF9BbnRyeQ_size_20_color_FFFFFF_t_70_g_se_x_16 1]  
配置  
![在这里插入图片描述][5c3a3d8a0e9e4f7d9336dbb55ee269ff.png]

# 四、TTL #

TTL全称Time To Live（存活时间、过期时间），当消息到达存活时间后，还没有被消费，会自动被删除。  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAVF9BbnRyeQ_size_20_color_FFFFFF_t_70_g_se_x_16 2]

*  可以对消息设置时间，也可以对整个队列设置时间
 *  设置队列过期时间参数：x-message-ttl,单位ms，会对整个队列生效。
 *  设置消息过期使用参数：expriration。单位ms，当该消息在队列头部时，会单独判断该消息是否过期。
 *  如果两者都设置了，则以时间较短的为准。

# 五、死信队列 #

DLX（dead letter exchange 死信交换机），当一个消息成为 dead message 后，可被重新发送到另一交换机，这个交换机就是DLX  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAVF9BbnRyeQ_size_20_color_FFFFFF_t_70_g_se_x_16 3]  
什么情况下消息会成为死信：

*  队列消息长度达到限制
 *  消费者拒绝消费消息，basicNack/basicReject，并且不把消息重新放入原目标队列，requeue=false
 *  原队列存在消息过期设置，消息到达超时时间，未被消费；

# 六、延时队列 #

消息进入队列后不会立即被消费 ，等待达到时间后被消费。很可惜，RabbitMQ没有提供延时队列功能，但是可以使用TTL+死信队列组合实现延时队列效果

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAVF9BbnRyeQ_size_20_color_FFFFFF_t_70_g_se_x_16 4]

# 七、幂等性保障 #

一次或多次请求某一个资源，对于资源本身应该具有同一个效果。在MQ中，指消费同一条消息多次，得到消费该消息一次相同效果。

通过version版本控制

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAVF9BbnRyeQ_size_20_color_FFFFFF_t_70_g_se_x_16 5]

[Link 1]: https://github.com/T-Antry/csdn-example.git
[RabbitMq]: https://blog.csdn.net/qq_39150049/article/details/120004369?spm=1001.2014.3001.5501
[RabbitMQ]: https://blog.csdn.net/qq_39150049/article/details/120030406?spm=1001.2014.3001.5501
[052d4e77609648d6a626b57bd1ea3e03.png]: /images/20220829/1ef1aaa062174668ba433ac04ab464d3.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAVF9BbnRyeQ_size_20_color_FFFFFF_t_70_g_se_x_16]: /images/20220829/3bf2537c128249bf8e040a0e2192bb79.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAVF9BbnRyeQ_size_20_color_FFFFFF_t_70_g_se_x_16 1]: /images/20220829/9bec84d29e40498ebda31d464ee48d18.png
[5c3a3d8a0e9e4f7d9336dbb55ee269ff.png]: /images/20220829/9a63f9bcaf7d488ca753b95ca73542b1.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAVF9BbnRyeQ_size_20_color_FFFFFF_t_70_g_se_x_16 2]: /images/20220829/5f63a3c160114d4ba710879249cec2be.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAVF9BbnRyeQ_size_20_color_FFFFFF_t_70_g_se_x_16 3]: /images/20220829/1b0dce1f23eb4b28ab97d255112d020f.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAVF9BbnRyeQ_size_20_color_FFFFFF_t_70_g_se_x_16 4]: /images/20220829/d0766e41649d4415aa669cb76727851a.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAVF9BbnRyeQ_size_20_color_FFFFFF_t_70_g_se_x_16 5]: /images/20220829/d0e3d524a3ac4eae8d1f64052f33a013.png