Spring RabbitMQ 消息重试机制

RabbitMQ框架提供了重试机制，只需要简单的配置即可开启，可以提升程序的健壮性。

测试一：重试5次

1spring:
2  rabbitmq:
3    listener:
4      simple:
5        retry:
6          enabled: true          
7          max-attempts: 5 # 最大重试次数，包含本身
8
92019-10-14 16:09:03.878 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
102019-10-14 16:09:04.881 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler 
112019-10-14 16:09:05.886 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
122019-10-14 16:09:06.891 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
132019-10-14 16:09:07.892 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
14
15由结果得知：默认是每秒重试

测试二：重试5次，每隔3秒重试

1spring:
2  rabbitmq:
3    listener:
4      simple:
5        retry:
6          enabled: true
7          max-attempts: 5 # 最大重试次数
8          initial-interval: 3000 # 重试间隔
9          
102019-10-14 16:12:12.348 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
112019-10-14 16:12:15.355 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
122019-10-14 16:12:18.362 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
132019-10-14 16:12:21.368 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
142019-10-14 16:12:24.374 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
15
16由结果得知：会按设置的时间间隔进行重试，这里配置的是3秒

测试三：重试5次，重试间隔根据乘子计算

1spring:
2  rabbitmq:
3    listener:
4      simple:
5        retry:
6          enabled: true
7          multiplier: 2 # 乘子
8          max-attempts: 5 # 最大重试次数
9          initial-interval: 3000 # 第一次和第二次之间的重试间隔
10
112019-10-14 16:15:10.010 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
122019-10-14 16:15:13.014 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
132019-10-14 16:15:19.021 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
142019-10-14 16:15:29.023 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
152019-10-14 16:15:39.026 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
16
17结果展示有点异常，第4次和第5次都是以10秒为重试间隔，原因是默认的最大重试间隔就是10秒

测试四(推荐)：重试5次，重试间隔根据乘子计算，并自定义最大重试间隔

1做如下修改，设置最大重试间隔为1个小时
2
3spring:
4  rabbitmq:
5    listener:
6      simple:
7        retry:
8          enabled: true
9          multiplier: 2 # 乘子
10          max-attempts: 5 # 最大重试次数
11          initial-interval: 3000 # 第一次和第二次之间的重试间隔，后面的用乘子计算
12          max-interval: 3600000 # 最大重试时间间隔
13          
142019-10-14 16:50:36.580 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler 
152019-10-14 16:50:39.588 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
162019-10-14 16:50:45.594 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
172019-10-14 16:50:57.597 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
182019-10-14 16:51:21.603 ERROR o.s.a.r.l.a.RabbitListenerErrorHandler
19
20由结果得知：重试间隔为：3s 6s 12s 24s