MQ下载地址
下载RocketMQ 4.7.1版本
RocketMQ运行版本下载地址:https ://archive.apache.org/dist/rocketmq/4.7.1/rocketmq-all-4.7.1-bin-release.zip
RocketMQ源码版本下载地址: Apache Download Mirrors
这两个版本我们都下载下来。
下面开启MQ安装步骤介绍:
安装Mq还是比较简单的,完全可以说So easy啦,废话不多说,马上上手起来。。。
温馨提示安装MQ,需要JAVA环境,所有没有安装Java环境的小伙伴可以参考本篇笔记:工欲善其事,必先利其器 ,搭建小小的JAVA环境还不是手到擒来的小事
MQ环境配置
JAVA环境配置完成后,然后我们把下载的rocketmq-all-4.7.1-bin-release.zip解压到指定目录下,把rocketmq的bin目录也配置到环境变量当中
vi ~/.bash_profile,加入以下内容,并执行source ~/.bash_profile让环境变量生效:
export ROCKETMQ_HOME=/home/rocketmq-all-4.7.1-bin-release
export PATH =$PATH:$ROCKETMQ_HOME/bin
这样RocketMQ就安装完成了。我们把他运行起来
注意:( 这个ROCKETMQ_HOME的环境变量是必须要单独配置的,如果不配置的话,启动NameSever和Broker都会报错。这个环境变量的作用是用来加载$ROCKETMQ_HOME/conf下的除broker.conf以外的几个配置文件。所以实际情况中,可以不按这个配置,但是一定要能找到配置文件。)
MQ启动
启动NameServer服务:
nohup bin/mqnamesrv &
启动完成后,在nohup.out里看到这一条关键日志就是启动成功了
Java HotSpot(TM) 64-Bit Server VM warning: Using the DefNew young collector with the CMS collector is deprecated and will likely be removed in a future release Java HotSpot(TM) 64-Bit Server VM warning: UseCMSCompactAtFullCollection is deprecated and will likely be removed in a future release.
The Name Server boot success. serializeType=JSON
启动broker服务:
nohup bin/mqbroker &
确定启动无误后通过下面命令来验证启动:
bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
MQ服务关闭
# 1.关闭NameServer
sh bin/mqshutdown namesrv
# 2.关闭Broker
sh bin/mqshutdown broker
MQ启动broker可以通过指定配置启动:
指定配置文件启动Broker
创建broker.conf,内容如下:
brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
namesrvAddr=192.168.36.132:9876
deleteWhen = 04
fileReservedTime = 48
brokerRole =ASYNC_MASTER
flushDiskType =ASYNC_FLUSH
#自动生成topic主题
autoCreateTopicEnable=true
listenPort=10911
#消息存储根路径
storePathRootDir=/home/rocketmq-all-4.7.1-bin-release/store
#日志路径
storePathCommitLog=/home/rocketmq-all-4.7.1-bin-release/store/commitlog
brokerIP1=192.168.36.132
启动命令:
nohup bin/mqbroker -n 192.168.36.132:9876 -c conf/broker.conf &
或者直接使用
nohup bin/mqbroker -c conf/broker.conf &
-n 指定Ip地址
-c 指定配置文件
在这里提一下,nameServer使用的是CMS垃圾回收器,而Broker使用的是G1垃圾回收器。
MQ配置完成启动Broker如果出现问题,可以参考这篇博客:RocketMQ第三篇 安装过程遇到的问题解决方案