rocketmq

1. 下载

进入apache仓库下载对应版本，本文以rocketmq-4.9.4为例。

2. 安装

1. 将压缩包进行解压

unzip rocketmq-all-4.9.4-source-release.zip
mv rocketmq-all-4.9.4-bin-release rocketmq-all-4.9.4

2. 配置rocketmq环境变量

export ROCKETMQ_HOME="安装路径"
PATH=$PATH:$ROCKETMQ_HOME/bin
export PATH

3. 修改配置

• 修改namesrv.properties可更改启动端口

listenPort=9876

• 修改bin/runserver.sh可更改启动jvm参数

• 修改conf/broker.conf可更改分片名称以及注册信息

brokerClusterName = DefaultCluster
# 分片名称
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
autoCreateTopicEnable = true
# 注册IP
brokerIP1 = 127.0.0.1
# 启动端口
listenPort = 10911

4. 启动rocketmq

nohup sh mqnamesrv -c ./conf/namesrv.properties > ./mqnamesrv.log 2>&1 &
tail -f ./mqnamesrv.log

nohup sh mqbroker -n localhost:9876 -c ./conf/broker.conf > ./mqbroker.log 2>&1 &
tail -f ./mqbroker.log

5. 编译并运行rocketmq-dashboard

mvn clean package -Dmaven.test.skip=true
java -jar target/rocketmq-dashboard-1.0.1-SNAPSHOT.jar
nohup java -jar -Drocketmq.namesrv.addr=127.0.0.1:9876 -Drocketmq.config.dataPath=./data ./rocketmq-dashboard-1.0.0.jar --server.port=19876 > ./rocketmq-dashboard.log 2>&1 &

在rocketmq.config.dataPath目录下新建users.properties可配置rocketmq-dashboard密码

# Define Admin
admin=123456,1

6. 配置NameServerAddressList

3. 其他

1. 常用命令

# 创建topic
mqadmin updateTopic -n localhost:9876 -b 10.8.0.162:10911 -t jerry_up_mq

# 主题列表
mqadmin topicList -n localhost:9876

# 发送消息
mqadmin sendMessage -n localhost:9876 -b 10.8.0.162:10911 -t jerry_up_mq -p demo

# 打印消息
mqadmin printMsg -n localhost:9876 -t jerry_up_mq

---

【1】RocketMQ 官网