很多教程中，會介紹原生demo，原生demo在實際開發中不會用到，而且代碼量比較大，而且不好理解，也沒什么用，所以我們課程不介紹。我們的課程主打實戰，所以只會介紹跟SpringBoot整合的方案。

新建一個maven項目，導入依賴

<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.ia</groupId><artifactId>springboot-jms</artifactId><version>1.0-SNAPSHOT</version><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.0.4.RELEASE</version><relativePath/></parent><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding><java.version>1.8</java.version></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-activemq</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>

在發送時，只需要指定發送目標的字符串即可，不需要Destination這個對象，直接用字符串。

package jms;import javax.jms.Destination; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.jms.core.JmsMessagingTemplate; import org.springframework.jms.core.JmsTemplate; import org.springframework.stereotype.Component;@Component public class Producer {@AutowiredJmsMessagingTemplate jmsTemplate;public void sendMessage(String destination,String message) {jmsTemplate.convertAndSend(destination,message);} } package jms;import org.springframework.jms.annotation.JmsListener; import org.springframework.stereotype.Component;@Component public class Consumer {@JmsListener(destination = "mytest.queue")public void receiveQueue(String text){System.out.println(text);} } package jms;import javax.jms.Destination;import org.apache.activemq.command.ActiveMQQueue; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.test.context.junit4.SpringRunner;/*** @Author: szz* @Date: 2019/6/8 下午8:02* @Version 1.0*/ @RunWith(SpringRunner.class) @SpringBootTest public class TestJms {@Autowiredprivate Producer producer;@Testpublic void sendMessage()throws Exception{producer.sendMessage("mytest.queue","你好，ActiveMQ");} }

application.yml

spring:activemq:broker-url: tcp://localhost:61616in-memory: true package jms;import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication public class App {public static void main(String[] args) {SpringApplication.run(App.class,args);} }

?

超強干貨來襲 云風專訪：近40年碼齡，通宵達旦的技術人生

總結

以上是生活随笔為你收集整理的ActiveMQ入门-ActiveMQ跟SpringBoot整合发送接收Queue的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。