三、RocketMQ下载和安装
下载地址：https://rocketmq.apache.org/download
我这里下载的是5.1.0版本的，下载后上传到服务器
解压
unzip rocketmq-all-5.1.0-bin-release.zip
进入rocketmq-all-5.1.0-bin-release
进入bin目录，需要修改一些配置，需要找到runserver.sh和runbroker.sh两个文件
修改runserver.sh文件
# 找到文件中下面这一行:
JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
# 将 -Xms4g -Xmx4g -Xmn2g 修改为 -Xms256m -Xmx256m -Xmn128m
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"修改runbroker.sh文件
# 找到文件中下面这一行:
JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g"
# 将 -Xms8g -Xmx8g 修改为 -Xms256m -Xmx256m
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m"启动RocketMQ
（1）先启动name server；
# 进入bin目录
cd bin
# 启动 name server
nohup sh mqnamesrv &
# 查看运行日志
tail -f nohup.out
tail这个命令会持续输出文件的新内容，按Ctrl+C可以结束
（2）再启动broker
# 启动 broker, 并连接到name server；localhost:9876
cd /usr1/rocketmq/bin/
nohup sh mqbroker -n localhost:9876 &
也可以
nohup sh mqbroker -n localhost:9876 -c ../conf/broker.conf
-n 指定的是注册到哪个消息服务器上
-c 指定的是刚刚修改的conf配置文件
# 查看运行日志
tail -f nohup.out
使用jps命令可以列出Java进程
关闭RocketMQ
#要关闭RocketMQ服务可以通过mqshutdown脚本直接关闭
# 1.关闭NameServer
sh bin/mqshutdown namesrv
# 2.关闭Broker
sh bin/mqshutdown broker快速测试
# 退回到bin目录的上一级
cd ..
# 首先需要配置一个环境变量NAMESRV_ADDR指向我们启动的NameServer服务。
export NAMESRV_ADDR='localhost:9876'
#然后启动消息生产者发送消息：默认会发1000条消息
bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
# 然后启动消息消费者接收消息：
bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
这个Consume指令并不会结束，他会继续挂起，等待消费其他的消息。我们可以使用CTRL+C停止该进程。
