【RocketMQ源碼分析】重試機制

咱們知道RocketMQ消息處理成功的標誌是消費者消費一條消息後向Broker端發送ACK消息(ack,message back)而且被Broker處理。這個過程當中是涉及到網絡傳輸,有網絡的地方就存在不肯定性,若是因爲網絡等緣由致使ACK丟失,則RocketMQ會觸發消息消費重試機制,從新消費該條消息。RocketMQ支持了生產端和消費端兩類重試機制。java 生產端重試 若是因爲網絡抖動等緣由
相關文章
相關標籤/搜索