Spring Boot 与 ActiveMQ 整合

接收的配置文件 ：  

1.导入配置文件，上面，

 

2.导坐标

    <!-- activemq  start -->         <dependency>           <groupId>org.apache.activemq</groupId>           <artifactId>activemq-all</artifactId>           <version>5.2.0</version>         </dependency>                  <!-- activemq  end -->                  <!-- spring 与 mq整合  start -->         <dependency>             <groupId>org.springframework</groupId>             <artifactId>spring-jms</artifactId>             <version>4.2.4.RELEASE</version>         </dependency>         <dependency>             <groupId>org.apache.xbean</groupId>             <artifactId>xbean-spring</artifactId>             <version>3.7</version>         </dependency>         <!-- spring 与 mq整合  end -->

  3.编写发送消息测试类     queue 的方式发送    在配置文件applicationContext-mq.xml查看设置编辑

    

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans"     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"     xmlns:context="http://www.springframework.org/schema/context"     xmlns:jdbc="http://www.springframework.org/schema/jdbc" xmlns:tx="http://www.springframework.org/schema/tx"     xmlns:jpa="http://www.springframework.org/schema/data/jpa" xmlns:task="http://www.springframework.org/schema/task"     xmlns:amq="http://activemq.apache.org/schema/core"     xmlns:jms="http://www.springframework.org/schema/jms"     xsi:schemaLocation=" http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/aophttp://www.springframework.org/schema/aop/spring-aop.xsd http://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/jdbchttp://www.springframework.org/schema/jdbc/spring-jdbc.xsd http://www.springframework.org/schema/txhttp://www.springframework.org/schema/tx/spring-tx.xsd http://www.springframework.org/schema/data/jpa http://www.springframework.org/schema/data/jpa/spring-jpa.xsd http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms.xsd http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd">

 <!-- 扫描包 -->   

 <!-- <context:component-scan base-package="cn.itcast.jms" /> -->          <!-- ActiveMQ 连接工厂 -->     <!-- 真正可以产生Connection的ConnectionFactory，由对应的 JMS服务厂商提供-->     <!-- 如果连接网络：tcp://ip:61616；未连接网络：tcp://localhost:61616 以及用户名，密码-->     <amq:connectionFactory id="amqConnectionFactory"         brokerURL="tcp://localhost:61616" userName="admin" password="admin"  />     <!-- Spring Caching连接工厂 -->     <!-- Spring用于管理真正的ConnectionFactory的ConnectionFactory -->       <bean id="connectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">         <!-- 目标ConnectionFactory对应真实的可以产生JMS Connection的ConnectionFactory -->           <property name="targetConnectionFactory" ref="amqConnectionFactory"></property>         <!-- Session缓存数量和链接数有关 -->         <property name="sessionCacheSize" value="100" />     </bean>

    

     <!-- 定义JmsTemplate的Queue类型 -->

    <bean id="jmsQueueTemplate" class="org.springframework.jms.core.JmsTemplate">

        <!-- 这个connectionFactory对应的是我们定义的Spring提供的那个ConnectionFactory对象 -->  

        <constructor-arg ref="connectionFactory" />

        <!-- 非pub/sub模型（发布/订阅），即队列模式 -->

        <property name="pubSubDomain" value="false" />

    </bean>

 

    <!-- 定义JmsTemplate的Topic类型 -->

    <bean id="jmsTopicTemplate" class="org.springframework.jms.core.JmsTemplate" >

         <!-- 这个connectionFactory对应的是我们定义的Spring提供的那个ConnectionFactory对象 -->  

        <constructor-arg ref="connectionFactory" />

        <!-- pub/sub模型（发布/订阅） -->

        <property name="pubSubDomain" value="true"  />

    </bean>

   

</beans>

3.1 编写queue发送消息，，和接收消息

//1.手动架子啊xml配置文件 @RunWith(SpringJUnit4ClassRunner.class) @ContextConfiguration("classpath:applicationContext-mq.xml") public class SpringQueueTest { //2.自动注入一个对象 ，但是在这里直接使用Autowired 自动注入不了。需要把他在配置文件的ID名 加上     @Autowired     @Qualifier(value="jmsQueueTemplate")     private JmsTemplate queueTemplate;          @Test     public void testQueueSend(){ //通过queueTemplate.send（"数据名",new MessageCreator()）给queue发送数据 //实现他的匿名方法         queueTemplate.send("itcast297_queue——数据名", new MessageCreator() {                          @Override             public Message createMessage(Session session) throws JMSException {                 //session.自己想要传的数据的类型。。text  map 类型等，下面是text类型的                 TextMessage message = session.createTextMessage("spring发送的消息");                 return message;             }         });     }          @Test     public void testQueueReceive() throws JMSException{ //调用queueTemplate接收数据  .receive（"数据名"）：接收            手动接收数据一般不用了         TextMessage message = (TextMessage) queueTemplate.receive("itcast297_queue");         System.out.println(message.getText());     } }

3.2 编写Topic发送消息，，和接收消息

@RunWith(SpringJUnit4ClassRunner.class) @ContextConfiguration("classpath:applicationContext-mq.xml") public class SpringTopicTest {     @Autowired     @Qualifier(value="jmsTopicTemplate")     private JmsTemplate topicTemplate;          @Test     public void testTopicSend(){         topicTemplate.send("itcast297_topic", new MessageCreator() {                          @Override             public Message createMessage(Session session) throws JMSException {                 // TODO Auto-generated method stub                 //TextMessage message = session.createTextMessage("spring发送的消息");                 MapMessage map = session.createMapMessage();                 map.setString("username", "cgx");                 return map;             }         });     }          /**      * 手动调用的方式      * @throws JMSException      */     @Test     public void testTopicReceive() throws JMSException{         MapMessage message = (MapMessage) topicTemplate.receive("itcast297_topic");         System.out.println(message.getString("username"));         System.out.println("执行结束");     }           }