一、Rocket 部署

1.下载RocketMq

https://mirror.bit.edu.cn/apache/rocketmq/4.7.0/

1. 上传到linux服务

 

2.安装RocketMq

unzip rocket rocketmq-all-4.7.0-bin-release.zip

创建rocketmq文件夹：mkdir /usr/local/rocketmq

移动到 usr/local/rocketmq

 

3.启动 NamesServer

#启动

cd /usr/local/rocketmq/bin

nohup sh mqnamesrv &

 

#查看启动日志

tail -f ~/logs/rocketmqlogs/namesrv.log

 

 

 

4.启动Broker

# 1.启动Broker

cd /usr/local/rocketmq/bin

nohup sh mqbroker -n localhost:9876 &

#2.查看日志

tail -f ~/logs/rocketmqlogs/broker.log

 

问题描述：

RocketMQ 默认的虚拟机内存较大，启动Broker如果因为内存不足失败，修改JVM内存大小

 

默认8G 太大了！！

#编辑runbroker.sh 和 runserver.sh 修改默认JVM大小

vi runbroker.sh

vi runserver.sh

重新启动broker 启动命令在上面！

 

jps 命令查看进程

 

5.关闭RocketMQ

sh mqshutdown namesrv

sh mqshutdown broker

 

 

 

 

6.测试RocketMQ

发送消息

1.设置环境变量

export NAMESRV_ADDR=localhost:9876

2.使用安装包的Demo发送消息

cd /usr/local/rocketmq/bin

sh tools.sh org.apache.rocketmq.example.quickstart.Producer

接收消息

1.设置环境变量

export NAMESRV_ADDR=localhost:9876

2.接收消息

cd /usr/local/rocketmq/bin

sh tools.sh org.apache.rocketmq.example.quckstart.Consumer

效果图：

 

 

二、RocketMQ集群部署

未完待续….