zoukankan      html  css  js  c++  java
  • RocketMQ 创建和删除 topic,以及 broker 和 nameserver 之间的心跳

    命令行主类:org.apache.rocketmq.tools.command.MQAdminStartup

    客户端创建 topic

    程序参数:
    updateTopic -n localhost:9876 -c DefaultCluster -t topic-zhang

    org.apache.rocketmq.tools.command.topic.UpdateTopicSubCommand#execute
    创建 topic 步骤:
    1. 从 nameserver 获取当前集群的 master broker

    2. 向 master 发送请求,创建 topic

    3. broker 利用 registerBroker 同步新建的 topic 到 nameserver
    broker 发送请求:org.apache.rocketmq.broker.BrokerController#registerIncrementBrokerData

    客户端删除 topic

    程序参数:
    deleteTopic -n localhost:9876 -c DefaultCluster -t topic-zhang

    org.apache.rocketmq.tools.command.topic.DeleteTopicSubCommand#deleteTopic
    删除 topic 步骤:
    1. client 从 nameserver 获取 broker 列表

    2. 向 broker 发送请求,删除 broker 中的 topic
    broker 删除 topic
    org.apache.rocketmq.broker.topic.TopicConfigManager#deleteTopicConfig

    3. 向 nameserver 发送请求, 删除 nameserver 中的 topic

    同时,broker 和 nameserver 之间有定时的 registerBroker,10s 一次:

    org.apache.rocketmq.broker.BrokerController#start

    this.scheduledExecutorService.scheduleAtFixedRate(new Runnable() {
    
        @Override
        public void run() {
            try {
                BrokerController.this.registerBrokerAll(true, false, brokerConfig.isForceRegister());
            } catch (Throwable e) {
                log.error("registerBrokerAll Exception", e);
            }
        }
    }, 1000 * 10, Math.max(10000, Math.min(brokerConfig.getRegisterNameServerPeriod(), 60000)), TimeUnit.MILLISECONDS);

     org.apache.rocketmq.namesrv.NamesrvController#initialize

    this.scheduledExecutorService.scheduleAtFixedRate(new Runnable() {
    
        @Override
        public void run() {
            NamesrvController.this.routeInfoManager.scanNotActiveBroker();
        }
    }, 5, 10, TimeUnit.SECONDS);
  • 相关阅读:
    LightOJ 1341 Aladdin and the Flying Carpet 数学
    NOIP2013 花匠 DP 线段树优化
    LightOJ 1370 Bi-shoe and Phi-shoe 欧拉函数+线段树
    BZOJ2818: Gcd 欧拉函数求前缀和
    SPOJ3267 D-query 离线+树状数组 在线主席树
    BZOJ 2588: Spoj 10628. Count on a tree 主席树+lca
    拓展欧几里得算法
    POJ1845Sumdiv(求所有因子和 + 唯一分解定理)
    UVA1635 Irrelevant Elements(唯一分解定理 + 组合数递推)
    codeforce 626E(二分)
  • 原文地址:https://www.cnblogs.com/allenwas3/p/11492196.html
Copyright © 2011-2022 走看看