溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
1.1使用內嵌服務
（1）在pom.xml中引入ActiveMQ起步依賴
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-activemq</artifactId> </dependency>
（2）創建消息生產者
/**
* 消息生產者
* @author Administrator
**/
@RestController
public class QueueController {
@Autowired
private JmsMessagingTemplate jmsMessagingTemplate;
@RequestMapping("/send")
public void send(String text){
jmsMessagingTemplate.convertAndSend("itcast", text);
}
}
（3）創建消息消費者
@Component
public class Consumer {
@JmsListener(destination="itcast")
public void readMessage(String text){
System.out.println("接收到消息："+text);
}
}
測試：啟動服務后，在瀏覽器執行http://localhost:8088/send.do?text=aaaaa即可看到控制臺輸出消息提示。Spring Boot內置了ActiveMQ的服務，所以我們不用單獨啟動也可以執行應用程序。
1.2使用外部服務
在src/main/resources下的application.properties增加配置, 指定ActiveMQ的地址spring.activemq.broker-url=tcp://192.168.25.135:61616運行后，會在activeMQ中看到發送的queue
1.3.3發送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);
}
總結
以上就是這篇文章的全部內容了，希望本文的內容對大家的學習或者工作具有一定的參考學習價值，謝謝大家對億速云的支持。如果你想了解更多相關內容請查看下面相關鏈接
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
