这里是一个使用rocketmq-spring-boot-starter的例子。 rocketmq-spring-boot
如上面注意项所述,需要开发者在本地build并安装rocketmq-spring-boot-starter
根据RocketMQ官网的quick-start来启动NameServer和Broker,并验证是否启动正确。注意: 测试期间不要停止Broker或者NameServer http://rocketmq.apache.org/docs/quick-start/
创建测试例子所需要的Topic
cd YOUR_ROCKETMQ_HOME bash bin/mqadmin updateTopic -c DefaultCluster -t string-topic bash bin/mqadmin updateTopic -c DefaultCluster -t order-paid-topic bash bin/mqadmin updateTopic -c DefaultCluster -t message-ext-topic bash bin/mqadmin updateTopic -c DefaultCluster -t spring-transaction-topic
# 打开一个终端窗口,编译并启动发送端 cd rocketmq-produce-demo mvn clean package java -jar target/rocketmq-produce-demo-0.0.1-SNAPSHOT.jar # 打开另一个终端窗口,编译并启动消费端 cd rocketmq-consume-demo mvn clean package java -jar target/rocketmq-consume-demo-0.0.1-SNAPSHOT.jar
结合测试代码,观察窗口中消息的发送和接收情况