栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

centos8安装rocketMQ

centos8安装rocketMQ

1.下载jdk,并安装

jdk11地址:Java Downloads | Oracle

2.下载rocketMQ下载地址:

下载地址:Apache DownloadsHome page of The Apache Software Foundationhttps://www.apache.org/dyn/closer.cgi?path=rocketmq/4.9.3/rocketmq-all-4.9.3-bin-release.zip

 3.上传rocketMQ包到centos目录下并解压

##我是放在该目录下的
/usr/local/rocketmq-4.9.3

4.配置conf目录下的broker.conf文件

brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
#新版本最好配置
storePathRootDir=/data/rocketmq/rootdir-a-m
storePathCommitLog=/data/rocketmq/commitlog-a-m
autoCreateSubscriptionGroup=true
## if msg tracing is open,the flag will be true
traceTopicEnable=true
listenPort=10911
# 将namesrvAddr和brokerIP1设置在config中
namesrvAddr=121.4.xx.22:9876
brokerIP1=121.4.xx.22

5.配置bin目录下的runbroker.sh和runserver.sh两个启动文件的java内存大小,默认是8g

runbroker.sh文件:

将红框中的内存改为你认为合适的(我的改为了2g)

 runserver.sh文件:

 6.启动mqnamesrv和mqbroker

#以下运行命令需要在bin目录下运行

#启动nameserver
nohup sh mqnamesrv >/usr/local/rocketmq-4.9.3/rocketmqlogs/namesrv.log 2>&1 & 



##启动broker
nohup sh mqbroker -n localhost:9876 autoCreateTopicEnable=true >/usr/local/rocketmq-4.9.3/rocketmqlogs/mqbroker.log 2>&1 & 

##指定配置文件ip来启动broker  解决云上内网访问的问题
#下面命令执行 如果jdk环境在8以上 需要在runbroker.sh 加上配置JAVA_OPT="${JAVA_OPT} --add-exports java.base/jdk.internal.ref=ALL-UNNAMED"
nohup sh mqbroker -n localhost:9876 -c ../conf/broker.conf autoCreateTopicEnable=true >/usr/local/rocketmq-4.9.3/rocketmqlogs/mqbroker.log 2>&1 & 


#环境变量NAMESRV_ADDR测试发送消息和接受消息
export NAMESRV_ADDR=localhost:9876
#发送消息
sh tools.sh org.apache.rocketmq.example.quickstart.Producer
#接收消息
sh tools.sh org.apache.rocketmq.example.quickstart.Consumer
         
sh bin/mqshutdown broker    //停止 broker
sh bin/mqshutdown namesrv   //停止 nameserver

7.使用jps查看mq的启动进程

 8.如果是使用云服务记得打开9876端口的访问权限

9.下载rocketmq-externals-master源码进行编译

下载地址:rocketmq-externals-master: rocketmq的管理界面平台,启动rocketmq-console中的rocketmq-console-ng-2.0.0.jar就行启动命令为java -jar rocketmq-console-ng-2.0.0.jar --server.port=8080 --rocketmq.config.namesrvAddr=127.0.0.1:9876https://gitee.com/IceTea9527/rocketmq-externals-master?_from=gitee_search

10编译源码rocketmq-console

mvn clean install -Dmaven.test.skip=true

11.将编译好的 rocketmq-console-ng-2.0.0.jar放在服务器中然后启动

nohup java -jar rocketmq-console-ng-2.0.0.jar --server.port=12581 --rocketmq.config.namesrvAddr='127.0.0.1:9876' >/usr/local/rocketmq-4.9.3/rocketmqlogs/mqConsole.log 2>&1 & 

12.访问http://ip:12581

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/775984.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号