Spring Cloud Alibaba RocketMQ

RocketMQ

Download 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

Spring Cloud Stream

References

• RocketMQ Example

• Quick Start

• CLI Admin Tool

• Spring Cloud Stream 体系及原理介绍