- 系统 CentOS Linux release 8.2.2004 (Core)
- 配置 6核 32G
- java环境 jdk1.8
- guan官方地址
- 软件下载地址
- 控制台源码下载地址
- 解压到指定路径
[root@localhost zip]# unzip rocketmq-all-4.9.2-bin-release.zip -d /opt/rocketmq - 配置broker.conf
# 默认的集群名称 brokerClusterName=DefaultCluster # broke名称 brokerName=broker-a # Broker 对外服务的监听端口 listenPort=10911 # 0为master, 大于0的为slave brokerId=0 # 删除文件时间点,默认凌晨 4点 ,PS : 在每天的什么时间删除已经超过文件保留时间的 commit log deleteWhen=04 #文件保留时间,默认 48 小时 fileReservedTime=48 #Broker 的角色 #- ASYNC_MASTER 异步复制Master #- SYNC_MASTER 同步双写Master #- SLAVE 从机 brokerRole=ASYNC_MASTER #刷盘方式 #- ASYNC_FLUSH 异步刷盘 #- SYNC_FLUSH 同步刷盘 flushDiskType=ASYNC_FLUSH # broker IP地址 brokerIP1=192.168.2.211 # nameServer地址,分号分割 namesrvAddr=192.168.2.211:9876 # 是否允许 Broker 自动创建Topic,建议线下开启,线上关闭 autoCreateTopicEnable=true # 是否允许 Broker 自动创建订阅组,建议线下开启,线上关闭 autoCreateSubscriptionGroup=true #存储路径 storePathRootDir=/opt/rocketmq/store #commitLog 存储路径 storePathCommitLog=/opt/rocketmq/store/commitlog #消费队列存储路径存储路径 storePathConsumeQueue=/opt/rocketmq/store/consumequeue #消息索引存储路径 storePathIndex=/opt/rocketmq/store/index #checkpoint 文件存储路径 storeCheckpoint=/opt/rocketmq/store/checkpoint #abort 文件存储路径 abortFile=/opt/rocketmq/store/abort # commit log 的映射文件大小 mapedFileSizeCommitLog = 1024 * 1024 * 1024 #限制的消息大小 maxMessageSize=65536
- 创建对应的存储文件夹
- 启动rocketmq服务
- nohup sh bin/mqnamesrv > /opt/rocketmq/logs/mqnamesrv.log 2>&1 &
- nohup sh bin/mqbroker -c /opt/rocketmq/conf/broker.conf > /opt/rocketmq/logs/mqbroker.log 2>&1 &
* 启动日志
The broker[broker-a, 192.168.2.211:10911] boot success. serializeType=JSON and name server is 192.168.2.211:9876
- rocketmq服务关闭
- 关闭namesrv服务:sh bin/mqshutdown namesrv
- 关闭broker服务 :sh bin/mqshutdown broker
- broker无法启动 参考文档:https://blog.csdn.net/u011249920/article/details/108217411
- 单机安装:https://blog.csdn.net/lumengmeng_csdn/article/details/87855335
- 分布式安装参考:https://www.cnblogs.com/tudachui/p/10998984.html
-
开发mq服务端口
firewall-cmd --zone=public --add-port=9876/tcp --permanent
firewall-cmd --zone=public --add-port=10911/tcp --permanent
firewall-cmd --zone=public --add-port=10912/tcp --permanent -
修改配置
在rocketmq-externals-release-rocketmq-console-1.0.0rocketmq-consolesrcmainresources目录下修改application.properties配置文件 修改为对应地址
#if this value is empty,use env value rocketmq.config.namesrvAddr NAMESRV_ADDR | now, you can set it in ops page.default localhost:9876 rocketmq.config.namesrvAddr=192.168.2.211:9786 #if you use rocketmq version < 3.5.8, rocketmq.config.isVIPChannel should be false.default true rocketmq.config.isVIPChannel=fasle #rocketmq-console's data path:dashboard/monitor rocketmq.config.dataPath=/opt/rocketmq/console/data```
-
编译源码
mvn clean package -Dmaven.test.skip=true -
将编译好的rocketmq-console-ng-0.0.jar包上传linux服务器运行
-
访问 http://192.168.2.211:8849
-
出现问题
- 无法连接mq服务,原因:在启动mq服务时指定了ip地址和端口,即使在同一台也需要控制台配置文件也需要填写对应的IP端口
- 无法连接mq服务,原因:在启动mq服务时指定了ip地址和端口,即使在同一台也需要控制台配置文件也需要填写对应的IP端口
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)