RocketMQTemplate 注入失败的解决

时间:2021-07-14 17:20:19

RocketMQTemplate 注入失败

在使用rocketmq 发送消息时,会发现

  1. @Autowired
  2. private RocketMQTemplate rocketMQTemplate;

注入RocketMQTemplate 失败。

解决方案

究其原因是因为,配置文件中,我们没有添加

RocketMQTemplate 注入失败的解决

上图中蓝色的两行代码,指定发送的组名。写上后,问题解决。

好了,再来说说RocketMQTemplate 的基本使用吧~

RocketMQTemplate的使用

1、pom.xml依赖

  1. <dependency>
  2. <groupId>org.apache.rocketmq</groupId>
  3. <artifactId>rocketmq-spring-boot-starter</artifactId>
  4. <version>2.0.3</version>
  5. </dependency>
  6. <dependency>
  7. <groupId>org.apache.rocketmq</groupId>
  8. <artifactId>rocketmq-client</artifactId>
  9. <version>4.5.1</version>
  10. </dependency>
  11. <dependency>
  12. <groupId>org.apache.rocketmq</groupId>
  13. <artifactId>rocketmq-common</artifactId>
  14. <version>4.5.1</version>
  15. </dependency>

2、配置文件

  1. # 必须配置
  2. # 指定nameServer
  3. rocketmq.nameServer=192.168.168.168:9876
  4. # 指定发送者组名 相当于rabbitmq的virtual host 逻辑上的划分
  5. rocketmq.producer.group=my-group
  6. # 其他可选配置
  7. #rocketmq.producer.send-message-timeout=300000
  8. #rocketmq.producer.compress-message-body-threshold=4096
  9. #rocketmq.producer.max-message-size=4194304
  10. #rocketmq.producer.retry-times-when-send-async-failed=0
  11. #rocketmq.producer.retry-next-server=true
  12. #rocketmq.producer.retry-times-when-send-failed=2

3、RocketMQTemplate的基本方法

首先使用@Autowired注入MongoTemplate(后面直接使用,就不特殊说明)

  1. @Autowired
  2. private RocketMQTemplate rocketMQTemplate;

简单使用

  1. //发送消息
  2. public class ProducerController {
  3. @Autowired
  4. private RocketMQTemplate rocketMQTemplate;
  5.  
  6. public void send(){
  7. //实体类User
  8. User user=new User(999L,"testUser");
  9. //发送自定义对象
  10. rocketMQTemplate.convertAndSend("test_topic",user);//会自动转换为json格式
  11. }
  12. }
  1. //接收消息
  2. @Component //必须注入spring容器
  3. @RocketMQMessageListener(
  4. topic = "test_topic", //topic:消息的发送者使用同一个topic
  5. consumerGroup = "test_my-consumer", //group:不用和生产者group相同
  6. selectorExpression = "*") //tag
  7. // 在RocketMQ中消费者和发送者组没有关系
  8. // 如果两个消费者groupname和topic都一样,则二者轮循接收消息
  9. // 如果两个消费者topic一样,而group不一样,则消息变成广播机制
  10. // RocketMQListener<>泛型必须和接收的消息类型相同
  11. public class TestListner implements RocketMQListener<User> {
  12. private static final ObjectMapper MAPPER = new ObjectMapper();
  13. @Override
  14. public void onMessage(User user) {
  15. JsonNode jsonNode = MAPPER.readTree(user);//可以使用mapper读取json格式数据
  16. Long userId = jsonNode.get("userId").asLong();
  17. System.out.println(user);
  18. }
  19. }

以上为个人经验,希望能给大家一个参考,也希望大家多多支持我们。

原文链接:https://blog.csdn.net/taiguolaotu/article/details/113447642