RocketMQTemplate 注入失败的解决

RocketMQTemplate 注入失败

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

1. @Autowired
2. private 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