Spring Boot與ActiveMQ整合的步驟
1.1使用內(nèi)嵌服務(wù)
（1）在pom.xml中引入ActiveMQ起步依賴(lài)
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-activemq</artifactId> </dependency>
（2）創(chuàng)建消息生產(chǎn)者
/**
* 消息生產(chǎn)者
* @author Administrator
**/
@RestController
public class QueueController {
@Autowired
private JmsMessagingTemplate jmsMessagingTemplate;
@RequestMapping("/send")
public void send(String text){
jmsMessagingTemplate.convertAndSend("itcast", text);
}
}
（3）創(chuàng)建消息消費(fèi)者
@Component
public class Consumer {
@JmsListener(destination="itcast")
public void readMessage(String text){
System.out.println("接收到消息："+text);
}
}
測(cè)試：?jiǎn)?dòng)服務(wù)后，在瀏覽器執(zhí)行http://localhost:8088/send.do?text=aaaaa即可看到控制臺(tái)輸出消息提示。Spring Boot內(nèi)置了ActiveMQ的服務(wù)，所以我們不用單獨(dú)啟動(dòng)也可以執(zhí)行應(yīng)用程序。
1.2使用外部服務(wù)
在src/main/resources下的application.properties增加配置, 指定ActiveMQ的地址spring.activemq.broker-url=tcp://192.168.25.135:61616運(yùn)行后，會(huì)在activeMQ中看到發(fā)送的queue
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);
}
總結(jié)
以上就是這篇文章的全部?jī)?nèi)容了，希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，謝謝大家對(duì)腳本之家的支持。如果你想了解更多相關(guān)內(nèi)容請(qǐng)查看下面相關(guān)鏈接
相關(guān)文章
這篇文章主要為大家詳細(xì)介紹了JAVA的觀察者模式，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下，希望能夠給你帶來(lái)幫助2022-03-03
springboot表單提交之validator校驗(yàn)
在前臺(tái)表單驗(yàn)證的時(shí)候，通常會(huì)校驗(yàn)一些數(shù)據(jù)的可行性，比如是否為空，長(zhǎng)度，身份證，郵箱等等，這篇文章主要給大家介紹了關(guān)于springboot表單提交之validator校驗(yàn)的相關(guān)資料，需要的朋友可以參考下2021-05-05
Springboot使用redis進(jìn)行api防刷限流過(guò)程詳解
這篇文章主要介紹了Springboot使用redis進(jìn)行api防刷限流過(guò)程詳解,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-12-12
SpringBoot配置Redis連接池的實(shí)現(xiàn)步驟
本文主要介紹了SpringBoot配置Redis連接池的實(shí)現(xiàn)步驟,詳細(xì)的講解了連接池的作用、配置方式、連接池參數(shù)說(shuō)明,具有一定的參考價(jià)值,感興趣的可以了解一下2025-03-03
關(guān)于Javaweb的轉(zhuǎn)發(fā)和重定向詳解
這篇文章主要介紹了關(guān)于Javaweb的轉(zhuǎn)發(fā)和重定向詳解,請(qǐng)求的轉(zhuǎn)發(fā),是指服務(wù)器收到請(qǐng)求后,從一個(gè)服務(wù)器端資源跳轉(zhuǎn)到同一個(gè)服務(wù)器端另外一個(gè)資源的操作,需要的朋友可以參考下2023-05-05
Mybatis plus 配置多數(shù)據(jù)源的實(shí)現(xiàn)示例
這篇文章主要介紹了Mybatis plus 配置多數(shù)據(jù)源的實(shí)現(xiàn)示例，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2020-08-08
如何在springboot項(xiàng)目中自定義404頁(yè)面
今天點(diǎn)擊菜單的時(shí)候不小心點(diǎn)開(kāi)了一個(gè)不存在的頁(yè)面,然后看到瀏覽器給的一個(gè)默認(rèn)的404頁(yè)面,這篇文章主要介紹了如何在springboot項(xiàng)目中自定義404頁(yè)面,需要的朋友可以參考下2024-05-05
這篇文章主要介紹了java IO流的深入理解，下面和小編來(lái)一起學(xué)習(xí)一下吧，希望能給你帶來(lái)幫助，也希望您能夠多多關(guān)注腳本之家的更多內(nèi)容2021-07-07
這篇文章主要為大家介紹了JCommander解析命令行參數(shù)使用詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2023-09-09
java 方法泛型入?yún)和String的重載關(guān)系詳解
這篇文章主要介紹了java 方法泛型入?yún)和String的重載關(guān)系詳解，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2022-02-02