rocketmq消息發送容錯策略和優雅關機

1.近期研究rocketmq的源碼,發現producer在發送消息時,先根據路由選擇broker的MessageQueue,在選擇發送隊列時, 會根據sendLatencyFaultEnable值進行容錯處理。 DefaultMQProducer設置參數入口: 2.發送消息源碼 (1)獲取topic路由信息:TopicPublishInfo topicPublishInfo = this.tryT
相關文章
相關標籤/搜索