java实现rabbitMQ延时队列

一、在队列上设置TTL
java实现rabbitMQ延时队列
1、exchange_delay_begin:缓冲队列exchange交换器,用于将消息转发至缓存消息队列 queue_delay_begin 。
2、queue_delay_begin:缓冲消息队列,等待消息过期。
3、exchange_delay_done:死信(dead-letter)队列exchange交换器,用于将队列 queue_delay_begin 转发到死信队列。
4、queue_delay_done:死信消息队列,消费者能够真正消费信息。

queue_delay_begin的参数:
x-dead-letter-exchange: exchange_delay_done
x-dead-letter-routing-key: queue_delay_done
x-max-length: 500 (队列长度,超过直接进入死信队列)
x-message-ttl: 30000 (超时时间,超过进入死信队列)

相关文章:

  • 2021-09-01
  • 2022-12-23
  • 2021-05-17
  • 2021-08-03
  • 2022-02-05
  • 2022-01-13
  • 2021-12-25
  • 2022-12-23
猜你喜欢
  • 2021-10-20
  • 2021-06-25
  • 2022-02-22
  • 2021-09-01
  • 2022-12-23
  • 2021-06-04
相关资源
相似解决方案