RocketMQTemplate 注入失败的解决

网友投稿 1615 2023-01-01

RocketMQTemplate 注入失败的解决

RocketMQTemplate 注入失败的解决

RocketMQTemplate 注入失败

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

@Autowired

private RocketMQTemplate rocketMQTemplate;

注入RocketMQTemplate 失败。

解决方案

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

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

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

RocketMQTemplate的使用

1、pom.xml依赖

org.apache.rocketmq

rocketmq-spring-boot-starter

2.0.3

org.apache.rocketmq

rocketmq-client

4.5.1

org.apache.rocketmq

rocketmq-common

4.5.1

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.compress-message-body-threshold=4096

#rocketmq.producer.max-message-size=41943http://04

#rocketmq.producer.retry-times-when-send-async-failed=0

#rocketmq.producer.retry-next-server=true

#rocketmq.producer.retry-http://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 {

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);

}

}

版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。

上一篇:创建小程序组件快捷键命令(创建组件的快捷键)
下一篇:一网通办工伤报销流程(网报工伤保险流程)
相关文章

 发表评论

暂时没有评论,来抢沙发吧~