RocketMQ环境搭建

1. 安装

cd /usr/local
wget http://mirrors.tuna.tsinghua.edu.cn/apache/rocketmq/4.4.0/rocketmq-all-4.4.0-source-release.zip
unzip rocketmq-all-4.4.0-source-release.zip
cd rocketmq-all-4.4.0/
mvn -Prelease-all -DskipTests clean install -U
cd distribution/target/apache-rocketmq

# Start Name Server
// 虚拟机内存小时需要修改配置
cd /usr/local/rocketmq-all-4.4.0/distribution/target/apache-rocketmq/bin

vim runserver.sh
#JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn125m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

cd /usr/local/rocketmq-all-4.4.0/distribution/target/apache-rocketmq/
nohup sh bin/mqnamesrv &
tail -f ~/logs/rocketmqlogs/namesrv.log
The Name Server boot success...

# Start Broker
// 虚拟机内存小时需要修改配置
cd /usr/local/rocketmq-all-4.4.0/distribution/target/apache-rocketmq/bin

vim runbroker.sh
#JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -Xmn4g"
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn125m"

cd /usr/local/rocketmq-all-4.4.0/distribution/target/apache-rocketmq/
nohup sh bin/mqbroker -n localhost:9876 &
tail -f ~/logs/rocketmqlogs/broker.log
The broker[%s, 172.30.30.233:10911] boot success...

2. 发送、接收消息

cd /usr/local/rocketmq-all-4.4.0/distribution/target/apache-rocketmq
export NAMESRV_ADDR=localhost:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
SendResult [sendStatus=SEND_OK, msgId= ...

cd /usr/local/rocketmq-all-4.4.0/distribution/target/apache-rocketmq
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
ConsumeMessageThread_%d Receive New Messages: [MessageExt...

3. 关闭

cd /usr/local/rocketmq-all-4.4.0/distribution/target/apache-rocketmq

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

4. Console搭建

cd /usr/local
git clone https://github.com/apache/rocketmq-externals.git

cd rocketmq-externals/rocketmq-console
mvn clean package -Dmaven.test.skip=true

cd target
nohup java -jar rocketmq-console-ng-1.0.1.jar --server.port=12581 --rocketmq.config.namesrvAddr=localhost:9876 &

5. 常用命令

cd /usr/local/rocketmq-all-4.4.0/distribution/target/apache-rocketmq/bin

# 查看集群情况
./mqadmin clusterList -n localhost:9876

# 查看 broker 状态
./mqadmin brokerStatus -n localhost:9876 -b localhost:10911

# 查看 topic 列表
./mqadmin topicList -n localhost:9876

# 查看 topic 状态
./mqadmin topicStatus -n localhost:9876 -t BenchmarkTest (换成想查询的 topic)

# 查看 topic 路由
./mqadmin topicRoute -n localhost:9876 -t BenchmarkTest