死信队列+TTL实现延迟重试
思路
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,则进行异常处理(报警或者其他之类)
此处亦可以使用单通道queue_delay,过期时间设置在消息message上,通道不设置过期,如下
新版本的rabbitMQ,安装了插件rabbitmq_delayed_message_exchange后,可直接设置延迟投递,如下