Spring Cloud Alibaba RocketMQ#
RocketMQ#
unzip rocketmq-all-4.4.0-bin-release.zip -d /usr/local/
mkdir logs
vi bin/runbroker.sh
JAVA_OPT="${JAVA_OPT} -server -Xms2g -Xmx2g -Xmn1g"
vi ~/.bashrc
export ROCKETMQ_HOME=/usr/local/rocketmq-all-4.4.0-bin-release
export PATH=${JAVA_HOME}/bin:${ROCKETMQ_HOME}/bin:$PATH
Start RocketMQ#
nohup sh mqnamesrv &
nohup sh mqbroker -n localhost:9876 &
nohup mqnamesrv > $ROCKETMQ_HOME/logs/mqnamesrv.log 2> $ROCKETMQ_HOME/logs/mqnamesrv.log &
nohup mqbroker -n localhost:9876 > $ROCKETMQ_HOME/logs/mqbroker.log 2> $ROCKETMQ_HOME/logs/mqbroker.log &
Shutdown Servers#
sh mqshutdown broker
sh mqshutdown namesrv
CLI Admin Tool#
sh mqadmin
sh mqadmin updateTopic -n localhost:9876 -c DefaultCluster -t test-topic
mqadmin topicRoute -n 127.0.0.1:9876 -t test-topic
mqadmin topicStatus -n 127.0.0.1:9876 -t test-topic
mqadmin topicClusterList -n 127.0.0.1:9876 -t test-topic
mqadmin brokerStatus -b 127.0.0.1:10911
mqadmin printMsg -n 127.0.0.1:9876 -t test-topic
mqadmin clusterList -n 127.0.0.1:9876
mqadmin topicList -n 127.0.0.1:9876