RocketMQ 4.7.1安装

诺米 • • 中间件 • 2061 阅读

一、在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/runbroker.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
[alert size="0" icon="" type="default"]

注意事项及存在的问题：
手动创建topic命令：
sh mqadmin updateTopic -c 集群名称（broker.conf中） -n 公网IP:9876 -t topic名称

RocketMQ规定，在使用updateTopic命令创建topic时，-b或-c选项必须指定其中一个（都指定则处理-b参数，忽略-c参数），与此同时，-t参数也为必要参数，缺少这几个必要参数则topic创建失败！！！
使用Java代码手动创建topic的形式中，使用-b选项创建topic可以正常使用，此时RocketMQ直接使用指定的broker地址来找到broker并在对应broker上创建topic。

[/alert]

七、关闭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地址（端口）。

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

[alert size="0" icon="" type="default"]

MQ启动正常，但生产消费超时，解决方案
Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is org.springframework.messaging.MessagingException: sendDefaultImpl call timeout; nested exception is org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl call timeout] with root cause org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl call timeout at

1. nameserver
name server 启动时 ip修改为你服务器对应公网ip
nohup ./bin/mqnamesrv -n 你的公网IP:9876 &

不要写localhost

2. broker
在conf/broker.conf 中 加入以下信息：
brokerIP1=你的公网IP

broker 启动
nohup sh bin/mqbroker -n 你的公网IP:9876 -c conf/broker.conf autoCreateTopicEnable=true &

[/alert]
[alert size="0" icon="" type="default"]

相关服务说明：
rocktMq中nameserv相当于一个zookeeper，充当一个注册的角色，所以brocker和我们的代码producer是通过nameserv来进行同行的。

brocker的启动命令中 -n xxxx:9876 就是指定 mqnameserv ，producer的代码中 也是 producer.setNamesrvAddr(“xxxx:9876”); ，这里都是指定的mqnameserv。

topic没有创建 在brocker的启动命令中加入autoCreateTopicEnable=true 就可以了（待验证）
sh mqbroker -n 10.0.1.1:9876 autoCreateTopicEnable=true

[/alert]

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

1、所有文章未经授权禁止转载、摘编、复制或建立镜像，如有违反，追究法律责任。
2、本站文章部分来源注册用户发布或互联网收集而来，若有侵权，请邮件联系作者。
邮箱地址：wtao219@qq.com
THE END
分享
二维码
< <上一篇
下一篇>>