RocketMQ下载
直接从 RocketMQ 官网下载最新的安装包
下载地址:https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.9.2/rocketmq-all-4.9.2-bin-release.zip
如下图:
RocketMQ安装
1.创建rocketmq目录
用来存放rocketmq相关的东西:
mkdir /usr/rocketmq cd /usr/rocketmq
2.解压安装包
由于下载的是zip压缩格式文件,因此在linux上安装unzip来进行解压:
# unzip rocketmq-all-4.9.2-bin-release.zip
3.修改文件名称
解压后修改文件夹名称:
mv rocketmq-4.9.2/ rocketmq
4.配置环境变量
将刚刚解压的 rocketmq 路径配置到环境变量中:
命令:
vi /etc/profile
修改环境变量:
export ROCKETMQ_HOME=/usr/rocketmq export PATH=$PATH:$ROCKETMQ_HOME/bin:$PATH
使刚修改的配置文件生效:
source /etc/profile
RocketMQ启动验证
1.启动 nameserver
命令:
nohup sh bin/mqnamesrv &
nohup sh mqnamesrv & :属于后台启动,也可以sh mqnamesrv :属于终端启动,直接输出日志信息。
再查看是否启动成功:
jps -l
2.配置JVM参数
RocketMQ Broker 默认配置的 jvm 虚拟机内存大小可能比较大,如果不修改会导致启动不起来,这里我们根据自己的实际需要进行修改。
命令:
vi bin/runbroker.sh
将画圈的地方设置小点,当然也别太小啊。
修改为:
-server -Xms1g -Xmx1g -Xmn512m
3.启动Broker
命令:
nohup sh bin/mqbroker -c conf/broker.conf &
查看是否启动成功:
jps -l
如果出现下图,说明已经启动成功了。
4.模拟发送消息和消费消息
目前 NameServer 和 Broker 都已经启动成功,就可以进行发送和消费消息。
RocketMQ 安装包默认:提供了一个模拟发送消息和消费消息的测试类,我们来验证一下。
1.创建生产者发送消息
命令:
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
2.消费消息
命令:
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
通过模拟发送和消费,也就验证了我们整个 RocketMQ 就搭建成功了。
陈睿mikechen
10年+大厂架构经验,资深技术专家,就职于阿里巴巴、淘宝、百度等一线互联网大厂。
关注「mikechen」公众号,获取更多技术干货!
后台回复【面试】即可获取《史上最全阿里Java面试题总结》,后台回复【架构】,即可获取《阿里架构师进阶专题全部合集》