Apache RocketMQ 从入门到实战RocketMQ 技术内幕》第二、三章。 Step1:在 Broker 启动流程中,会构建 TopicConfigManager 对象,其构造方法中 首先会判断是否开启了允许自动创建主题,如果启用了自动创建主题,则向 topicConfigT able 中添加默认主题的路由信息。 TopicConfigManager 构造方法: 本文来自『中间件兴趣圈』公众号,仅作技术交流,未授权任何商业行为。 径为${ROCKET_HOME}/store/config/topics.json 中,这样在 Broker 关闭后再重启, 并不会丢失路由信息。 广大读者朋友,跟踪到这一步的时候,大家应该对启用自动创建主题机制时,新主题是 的路由信息是如何创建的,为了方便理解,给出创建主题序列图: 本文来自『中间件兴趣圈』公众号,仅作技术交流,未授权任何商业行为。 25 > 1.2 生产环境中,autoCreateTopicEnable 然后尝试查询是否存在默认 Topic 的路由信息,如果存在,说明启用了 autoCreateTopi cEnable,则在 TopicConfigManager 中创建新 Topic 的路由信息,此时存在与 Broker 服务端的内存中,然后本次消息发送结束。此时,在 NameServer 中还不存在新创建的 Topic 的路由信息。 这里有三个关键点: 1. 启用 autoCreateTopicEnable0 码力 | 165 页 | 12.53 MB | 1 年前3
共 1 条
- 1













