点击下载
本文文档

当前位置：首页 - 正文

rocketmq启动和配置

来源：动视网责编：小OO 时间：2025-10-01 20:51:20

rocketmq启动和配置

1.启动nameservernohupshmqnamesrv>namesrv.out2>&1&2.启动borkernohupshmqbroker-c$ROCKETMQ_HOME/conf/2m-noslave/broker-128.properties>broker.out2>&1&配置文件参数说明如下：listenPort10911Broker对外服务的监听端口namesrvAddrnullNameServer地址brokerIP1本机IP本机IP地址，默认系统自动识别，但是某些多网卡机器会

推荐度：

点击下载本文 文档为doc格式

导读1.启动nameservernohupshmqnamesrv>namesrv.out2>&1&2.启动borkernohupshmqbroker-c$ROCKETMQ_HOME/conf/2m-noslave/broker-128.properties>broker.out2>&1&配置文件参数说明如下：listenPort10911Broker对外服务的监听端口namesrvAddrnullNameServer地址brokerIP1本机IP本机IP地址，默认系统自动识别，但是某些多网卡机器会

1. 启动nameserver

nohup sh mqnamesrv >namesrv.out 2>&1 &

2. 启动borker

nohup sh mqbroker -c $ROCKETMQ_HOME/conf/2m-noslave/broker-128.properties >broker.out 2>&1 &

配置文件参数说明如下：

listenPort	10911		Broker对外服务的监听端口
namesrvAddr	null		Name Server地址
brokerIP1	本机IP		本机IP地址，默认系统自动识别，但是某些多网卡机器会存在识别错误的情况，这种情况下可以人工配置
brokerName		本机主机名
brokerClusterName	DefaultCluster		Broker所属哪个集群
brokerId	0		BrokerId，必须是大等于0的整数，0表示Master，>0表示Slave，一个Master可以挂多个Slave，Master与Slave通过BrokerName来配对
autoCreateTopicEnable	TRUE		是否允许Broker自动创建Topic，建议线下开启，线上关闭
autoCreateSubscriptionGroup	TRUE		是否允许Broker自动创建订阅组，建议线下开启，线上关闭
rejectTransactionMessage	FALSE		是否拒绝事务消息接入
fetchNamesrvAddrByAddressServer	FALSE		是否从web服务器获取Name Server地址，针对大规模的Broker集群建议使用这种方式
storePathCommitLog	$HOME/store/commitlog		commitLog存储路径
storePathConsumeQueue	$HOME/store/consumequeue		消费队列存储路径
storePathIndex	$HOME/store/index		消息索引存储路径
storeCheckpoint	$HOME/store/checkpoint		checkpoint文件存储路径
abortFile	$HOME/store/abort		abort文件存储路径
deleteWhen	4		删除文件时间点，默认凌晨4点
fileReservedTime	48		文件保留时间，默认48小时
maxTransferBytesOnMessageInMemory	262144		单次Pull消息（内存）传输的最大字节数
maxTransferCountOnMessageInMemory	32		单次Pull消息（内存）传输的最大条数
maxTransferBytesOnMessageInDisk	65536		单次Pull消息（磁盘）传输的最大字节数
maxTransferCountOnMessageInDisk	8		单次Pull消息（磁盘）传输的最大条数
messageIndexEnable	TRUE		是否开启消息索引功能
messageIndexSafe	FALSE		是否提供安全的消息索引机制，索引保证不丢
haMasterAddress		在Slave上直接设置Master地址，默认从Name Server上自动获取，也可以手工强制配置
brokerRole	ASYNC_MASTER		Broker的角色 - ASYNC_MASTER 异步复制Master - SYNC_MASTER 同步双写Master - SLAVE
flushDiskType	ASYNC_FLUSH		刷盘方式 - ASYNC_FLUSH 异步刷盘 - SYNC_FLUSH 同步刷盘
cleanFileForciblyEnable	TRUE		磁盘满、且无过期文件情况下 TRUE 表示强制删除文件，优先保证服务可用 FALSE 标记服务不可用，文件不删除

3、Jps查看服务启动情况

[root@m106 bin]# jps

12494 HRegionServer

12240 Kafka

16556 DataNode

18499 NamesrvStartup

13101 RunJar

17210 BrokerStartup

4、创建topic

[root@m106 bin]# sh mqadmin updateTopic

usage: mqadmin updateTopic [-b ] [-c ] [-h] [-n ] [-o ] [-p ] [-r ] [-s ]

-t [-u ] [-w ]

-b,--brokerAddr create topic to which broker

-c,--clusterName create topic to which cluster

-h,--help Print help

-n,--namesrvAddr Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876

-o,--order set topic's order(true|false

-p,--perm set topic's permission(2|4|6), intro[2:R; 4:W; 6:RW]

-r,--readQueueNums set read queue nums

-s,--hasUnitSub has unit sub (true|false

-t,--topic topic name

-u,--unit is unit topic (true|false

-w,--writeQueueNums set write queue nums

实例：

[root@m106 bin]# sh mqadmin updateTopic -n 172.16.8.106:9876 -c DefaultCluster -t TopicTest1

create topic to 172.16.8.107:10911 success.

TopicConfig [topicName=TopicTest1, readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, order=false]

5、删除topic

[root@m106 bin]# sh mqadmin deleteTopic -n 172.16.8.106:9876 -c DefaultCluster -t TopicTest1

delete topic [TopicTest1] from cluster [DefaultCluster] success.

delete topic [TopicTest1] from NameServer success.

6、查看topic信息

[root@m106 bin]# sh mqadmin topicList -n 172.16.8.106:9876

BenchmarkTest

TopicTest1

broker-a

DefaultCluster

7、查看topic统计信息

[root@m106 bin]# sh mqadmin topicStatus -n 172.16.8.106:9876 -t TopicTest1

#Broker Name #QID #Min Offset #Max Offset #Last Updated

broker-a 0 0 0

broker-a 1 0 0

broker-a 2 0 0

broker-a 3 0 0

broker-a 4 0 0

broker-a 5 0 0

broker-a 6 0 0

broker-a 7 0 0

8、查看所有消费组group

[root@m106 bin]# sh mqadmin consumerProgress -n 172.16.8.106:9876

9、查看指定消费组下的所有topic数据堆积情况

[root@m106 bin]# sh mqadmin consumerProgress -n 172.16.8.106:9876 -g ConsumerGroupName

10、关闭nameserver broker

#sh mqshutdown namesrv

#sh mqshutdown broker

rocketmq启动和配置

1.启动nameservernohupshmqnamesrv>namesrv.out2>&1&2.启动borkernohupshmqbroker-c$ROCKETMQ_HOME/conf/2m-noslave/broker-128.properties>broker.out2>&1&配置文件参数说明如下：listenPort10911Broker对外服务的监听端口namesrvAddrnullNameServer地址brokerIP1本机IP本机IP地址，默认系统自动识别，但是某些多网卡机器会

推荐度：

点击下载本文 文档为doc格式

热门焦点

rocketmq启动和配置

rocketmq启动和配置

rocketmq启动和配置

最新推荐

猜你喜欢

热门推荐