RocketMQTemplate 注入失败的解决

RocketMQTemplate 注入失败

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

@Autowired private RocketMQTemplate rocketMQTemplate ;

注入RocketMQTemplate 失败。

解决方案

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

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

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

RocketMQTemplate的使用

1、pom.xml依赖

<dependency> <groupId> org.apache.rocketmq </groupId> <artifactId> rocketmq-spring-boot-starter </artifactId> <version> 2.0.3 </version> </dependency> <dependency> <groupId> org.apache.rocketmq </groupId> <artifactId> rocketmq-client </artifactId> <version> 4.5.1 </version> </dependency> <dependency> <groupId> org.apache.rocketmq </groupId> <artifactId> rocketmq-common </artifactId> <version> 4.5.1 </version> </dependency>

2、配置文件

# 必须配置 # 指定nameServer rocketmq . nameServer = 192.168 . 168.168 : 9876 # 指定发送者组名 相当于rabbitmq的virtual host 逻辑上的划分 rocketmq . producer . group = my - group # 其他可选配置 #rocketmq.producer.send-message-timeout=300000 #rocketmq.producer测试数据press-message-body-threshold=4096 #rocketmq.producer.max-message-size=4194304 #rocketmq.producer.retry-times-when-send-async-failed=0 #rocketmq.producer.retry-next-server=true #rocketmq.producer.retry-times-when-send-failed=2

3、RocketMQTemplate的基本方法

首先使用@Autowired注入MongoTemplate（后面直接使用，就不特殊说明）

@Autowired private RocketMQTemplate rocketMQTemplate ;

简单使用

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

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

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

查看更多关于RocketMQTemplate 注入失败的解决的详细内容...