5. 第4节 如何使用Spring接入RocketMQ
本教程将演示如何在spring框架中使用RocketMQ发送、消费消息。
本教程将简单演示如何发送和消费消息。当前环境已经安装了一个1Namesrv + 1Broker的集群， 演示代码路径：
cd /data/demos
1. 下载RocketMQ Spring代码demo
git clone https://github.com/ApacheRocketMQ/02-spring-demos.git cd 02-spring-demos/
2. 打包，执行代码demo
如下图，找到当前实验环境的公网ip
替换mvn exec:java命令中的namesrv ip地址后，再执行命令， 可以看到正常生产和消费输出
mvn clean package mvn exec:java -Dexec.args="xxx.xxx.xxx.xxx:9876" -Dexec.mainClass="org.apache.rocketmqdemos.Startup" -Dexec.classpathScope=runtime
3. Demo代码说明
- RocketMQ Spring Client中生产者使用的套路分为两个步骤
步骤1: 创建RocetMQ客户端模板对象: RocketMQTemplate, 并且注入namesrv等参数。
步骤2: 调用RocketMQTemplate实例的方法即可。
比如注入生产者代码如下
- RocketMQ Spring Client中消费者只需要一步就可以直接使用
继承RocketMQListener类，实现onMessage()方法即可， demo代码如下：
全部代码可以查看实验本地或者github
