下载 RocketMQ
我下载的版本是：4.9.3
下载地址 Apache Downloads
环境说明
- Linux64 位系统
- JDK1.8+ (64位)
安装步骤
第一步：传入文件到 Linux 服务器
先将下载好的包传到 linux 服务器上面去
这里我传入的路径是在 /usr/local
第二步：解压压缩文件
使用命令解压 unzip rocketmq-all-4.9.3-bin-release.zip ，解压之后的进入 rocketmq 目录，简单介绍下文件目录：
- bin：启动脚本，包括shell脚本和CMD脚本
- conf：实例配置文件 ，包括broker配置文件、logback配置文件等
- lib：依赖jar包，包括Netty、commons-lang、FastJSON等
第三步：启动
启动 NameServer
# 1.进入 bin 目录, 启动 NameServer
nohup sh mqnamesrv &
# 2.查看启动日志
tail -f ~/logs/rocketmqlogs/namesrv.log
启动 Broker
# 1.启动Broker
nohup sh bin/mqbroker -n localhost:9876 &
或者
nohup sh mqbroker -n localhost:9876 &
# 2.查看启动日志
tail -f ~/logs/rocketmqlogs/broker.log
在启动的时候发现报错
问题的发现，在使用 nohup sh mqnamesrv & 时发先，程序一直启动不起来，然后就使用 sh mqnamesrv 发现问题如下：
找到 runserver.sh 和 runbroker.sh 以及 tools.sh 修改下 JAVA_OPT 的参数
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn125m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
修改完成之后，再次启动 sh mqnamesrv 就没有报错了
第四步：测试发送消息
这个时候需要开启两个终端进行测试
发送消息
开启第一个终端
# 1.设置环境变量
export NAMESRV_ADDR=localhost:9876
# 2.使用安装包的Demo发送消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
发送消息之后，刷屏太快了，最后的截图
接受消息
开启另外一个终端
# 1.设置环境变量
export NAMESRV_ADDR=localhost:9876
# 2.接收消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
关闭RocketMQ
# 1.关闭NameServer
sh bin/mqshutdown namesrv
# 2.关闭Broker
sh bin/mqshutdown broker
