环境要求
64bit JDK 1.8+;
4g+ free disk for Broker server
下载软件
本文直接下载官方编译好的版本:下载地址
开始安装
1.将安装包上传至服务器 /usr/local 目录下
2.解压压缩包
tar - xzf rocketmq-4.9.3.tar.gz
3.修改配置文件
vi /usr/local/rocketmq-4.9.3/conf/broker.conf
添加配置信息
# 自动创建Topic
autoCreateTopicEnable=true
# nameServ地址(你的服务器地址)
namesrvAddr=178.16.1.139:9876
# 存储路径
storePathRootDir=/usr/local/rocketmq-4.9.3/data/
# commitLog路径
storePathCommitLog=/usr/local/rocketmq-4.9.3/data/commitlog
# 消息队列存储路径
storePathConsumeQueue=/usr/local/rocketmq-4.9.3/data/consumequeue
# 消息索引存储路径
storePathIndex=/usr/local/rocketmq-4.9.3/data/index
# checkpoint文件路径
storeCheckpoint=/usr/local/rocketmq-4.9.3/data/checkpoint
# abort文件存储路径
abortFile=/usr/local/rocketmq-4.9.3/data/abort
4.启动
启动 Name Server
> nohup sh bin/mqnamesrv &
> tail -f ~/logs/rocketmqlogs/namesrv.log
The Name Server boot success...
启动 Broker
> nohup sh bin/mqbroker -n localhost:9876 &
> tail -f ~/logs/rocketmqlogs/broker.log
The broker[%s, 178.16.1.139:10911] boot success...
5.发送接受消息测试
> export NAMESRV_ADDR=localhost:9876
> sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
SendResult [sendStatus=SEND_OK, msgId= ...
> sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
ConsumeMessageThread_%d Receive New Messages: [MessageExt...
6.关闭
> sh bin/mqshutdown broker
The mqbroker(36695) is running...
Send shutdown request to mqbroker(36695) OK
> sh bin/mqshutdown namesrv
The mqnamesrv(36664) is running...
Send shutdown request to mqnamesrv(36664) OK
安装控制台
为了省事我使用的docker安装的
docker pull apacherocketmq/rocketmq-dashboard:1.0.0
docker run -d --name rocketmq-dashboard -e "JAVA_OPTS=-Drocketmq.namesrv.addr=178.16.1.139:9876" -p 8080:8080 -t apacherocketmq/rocketmq-dashboard:1.0.0
访问控制台
注意事项
我的服务器防火墙是关闭的,如果你的防火墙是开启的注意打开端口
firewall-cmd --permanent --zone=public --add-port=9876/tcp
firewall-cmd --permanent --zone=public --add-port=8080/tcp
firewall-cmd --permanent --zone=public --add-port=10911/tcp
firewall-cmd --reload