RocketMQ原理解析-producer 1.启动流程

http://blog.csdn.net/quhongwei_zhanqiu/article/details/39141415

 

Producer如何感知要发送消息的broker即brokerAddrTable中的值是怎么获得的，

1.      发送消息的时候会指定topic，如果producer集合中没有，会根据指定topic到namesrv获取topic发布信息TopicPublishInfo，并放入本地集合

2.      定时从namesrv更新topic路由信息，

 

Producer与broker间的心跳

Producer定时发送心跳将producer信息（其实就是procduer的group）定时发送到， brokerAddrTable集合中列出的broker上去

 

Producer发送消息只发送到master的broker机器，在通过broker的主从复制机制拷贝到broker的slave上去