SpringBoot中使用RocketMQ的示例代码 SpringBoot中使用RocketMQ的示例代

1 订单微服务发送消息

1.1 订单微服务添加rocketmq的依赖
1.2 添加配置
1.3 编写测试代码
1.4 测试

2 用户微服务订阅消息

2.1 用户微服务增加rocketmq依赖
2.2 修改主类，启动nacos客户端
2.3 修改配置文件
2.4 编写消息接收服务
2.5 测试

接下来我们模拟一种场景：商品下单成功之后，向下单用户发送短信。以此来示例SpringBoot中RocketMQ的使用方式。

文章图片

1 订单微服务发送消息
1.1 订单微服务添加rocketmq的依赖

org.apache.rocketmqrocketmq-spring-boot-starter2.1.1org.apache.rocketmqrocketmq-client4.7.1

1.2 添加配置

rocketmq:name-server: 192.168.232.129:9876 # rocketmq服务的地址producer:group: jack-producer-group# 生产者组名

1.3 编写测试代码

package cn.jack.controller; import cn.jack.domain.Order; import cn.jack.domain.Product; import cn.jack.service.OrderService; import cn.jack.service.ProductService; import com.alibaba.fastjson.JSON; import lombok.extern.slf4j.Slf4j; import org.apache.rocketmq.spring.core.RocketMQTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.cloud.client.discovery.DiscoveryClient; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import org.springframework.web.client.RestTemplate; @RestController@Slf4jpublic class OrderController { @Autowiredprivate RestTemplate restTemplate; @Autowiredprivate OrderService orderService; @Autowiredprivate DiscoveryClient discoveryClient; @Autowiredprivate ProductService productService; @Autowiredprivate RocketMQTemplate rocketMQTemplate; /*** 下单 -- 基于Feign实现服务调用* @param pid商品id* @return*/@RequestMapping("/order/prod/{pid}")public Order order(@PathVariable("pid") Long pid) {log.info("收到下单请求，准备查询商品信息。pid={}", pid); // 通过Feign调用商品微服务，查询商品信息Product product = this.productService.findByPid(pid); log.info("商品信息查询成功。内容为：{}", JSON.toJSONString(product)); // 进行容错判断if (product.getPid() == -100) {Order order = new Order(); order.setOid(-100L); order.setPname("下单失败"); return order; } // 生成商品信息保存Order order = new Order(); order.setNumber(1); order.setPid(pid); order.setPname(product.getPname()); order.setPprice(product.getPprice()); order.setUid(1); order.setUsername("陈家宝"); this.orderService.createOrder(order); log.info("订单信息保存成功。内容为：{}", JSON.toJSONString(order)); // TODO 下单成功之后，mq发送订单内容消息rocketMQTemplate.convertAndSend("jack-topic", order); return order; }}

1.4 测试
访问下单接口，确认RocketMQ是否发送了消息。从RocketMQ控制台得到确认，消息发送成功。

文章图片

【SpringBoot中使用RocketMQ的示例代码】

文章图片

2 用户微服务订阅消息
2.1 用户微服务增加rocketmq依赖

com.alibaba.cloudspring-cloud-starter-alibaba-nacos-discovery org.apache.rocketmqrocketmq-spring-boot-starter2.1.1org.apache.rocketmqrocketmq-client4.7.1

2.2 修改主类，启动nacos客户端

package cn.jack; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; @SpringBootApplication@EnableDiscoveryClientpublic class UserApplication {public static void main(String[] args) {SpringApplication.run(UserApplication.class); }}

2.3 修改配置文件

rocketmq:name-server: 192.168.232.129:9876 # rocketmq服务的地址

2.4 编写消息接收服务

package cn.jack.service; import cn.jack.domain.Order; import lombok.extern.slf4j.Slf4j; import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; import org.apache.rocketmq.spring.core.RocketMQListener; import org.springframework.stereotype.Service; @Slf4j@Service@RocketMQMessageListener(consumerGroup = "jack-consumer-group", topic = "jack-topic")public class SmsService implements RocketMQListener {@Overridepublic void onMessage(Order order) {log.info("收到订单信息，内容如下：{}，接下来进行短信发送", order); }}

2.5 测试
启动用户微服务，收到了来自RocketMQ的消息。

2020-09-16 21:46:30.465 INFO [service-user,,,] 660 --- [MessageThread_2] cn.jack.service.SmsService : 收到订单信息，内容如下：Order(oid=66, uid=1, username=陈家宝, pid=2, pname=雪梨, pprice=2000.0, number=1)，接下来进行短信发送
2020-09-16 21:46:30.465 INFO [service-user,,,] 660 --- [MessageThread_1] cn.jack.service.SmsService : 收到订单信息，内容如下：Order(oid=65, uid=1, username=陈家宝, pid=3, pname=华为, pprice=8000.0, number=1)，接下来进行短信发送

消息成功消费：