RocketMQ NameServer

环境配置

配置环境变量ROCKETMQ_HOME，是RockMQ的运行文件目录

比如:

export ROCKETMQ_HOME="/opt/rocketmq/"

先配置这个变量,如果说此时IDE已经打开,那么后来的系统配置IDE会看不到.

http://stackoverflow.com/questions/29782467/system-getenv-returns-null-when-the-environment-variable-exists

执行类

org.apache.rocketmq.namesrv.NamesrvStartup

可配置的参数变量

参数	含义	是否必须	默认值
rocketmq.remoting.version	RocketMQ版本	false	当前的默认值是V4_1_0_SNAPSHOT的序数
com.rocketmq.remoting.socket.sndbuf.size	发送消息的buff大小 ,这个是系统配置	false	4096字节
com.rocketmq.remoting.socket.rcvbuf.size	接受消息的buff大小,这个是系统配置	false	4096字节

运行

脚本运行

参数	含义	是否必须
-c	config文件	false
-h	help	false
-n	NameServer的地址	false
-p	展示配置参数	false

执行类直接运行

要DEBUG,当然是直接运行main方法即可,不需要传递参数.

如果说不想配置全局的环境变量可以在namesrvConfig实例中配置该参数.

namesrvConfig.setRocketmqHome("/home/code/github/incubator-rocketmq");

NamesrvController

NamesrvController是NameServer服务的核心类

整个流程可以看做是

controller.getConfiguration().registerConfig(properties);

boolean initResult = controller.initialize();
if (!initResult) {
    controller.shutdown();
    System.exit(-3);
}
controller.start();

registerConfig

如果说提供了配置文件,会全部加载到NamesrvController实例的Configuration中

controller.getConfiguration().registerConfig(properties);

配置文件的识别是线程安全的,使用了读写锁

public Configuration registerConfig(Properties extProperties) {
    if (extProperties == null) {
        return this;
    }

    try {
        readWriteLock.writeLock().lockInterruptibly();

        try {
            merge(extProperties, this.allConfigs);
        } finally {
            readWriteLock.writeLock().unlock();
        }
    } catch (InterruptedException e) {
        log.error("register lock error. {}" + extProperties);
    }

    return this;
}

initialize

initialize会对相关服务预加载

加载RouteInfoManager

RouteInfoManager实例中保存了整个消息集群的先关信息

HashMap<String/* topic */, List<QueueData>> topicQueueTable;
HashMap<String/* brokerName */, BrokerData> brokerAddrTable;
HashMap<String/* clusterName */, Set<String/* brokerName */>> clusterAddrTable;
HashMap<String/* brokerAddr */, BrokerLiveInfo> brokerLiveTable;
HashMap<String/* brokerAddr */, List<String>/* Filter Server */> filterServerTable;

定时扫描无效的broker

this.scheduledExecutorService.scheduleAtFixedRate(new Runnable() {
    @Override
    public void run() {
        NamesrvController.this.routeInfoManager.scanNotActiveBroker();
    }
}, 5, 10, TimeUnit.SECONDS);

加载KVConfigManager

KVConfigManager是一配置文件，默认读取用户目录下的配置文件

private String kvConfigPath = System.getProperty("user.home") + File.separator + "namesrv" + File.separator + "kvConfig.json";

这个是KVConfigSerializeWrapper实例的JSON序列化文件

定时将配置信息输出

this.scheduledExecutorService.scheduleAtFixedRate(new Runnable() {
    @Override
    public void run() {
        NamesrvController.this.kvConfigManager.printAllPeriodically();
    }
}, 1, 10, TimeUnit.MINUTES);

start

NamesrvController的start实际上调用了RemotingServer子类的start方法,这里是使用NettyRemotingServer

有些事情....先中断,回过头来继续

TO BE CONTINUE

补充说明

配置文件

ROCKETMQ_HOME目录下的conf文件中包含了默认的配置文件
默认的日志目录在${user.home}/logs/目录下

NameServer