RocketMQTemplate 注入失敗如何解決

今天就跟大家聊聊有關(guān)RocketMQTemplate 注入失敗如何解決，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結(jié)了以下內(nèi)容，希望大家根據(jù)這篇文章可以有所收獲。

RocketMQTemplate 注入失敗

在使用rocketmq 發(fā)送消息時(shí)，會(huì)發(fā)現(xiàn)

 @Autowired
 private RocketMQTemplate rocketMQTemplate;

注入RocketMQTemplate 失敗。

解決方案

究其原因是因?yàn)?配置文件中，我們沒有添加

上圖中藍(lán)色的兩行代碼，指定發(fā)送的組名。寫上后，問題解決。

好了，再來說說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 
# 指定發(fā)送者組名 相當(dāng)于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（后面直接使用，就不特殊說明）

@Autowired
private RocketMQTemplate rocketMQTemplate;

簡單使用

//發(fā)送消息
public class ProducerController {
    @Autowired
    private RocketMQTemplate rocketMQTemplate;
    
 public void send(){
     //實(shí)體類User
     User user=new User(999L,"testUser");
     //發(fā)送自定義對(duì)象
     rocketMQTemplate.convertAndSend("test_topic",user);//會(huì)自動(dòng)轉(zhuǎn)換為json格式
 }
}

//接收消息
@Component  //必須注入spring容器
@RocketMQMessageListener(
        topic = "test_topic",      //topic：消息的發(fā)送者使用同一個(gè)topic
        consumerGroup = "test_my-consumer",     //group：不用和生產(chǎn)者group相同
        selectorExpression = "*")        //tag
  // 在RocketMQ中消費(fèi)者和發(fā)送者組沒有關(guān)系
  // 如果兩個(gè)消費(fèi)者groupname和topic都一樣，則二者輪循接收消息
  // 如果兩個(gè)消費(fèi)者topic一樣，而group不一樣，則消息變成廣播機(jī)制
// 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格式數(shù)據(jù)
  Long userId = jsonNode.get("userId").asLong();
        System.out.println(user);
    }
}

看完上述內(nèi)容，你們對(duì)RocketMQTemplate 注入失敗如何解決有進(jìn)一步的了解嗎？如果還想了解更多知識(shí)或者相關(guān)內(nèi)容，請(qǐng)關(guān)注億速云行業(yè)資訊頻道，感謝大家的支持。