RocketMQ生产者和消费者关键概念总结

生产者:web 每隔30S向Master发送心跳,心跳信息内只包含producerGroup名称,同时上传FilterClassSource 每隔30S从Namesrv获取最新的TopicRouteData,提取信息封装成TopicPuhlishInfo 根据最新的TopicRouteData,定时更新持有的Broker列表,清空下线的Broker 当未开启延迟容错机制(默认)情形下,轮流按顺序向
相关文章
相关标签/搜索