【RocketMQ源码分析】重试机制

咱们知道RocketMQ消息处理成功的标志是消费者消费一条消息后向Broker端发送ACK消息(ack,message back)而且被Broker处理。这个过程当中是涉及到网络传输，有网络的地方就存在不肯定性，若是因为网络等缘由致使ACK丢失，则RocketMQ会触发消息消费重试机制，从新消费该条消息。RocketMQ支持了生产端和消费端两类重试机制。java 生产端重试 若是因为网络抖动等缘由

>>阅读原文<<