RocketMQ环境搭建

1. 安装包下载。

Apache官网下载 RocketMQ官网
下载文件解压后，可以看到conf文件夹里有2m-noslave、2m-2s-async、2m-2s-sync文件夹：

2m-noslave 两主,无从的配置
2m-2s-async 两主，两从，同步复制数据的配置
2m-2s-sync 两主，两从，异步复制数据的配置

image.png

上述配置是需要配置集群模式配置的内容，如果配置单机模式，可以不用理会。
上述配置文件的详细配置可参考官网。

环境变量配置

linux
环境变量配置(JAVA_HOME和ROCKETMQ_HOME)
vim /etc/profile
修改如下配置

export JAVA_HOME=/usr/java/jdk1.8.0_102
export ROCKETMQ_HOME=/usr/local/rocketmq
export PATH=$PATH:$JAVA_HOME/bin:$ROCKETMQ_HOME/bin:$PATH
export CLASSPATH=.:$JAVA_HOME/lib

window
计算机-高级配置-环境变量

image.png

2. 修改nameServer和broker中内存大小。（如果linux或者windows内存不够的话）

由于本地内存不足4G，因此修改如下

runServer.cmd:

image.png
runBroker.cmd:

image.png

linux环境对应修改上述sh文件即可

3. 管理平台下载

请参考文章 windows下Apache.RocketMQ安装部署第三节插件部署模块，这里不做详述。
【注意要修改下console项目的applicate属性文件中namesrvAddr，默认为空】
打包编译命令

mvn clean package -Dmaven.test.skip=true

4. 启动命令

启动mqnamesrv
windows:
如果需要指定日志路径，先去指定目录创建logs文件夹，这样启动命令后面就可以指定日志路径了。

cd F:\soft-install\rocketmq-4.4.0\bin

start  mqnamesrv.cmd >F:\soft-install\rocketmq-4.4.0\logs\mqnamesrv.log

linux:

nohup sh mqnamesrv >/usr/local/rocketmq/logs/mqnamesrv.log 2>&1 &

启动mqbroker
windows：

cd F:\soft-install\rocketmq-4.4.0\bin

start mqbroker.cmd -n "127.0.0.1:9876" autoCreateTopicEnable=true >F:\soft-install\rocketmq-4.4.0\logs\mqbroker.log

linux：

nohup sh mqbroker -n "127.0.0.1:9876" autoCreateTopicEnable=true> /usr/local/rocketmq/logs/mqbroker.log  2>&1 &

要设置自动创建Topic，需要加上 
autoCreateTopicEnable=true

关闭Broker服务 
sh mqshutdown broker

（还可以加上-c broker文件，指定使用哪个broker文件-c /usr/local/rocketmq/conf/2m-noslave/broker-a.properties ）

启动管理平台
windows：进入编译好的target目录，执行java -jar命令（可以通过参数动态修改服务端口号，以及nameServer的地址和端口，如果编译时没指定的话可以在启动的时候通过参数指定）。

java -jar rocketmq-console-ng-1.0.0.jar --server.port=8080 --rocketmq.config.namesrvAddr=127.0.0.1:9876

linux 同windows。

5. 管理平台使用

部署成功，打开http://服务器IP:8080

image.png

查看和创建topic

image.png

查看服务消费者（消费者组）

image.png
查看指定Topic的消息

image.png

参考文章
1、官方指南
2、 RocketMQ入门手册
3、 RocketMQ运维指令

最后编辑于：2019.03.23 12:04:32