源碼分析RocketMQ之消息ACK機制（消費進度）

一、消息消費進度概述 首先簡要闡述一下消息消費進度：java 消費者訂閱消息消費隊列（MessageQueue), 當生產者將消息負載發送到 MessageQueue 中時，消費訂閱者開始消費消息，消息消費過程當中，爲了不重複消費，須要一個地方存儲消費進度（消費偏移量）。apache 消息模式主要分爲集羣模式、廣播模式：json 集羣模式：一條消息被集羣中任何一個消費者消費。 廣播模式：每條消息都

>>阅读原文<<