RocketMQ NameServer
环境配置
配置环境变量ROCKETMQ_HOME，是RockMQ的运行文件目录
比如:
export ROCKETMQ_HOME="/opt/rocketmq/"
先配置这个变量,如果说此时IDE已经打开,那么后来的系统配置IDE会看不到.
执行类
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/目录下
