rocketmq消費失敗重試源碼分析。

啃了兩天這個功能的源碼，涉及了好幾個模塊，終於把這塊邏輯啃完了。看完以後有種豁然開朗的感受。java   首先咱們要知道一點 消息重試的功能是創建在延遲消費消息這個功能的前提條件之下的。 這篇文章會穿插延遲發送消息的一些源碼分析。node ① 當消費者（client）啓動的時候，將會調用copySubscription()方法。負載均衡 ②消費端拉取到消息後將拉取到的消息List（最多32條）扔給

>>阅读原文<<