死信队列+TTL实现延迟重试

ゝ一世哀愁。 2023-06-26 05:40 23阅读 0赞

# **思路** #

### MQ配置： ###

> 1.设置正常处理队列及绑定关系，exchange，queue，key
> 
> 2.创建5s延迟队列queue\_5s，10s延迟队列queue\_10s，20s延迟队列queue\_20s，差错处理队列queue\_error,分别于exchange\_delay绑定，设置routingKey分别为key\_5s，key\_10s，key\_20s，key\_error
> 
> 3.分别配置queue\_5s，queue\_10s，queue\_20s的死信交换机为exchange，routingKey为key

### 代码实现： ###

> 1.消息发送方正常投递消息到exchange —> key（正常发送）
> 
> 2.消息处理方式正常处理消息
> 
> 3.消息处理方异常，则计算routingKey，进行投递（可以将重试次数放入message head  或者直接使用message 的routingKey）
> 
> 4.若消息投递到queue\_\*s中，则过期后自动转到 exchange —> key 到达 queue
> 
> 5.若消息投递到queue\_error，则进行异常处理（报警或者其他之类）

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xhb3hpbGFveGlf_size_16_color_FFFFFF_t_70][]

> 此处亦可以使用单通道queue\_delay，过期时间设置在消息message上，通道不设置过期，如下

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xhb3hpbGFveGlf_size_16_color_FFFFFF_t_70 1][]

> 新版本的rabbitMQ，安装了插件rabbitmq\_delayed\_message\_exchange后，可直接设置延迟投递，如下

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xhb3hpbGFveGlf_size_16_color_FFFFFF_t_70 2][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xhb3hpbGFveGlf_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20191230143244370.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xhb3hpbGFveGlf,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xhb3hpbGFveGlf_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20191230143356389.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xhb3hpbGFveGlf,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xhb3hpbGFveGlf_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20191230143436680.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xhb3hpbGFveGlf,size_16,color_FFFFFF,t_70