rocketmq
约 378 字大约 1 分钟
1. 下载
进入apache仓库下载对应版本，本文以rocketmq-4.9.4为例。
2. 安装
- 将压缩包进行解压
unzip rocketmq-all-4.9.4-source-release.zip
mv rocketmq-all-4.9.4-bin-release rocketmq-all-4.9.4
- 配置rocketmq环境变量
export ROCKETMQ_HOME="安装路径"
PATH=$PATH:$ROCKETMQ_HOME/bin
export PATH
- 修改配置
- 修改
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
- 启动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
- 编译并运行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
- 配置
NameServerAddressList
3. 其他
- 常用命令
# 创建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