首页 资讯频道 互联频道 智能频道 网络 数据频道 安全频道 服务器频道 存储频道

如何在CentOS7上安装RocketMQ 4.7.1?

2020-09-10 09:05:18 来源 : 运维派公众号

阿里的fastjson的低版本(<=1.2.68)被爆出有安全漏洞,而RocketMQ 4.7.0使用了fastjson 1.2.62,因此需要将RocketMQ升级到 RocketMQ 4.7.1(fastjson 1.2.69)。

本文描述了在CentOS7上安装RocketMQ 4.7.1的过程,仅作为开发测试环境使用:

单机部署,Name Server和Broker都装在一台服务器上;

调低了RocketMQ默认的JVM大小;

没有设置开机自启动和守护进程。

安装过程

服务器上已经安装了OpenJDK 8,并设置了JAVA_HOME 。

下载和解压RocketMQ

在RocketMQ官网上找到下载RocketMQ 4.7.1的链接,下载和解压RocketMQ:

#下载

wgethttp://ftp.cuhk.edu.hk/pub/packages/apache.org/rocketmq/4.7.1/rocketmq-all-4.7.1-bin-release.zip

#解压

unziprocketmq-all-4.7.1-bin-release.zip

#安装到/usr/local/rocketmq

mvrocketmq-all-4.7.1-bin-release/usr/local

ln-s/usr/local/rocketmq-all-4.7.1-bin-release/usr/local/rocketmq

调低RocketMQ的JVM大小

RocketMQ的默认JVM太大,不适合在开发测试环境中使用,需要调低JVM大小。

在RocketMQ的安装目录(本例为/usr/local/rocketmq),查找sh脚本中的JVM参数设置:

find.-name'*.sh'|xargsegrep'Xms'

需要修改以下sh脚本的JVM参数:

bin/runserver.sh

bin/runbroker.sh

bin/tools.sh

修改前记得先备份相应脚本,具体JVM大小根据实际情况设定。

- bin/runserver.sh

修改前:

JAVA_OPT="${JAVA_OPT}-server-Xms4g-Xmx4g-Xmn2g-XX:MetaspaceSize=128m-XX:MaxMetaspaceSize=320m"

修改后:

JAVA_OPT="${JAVA_OPT}-server-Xms256m-Xmx256m-Xmn128m-XX:MetaspaceSize=128m-XX:MaxMetaspaceSize=320m"

- bin/runserver.sh

修改前:

JAVA_OPT="${JAVA_OPT}-server-Xms4g-Xmx4g-Xmn2g-XX:MetaspaceSize=128m-XX:MaxMetaspaceSize=320m"

修改后:

JAVA_OPT="${JAVA_OPT}-server-Xms256m-Xmx256m-Xmn128m-XX:MetaspaceSize=128m-XX:MaxMetaspaceSize=320m"

- bin/tools.sh修改前:

JAVA_OPT="${JAVA_OPT}-server-Xms1g-Xmx1g-Xmn256m-XX:MetaspaceSize=128m-XX:MaxMetaspaceSize=128m"

修改后:

JAVA_OPT="${JAVA_OPT}-server-Xms256m-Xmx256m-Xmn128m-XX:MetaspaceSize=128m-XX:MaxMetaspaceSize=128m"

启动Name Server

#后台启动

nohupshbin/mqnamesrv>/dev/null2>&1&

Name Server的默认端口为9876,运行sh bin/mqnamesrv -p可查看Name Server的配置项,并可通过-c namesrv.conf方式指定配置文件启动;

RocketMQ的默认日志路径为`~/logs/rocketmqlogs/``;

可以将启动Name Server命令保存为脚本,以方便下次启动。

启动Broker

启动Broker时需要指定要连接的Name Server:

#后台启动

nohupshbin/mqbroker-nlocalhost:9876>/dev/null2>&1&

可以将启动Broker命令保存为脚本,以方便下次启动。

查看RocketMQ进程

ps-ef|grep-vgrep|greprocketmq

测试RocketMQ

测试发送消息和接收消息

使用RocketMQ自带的消息生产者和消费者示例来测试发送消息和接收消息:

exportNAMESRV_ADDR=localhost:9876

shbin/tools.shorg.apache.rocketmq.example.quickstart.Producer

shbin/tools.shorg.apache.rocketmq.example.quickstart.Consumer

关闭RocketMQ

关闭Broker

shbin/mqshutdownbroker

可以将关闭Broker命令保存为脚本,以方便下次关闭。

关闭Name Server

shbin/mqshutdownnamesrv

关闭Name Server前需要先关闭Broker;

可以将关闭Name Server命令保存为脚本,以方便下次关闭。

修改Name Server的端口

RocketMQ Name Server的默认端口为9876,可以通过以下方法修改Name Server的端口:

新增一个Name Server配置文件namesrv.conf,保存内容为:

listenPort=10076

2. 启动Name Server时指定配置文件:

nohupshbin/mqnamesrv-cnamesrv.conf>/dev/null2>&1&

3. 查看RocketMQ进程:

ps-ef|greprocketmq

4. 查看RocketMQ Name Server的端口号:

netstat-tnlp|grep

5. 修改后Broker需要指定新的Name Server地址(端口)。

安装RocketMQ控制台

克隆rocketmq-externals 项目,并编译rocketmq-console。

命令示例:

gitclonehttps://github.com/apache/rocketmq-externals.git

cdrocketmq-externals/rocketmq-console

mvncleanpackage-Dmaven.test.skip=true

将target/rocketmq-console-ng*.jar放到和RocketMQ安装目录(本例为/usr/local/rocketmq)下。

在RocketMQ安装目录下新建一个启动RocketMQ控制台的脚本来启动RocketMQ控制台:

nohupjava-jarrocketmq-console-ng*.jar--server.port=8080--rocketmq.config.namesrvAddr=localhost:9876>/dev/null2>&1&

默认RocketMQ控制台不需要密码登录,请参考RocketMQ使用文档 进行配置。

参见:

https://github.com/apache/rocketmq-externals

https://github.com/apache/rocketmq-externals/tree/master/rocketmq-console

Troubleshooting

问题1: 启动Name Server和Broker,或测试时报错Please set the JAVA_HOME variable in your environment, We need java(x64)!但是系统已经安装了OpenJDK8,并且已经设置了JAVA_HOME。

解决方法: 运行which java来查看java的路径,比如为/usr/bin/java。

修改bin/runserver.sh和bin/runbroker.sh和bin/tools.sh,注释掉校验JAVA_HOME语句,并明确指定JAVA路径:

#[!-e"$JAVA_HOME/bin/java"]&&JAVA_HOME=$HOME/jdk/java

#[!-e"$JAVA_HOME/bin/java"]&&JAVA_HOME=/usr/java

#[!-e"$JAVA_HOME/bin/java"]&&error_exit"PleasesettheJAVA_HOMEvariableinyourenvironment,Weneedjava(x64)!"

#exportJAVA_HOME

exportJAVA="/usr/bin/java"

关键词:CentOS7 RocketMQ 4.7.1
相关文章

最近更新