思路

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,则进行异常处理(报警或者其他之类)

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

 

此处亦可以使用单通道queue_delay,过期时间设置在消息message上,通道不设置过期,如下

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

新版本的rabbitMQ,安装了插件rabbitmq_delayed_message_exchange后,可直接设置延迟投递,如下

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

 

相关文章:

  • 2021-07-10
  • 2021-10-25
  • 2021-08-08
  • 2022-02-04
  • 2023-03-11
  • 2021-10-06
  • 2021-06-06
猜你喜欢
  • 2021-07-07
  • 2021-11-19
  • 2022-12-23
  • 2021-09-29
  • 2022-02-07
  • 2022-12-23
  • 2021-10-19
相关资源
相似解决方案