rocketmq消费失败重试源码分析。

啃了两天这个功能的源码，涉及了好几个模块，终于把这块逻辑啃完了。看完以后有种豁然开朗的感受。java   首先咱们要知道一点 消息重试的功能是创建在延迟消费消息这个功能的前提条件之下的。 这篇文章会穿插延迟发送消息的一些源码分析。node ① 当消费者（client）启动的时候，将会调用copySubscription()方法。负载均衡 ②消费端拉取到消息后将拉取到的消息List（最多32条）扔给

>>阅读原文<<