RocketMQ生產者和消費者關鍵概念總結

生產者:web 每隔30S向Master發送心跳,心跳信息內只包含producerGroup名稱,同時上傳FilterClassSource 每隔30S從Namesrv獲取最新的TopicRouteData,提取信息封裝成TopicPuhlishInfo 根據最新的TopicRouteData,定時更新持有的Broker列表,清空下線的Broker 當未開啓延遲容錯機制(默認)情形下,輪流按順序向
相關文章
相關標籤/搜索