RocketMQ 4.7.1安装

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

# 下载
wget http://ftp.cuhk.edu.hk/pub/packages/apache.org/rocketmq/4.7.1/rocketmq-all-4.7.1-bin-release.zip

# 解压
unzip rocketmq-all-4.7.1-bin-release.zip

# 安装到/usr/local/rocketmq
mv rocketmq-all-4.7.1-bin-release /usr/local
ln -s /usr/local/rocketmq-all-4.7.1-bin-release /usr/local/rocketmq

内网环境,不能访问外网,提供网盘下载地址:

链接:https://pan.baidu.com/s/1i6edL1yw4x1BetWUwWQZHg
提取码:ht3w

官网下载

连接:https://rocketmq.apache.org/dowloading/releases/

二、调低RocketMQ的JVM大小

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

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

find . -name '*.sh' | xargs egrep '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

# 后台启动
nohup sh bin/mqnamesrv >/dev/null 2>&1 &

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

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

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

四、启动Broker

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

# 后台启动
nohup sh bin/mqbroker -n localhost:9876 >/dev/null 2>&1 &

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

五、查看RocketMQ进程

ps -ef | grep -v grep | grep rocketmq

六、测试RocketMQ

测试发送消息和接收消息

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

export NAMESRV_ADDR=localhost:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

七、关闭RocketMQ

关闭Broker
sh bin/mqshutdown broker

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

关闭Name Server
sh bin/mqshutdown namesrv

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

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

八、修改Name Server的端口

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

  1. 新增一个Name Server配置文件namesrv.conf,保存内容为:
listenPort=10076
  1. 启动Name Server时指定配置文件:
nohup sh bin/mqnamesrv -c namesrv.conf >/dev/null 2>&1 &
  1. 查看RocketMQ进程:
ps -ef | grep rocketmq
  1. 查看RocketMQ Name Server的端口号:
netstat -tnlp | grep 
  1. 修改后Broker需要指定新的Name Server地址(端口)。

————————————————————-下面为拓展补充————————————————————

了解更多rocketMq配置点我传送!!

1、原创文章,作者:诺米,如若转载,请注明出处:https://www.http3w.com/archives/814

2、本站内容若有雷同从属巧合,若侵犯了您的权益,请联系本站删除,E-mail: wtao219@qq.com

发表评论

您的电子邮箱地址不会被公开。 必填项已用*标注