RocketMQTemplate|RocketMQTemplate 注入失败的解决 RocketMQTemplate注入失败的解决

RocketMQTemplate 注入失败在使用rocketmq 发送消息时，会发现

@Autowired private RocketMQTemplate rocketMQTemplate;

注入RocketMQTemplate 失败。
解决方案
究其原因是因为,配置文件中，我们没有添加

RocketMQTemplate|RocketMQTemplate 注入失败的解决

文章图片

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

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

1、pom.xml依赖

org.apache.rocketmqrocketmq-spring-boot-starter2.0.3org.apache.rocketmqrocketmq-client4.5.1org.apache.rocketmqrocketmq-common4.5.1

2、配置文件

# 必须配置# 指定nameServerrocketmq.nameServer=192.168.168.168:9876 # 指定发送者组名相当于rabbitmq的virtual host 逻辑上的划分rocketmq.producer.group=my-group# 其他可选配置#rocketmq.producer.send-message-timeout=300000#rocketmq.producer.compress-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（后面直接使用，就不特殊说明）

@Autowiredprivate RocketMQTemplate rocketMQTemplate;

简单使用

//发送消息public class ProducerController {@Autowiredprivate RocketMQTemplate rocketMQTemplate; public void send(){//实体类UserUser user=new User(999L,"testUser"); //发送自定义对象rocketMQTemplate.convertAndSend("test_topic",user); //会自动转换为json格式 }}

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

【RocketMQTemplate|RocketMQTemplate 注入失败的解决】以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。