源碼分析RocketMQ之消息消費重試機制

主要關注業務方在消息消費失敗後，返回 ConsumeConcurrentlyStatus.RECONSUME_LATER ,專業術語：業務方每條消息消費後要告訴 MQ 消費者一個結果(ack,message back)，觸發 MQ 消息消費重試機制，而後 MQ 消費者須要反饋給 MQ(Broker)。java 備註：主要針對的仍是非順序消息，順序消息在後續專題詳細分析。apache 一、消息消費處

>>阅读原文<<