总体来说比较迂回,比较巧妙地利用了原顺序存储机制和delay队列机制.
重试消息的consumer发回:重试消息的cons
阅读背景：
rocketmq cluster下concurrently重试机制实现
来源：互联网
分享到：
