郑州网站设计制作网站域名年费

准备环境和安装包

rocketmq是基于Java语言开发所以搭建之前需要确保安装了jdk。这里使用jdk8即可。

#下载安装包
wget https://dist.apache.org/repos/dist/release/rocketmq/5.3.3/rocketmq-all-5.3.3-bin-release.zip
#解压
unzip rocketmq-all-5.3.3-bin-release.zip

开始安装

切换到安装解压目录下面去，如果内存足够的情况下可以不用去修改namesrv和broker的内存大小。

cd rocketmq-all-5.3.3-bin-release
#修改broker内存大小

修改broker堆内存大小 vim bin/runbroker.sh ，把xms xmx原本是8g改为1g。根据实际内存调整

-server -Xms1g -Xmx1g

修改namesrv的堆内存大小 vim bin/runserver.sh。和broker操作类似。根据实际情况调整即可。

启动namesrv

nohup bin/mqnamesrv &

如果你的mq服务需要别的网段访问，还需要改一下conf/broker.conf的ip地址。不需要可以跳过 就默认的就行
vim conf/broker.conf

brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
# 实际IP
brokerIP1=192.169.40.199                 

启动broker

nohup bin/mqbroker -n localhost:9876 -c conf/broker.conf  &

编写统一启动脚本

编写一个简单的一键启动脚本 方便启动
vim start-mq.sh

#!/bin/bash
nohup bin/mqnamesrv  >> namesrv.log 2>&1 &
echo "namesrv start complete"
nohup bin/mqbroker -n localhost:9876 -c conf/broker.conf  >> broker.log 2>&1 &
echo "broker start complete"

可视化仪表盘Dashboard

源码下载地址源码rocketmq-dashboard 导入idea进行编译后即可。我这里也编译了一个2.0.1的jar包分享给大家 rocketmq-dashboard jar包下载
下载后直接启动即可 命令如下：

java -jar rocketmq-dashboard-2.0.1-SNAPSHOT.jar