亚洲激情专区-91九色丨porny丨老师-久久久久久久女国产乱让韩-国产精品午夜小视频观看

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

RocketMQTemplate 注入失敗如何解決

發布時間:2021-07-02 13:51:15 來源:億速云 閱讀:1105 作者:Leah 欄目:開發技術

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

RocketMQTemplate 注入失敗

在使用rocketmq 發送消息時,會發現

 @Autowired
 private RocketMQTemplate 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.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;

簡單使用

//發送消息
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);
    }
}

看完上述內容,你們對RocketMQTemplate 注入失敗如何解決有進一步的了解嗎?如果還想了解更多知識或者相關內容,請關注億速云行業資訊頻道,感謝大家的支持。

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

怀化市| 会昌县| 余干县| 镇巴县| 元谋县| 天门市| 偏关县| 浪卡子县| 瓮安县| 蕲春县| 深州市| 武功县| 双牌县| 南木林县| 溧水县| 安丘市| 天台县| 马山县| 万山特区| 克拉玛依市| 松滋市| 荆州市| 乐昌市| 双流县| 雷州市| 株洲县| 桐城市| 宁远县| 崇明县| 务川| 库尔勒市| 金堂县| 永安市| 武威市| 临朐县| 明光市| 达州市| 洪泽县| 聂荣县| 车险| 临沂市|