Python 官方文档:入门教程 => 点击学习
RocketMQTemplate 注入失败 在使用rocketMQ 发送消息时,会发现 @Autowired private RocketMQtemplate rocketM
在使用rocketMQ 发送消息时,会发现
@Autowired
private RocketMQtemplate rocketMQTemplate;
注入RocketMQTemplate 失败。
究其原因是因为,配置文件中,我们没有添加
上图中蓝色的两行代码,指定发送的组名。写上后,问题解决。
好了,再来说说RocketMQTemplate 的基本使用吧~
<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>
# 必须配置
# 指定nameServer
rocketmq.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
首先使用@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);
}
}
以上为个人经验,希望能给大家一个参考,也希望大家多多支持编程网。
--结束END--
本文标题: RocketMQTemplate 注入失败的解决
本文链接: https://www.lsjlt.com/news/129669.html(转载时请注明来源链接)
有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
下载Word文档到电脑,方便收藏和打印~
2024-03-01
2024-03-01
2024-03-01
2024-02-29
2024-02-29
2024-02-29
2024-02-29
2024-02-29
2024-02-29
2024-02-29
回答
回答
回答
回答
回答
回答
回答
回答
回答
回答
0