队列在异常重试中的应用

用重试队列承接失败任务

可以把异常任务先写入重试队列，由消费者按设定策略再次拉取执行。常见做法是给消息附带重试次数、失败原因和下次可执行时间，消费者在处理失败后把消息重新投递到延迟队列或重试主题。这样既能缓解瞬时故障，也能避免业务线程被阻塞。

靠幂等设计控制重复执行

重试场景下要把消费者设计成幂等的，比如使用业务唯一键、去重表、状态机或分布式锁来识别同一笔请求。即便消息被重复投递，系统也只会接受一次有效变更。对于写操作，还可以在落库前检查当前状态，避免同一结果被反复覆盖。

用有限重试加死信兜底

可以按错误类型设置重试上限和间隔策略，像临时网络抖动适合较短间隔，依赖服务不可用则适合更长间隔。超过重试次数后，把消息送入死信队列或人工处理队列，由运维或业务系统介入排查。这样能把自动恢复和人工兜底分开，减少消息堆积。

按业务优先级拆分重试通道

如果业务对顺序敏感，可以把同一业务键的消息放进同一个分区或同一顺序队列，避免乱序。对吞吐要求高的场景，可以把正常消息和重试消息分开处理，让失败任务进入独立的重试通道，减少对主流程的影响。配合限流、批量消费和退避策略，可以把性能波动控制在可接受范围内。