RocketMQ安装与IDEA Debug环境搭建

本文主要分如下几个部分展开:
- linux服务器安装RocketMQ、RocketMQ-Console
- IDEA中搭建可调试环境
 1、Linux安装RocketMQ、RocketMQ-Console 1.1安装RocketMQStep1:从如下地址下载RocketMQ安装包
cd /opt/Applicationwget https://mirrors.tuna.tsinghua.edu.cn/Apache/rocketmq/4.7.1/rocketmq-all-4.7.1-bin-release.zipStep2:解压安装包
unzip rocketmq-all-4.7.1-bin-release.zipls -l解压后的文件如下图所示:

RocketMQ安装与IDEA Debug环境搭建

文章插图
 
其中 conf 文件夹存放的是RocketMQ的配置文件,提供了各种部署结构的示例配置 。例如2m-2s-async是2主2从异步复制的配置示例;2m-noslave是2主的示例配置 。由于本文主要是搭建一个学习环境,故采取的部署架构为1主的部署架构,关于生产环境下如何搭建RocketMQ集群、如何调优参数将在该专栏的后续文章中专门介绍 。
Step3:修改Nameserver jvm参数
cd binvi runserver.sh# 定位到如下代码JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"# 修改 "-Xms -Xmx -Xmn" 参数JAVA_OPT="${JAVA_OPT} -server -Xms512M -Xmx512M -Xmn256M -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
温馨提示:这里修改JVM参数主要目的是个人学习电脑内存不够,默认NameServer 会占用4G 。
Step4:启动nameserver
nohup ./mqnamesrv &查看${user_home}/logs/rocketmqlogs/namesrv.log日志文件,如果输出结果如下图所示即表示启动成功 。
RocketMQ安装与IDEA Debug环境搭建

文章插图
 
Step5:修改broker的配置文件
vi conf/broker.conf# 使用如下配置文件brokerClusterName = DefaultClusterbrokerName = broker-abrokerId = 0deleteWhen = 04fileReservedTime = 48brokerRole = ASYNC_MASTERflushDiskType = ASYNC_FLUSHstorePathRootDir=/data/rocketmq/storestorePathCommitLog=/data/rocketmq/store/commitlognamesrvAddr=127.0.0.1:9876brokerIP1=192.168.3.10brokerIP2=192.168.3.10autoCreateTopicEnable=falseStep6:修改broker jvm参数 。
cd binvi runbroker.sh #修改如下配置(配置前)JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -Xmn4g"#配置后JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m"Step7:启动broker
cd binnohup ./mqbroker -c ../conf/broker.conf &查看${user_home}/logs/rocketmqlogs/broker.log,如果输出结果如下图所示表示启动成功 。
RocketMQ安装与IDEA Debug环境搭建

文章插图
 
经过上面的步骤,就成功在Linux环境上安装了RocketMQ Nameserver服务器与Broker服务器 。
温馨提示:如果上面在安装过程中发生了错误,大家可以查看${user_home}/logs/rocketmqlogs中的日志,通过错误日志,能够较为直观的判断错误的原因 。其中${user_home}为用户主目录 。
 
该目录下会有众多的日志文件,如果一开始对这些文件的含义不了解也没关系,大家可以通过 ls -l 命令,逐一查看文件大小不为0的文件,从而寻找错误日志,便于快速解决问题 。
RocketMQ提供了众多的运维命令来查看RocketMQ集群的运行状态,在这里我先简单使用clusterList命令来查看集群的状态,用于验证一下集群的状态 。
sh ./mqadmin clusterList -n 127.0.0.1:9876其运行结果如下图所示:
RocketMQ安装与IDEA Debug环境搭建

文章插图
 
 1.2 安装RocketMQ-Console使用运维命令不太直观,学习成本较大,为此RocketMQ官方提供了一个运维管理界面RokcetMQ-Console,用于对RocketMQ集群提供常用的运维功能,故本节主要讲解如何在Linux环境安装rocketmq-console 。
RocketMQ官方并未提供rocketmq-console的安装包,故需要通过源码进行编译 。
Step1:下载源码
wget https://github.com/apache/rocketmq-externals/archive/rocketmq-console-1.0.0.tar.gztar -xf rocketmq-console-1.0.0.tar.gz# 重命名,为了方便后续操作mv rocketmq-externals-rocketmq-console-1.0.0/rocketmq-consolerocketmq-consoleStep2:修改配置文件
cd rocketmq-consolevi src/main/resources/applications.properties主要是修改指向的nameserver地址,修改结果如下图所示:
RocketMQ安装与IDEA Debug环境搭建

文章插图
 
Step3:使用maven命令编译源代码 。
mvn cleanpackage -DskipTests编译后在target目录下会生成可运行的jar包,如下图所示:


推荐阅读