Spring AMQP 的重试与死信

  监听方法被调用 4 次,时刻 [0.0, 0.5, 1.5, 3.6] 秒;重试用完之后队列状态 (0, 0)(ready, unacked);消息去哪了:没有死信配置,被丢弃

  max-attempts=1:被调用 4 次
  max-attempts=2:被调用 4 次
  max-retries=0:被调用 1 次
  max-retries=1:被调用 2 次
  max-retries=2:被调用 3 次

  重试用完之后:q.work=(0, 0),q.dlq=(1, 0)
  q.dlq 里的消息:{'body': 'poison-1', 'x-first-death-reason': 'rejected', 'x-first-death-queue': 'q.work', 'x-death 条目': [('q.work', 'rejected', 1L)]}

  ok-2 在 [7.0] 秒才被处理(poison-1 占着唯一的消费者线程重试了约 7 秒)

  0.0 秒  收到 poison-1
  0.0 秒  收到 ok-2
  0.0 秒  完成 ok-2
  0.7 秒  收到 poison-1(x-death 累计 2 次)
  1.4 秒  收到 poison-1(x-death 累计 4 次)
  1.4 秒  已重试 3 次,转存到 q.parking 并确认
  最终队列状态:{'q.wait': (0, 0), 'q.work': (0, 0), 'q.dlq': (0, 0), 'q.parking': (1, 0)}

  监听方法被调用 0 次;3 秒后 q.work=(0, 1),q.dlq=(1, 0);再过 3 秒 q.work=(0, 0),q.dlq=(1, 0)
  q.dlq 里的消息:{'body': 'this is not json', 'x-first-death-reason': 'rejected', 'x-first-death-queue': 'q.work', 'x-death 条目': [('q.work', 'rejected', 1L)]}