溫馨提示×

溫馨提示×

您好，登錄后才能下訂單哦！

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

Spring Boot與ActiveMQ整合的步驟

發(fā)布時間：2020-08-24 09:52:42 來源：腳本之家 閱讀：172 作者：qq_43193797 欄目：編程語言

1.1使用內嵌服務

（1）在pom.xml中引入ActiveMQ起步依賴

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-activemq</artifactId>
</dependency>

（2）創(chuàng)建消息生產者

/**
 * 消息生產者
 * @author Administrator
 **/
@RestController
public class QueueController {
 @Autowired
 private JmsMessagingTemplate jmsMessagingTemplate;
 @RequestMapping("/send")
 public void send(String text){
 jmsMessagingTemplate.convertAndSend("itcast", text);
 }
}

（3）創(chuàng)建消息消費者

@Component
public class Consumer {
 @JmsListener(destination="itcast")
 public void readMessage(String text){
 System.out.println("接收到消息："+text);
 } 
}

測試：啟動服務后，在瀏覽器執(zhí)行http://localhost:8088/send.do?text=aaaaa即可看到控制臺輸出消息提示。Spring Boot內置了ActiveMQ的服務，所以我們不用單獨啟動也可以執(zhí)行應用程序。

1.2使用外部服務

在src/main/resources下的application.properties增加配置, 指定ActiveMQ的地址spring.activemq.broker-url=tcp://192.168.25.135:61616運行后，會在activeMQ中看到發(fā)送的queue

Spring Boot與ActiveMQ整合的步驟

1.3.3發(fā)送Map信息

（1）修改QueueController.java

@RequestMapping("/sendmap")
 public void sendMap(){
 Map map=new HashMap<>();
 map.put("mobile", "13900001111");
 map.put("content", "恭喜獲得10元代金券"); 
 jmsMessagingTemplate.convertAndSend("itcast_map",map);
 }

（2）修改Consumer.java

@JmsListener(destination="itcast_map")
 public void readMap(Map map){
 System.out.println(map); 
 }

總結

以上就是這篇文章的全部內容了，希望本文的內容對大家的學習或者工作具有一定的參考學習價值，謝謝大家對億速云的支持。如果你想了解更多相關內容請查看下面相關鏈接

向AI問一下細節(jié)

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

AI
助
手