1.1使用內嵌服務
（1）在pom.xml中引入activemq起步依賴
|
1
2
3
4
|
<dependency> <groupid>org.springframework.boot</groupid> <artifactid>spring-boot-starter-activemq</artifactid></dependency> |
（2）創建消息生產者
|
1
2
3
4
5
6
7
8
9
10
11
12
13
|
/** * 消息生產者 * @author administrator **/@restcontrollerpublic class queuecontroller { @autowired private jmsmessagingtemplate jmsmessagingtemplate; @requestmapping("/send") public void send(string text){ jmsmessagingtemplate.convertandsend("itcast", text); }} |
（3）創建消息消費者
|
1
2
3
4
5
6
7
|
@componentpublic 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
|
1
2
3
4
5
6
7
|
@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
|
1
2
3
4
|
@jmslistener(destination="itcast_map") public void readmap(map map){ system.out.println(map); } |
總結
以上就是這篇文章的全部內容了，希望本文的內容對大家的學習或者工作具有一定的參考學習價值，謝謝大家對服務器之家的支持。如果你想了解更多相關內容請查看下面相關鏈接
原文鏈接：https://blog.csdn.net/qq_43193797/article/details/83585907
