rocketmq消息发送容错策略和优雅关机

1.近期研究rocketmq的源码,发现producer在发送消息时,先根据路由选择broker的MessageQueue,在选择发送队列时, 会根据sendLatencyFaultEnable值进行容错处理。 DefaultMQProducer设置参数入口: 2.发送消息源码 (1)获取topic路由信息:TopicPublishInfo topicPublishInfo = this.tryT
相关文章
相关标签/搜索