ActiveMQ与Spring整合项目中，首先建立Maven项目之后，引入相应的包：

<dependencies>
        <dependency>
            <groupId>org.apache.activemq</groupId>
            <artifactId>activemq-all</artifactId>
            <version>5.9.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.xbean</groupId>
            <artifactId>xbean-spring</artifactId>
            <version>4.5</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jms</artifactId>
            <version>4.1.6.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>4.1.6.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
            <scope>compile</scope>
        </dependency>
    </dependencies>

        编写配置文件：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:amq="http://activemq.apache.org/schema/core"
       xmlns:jms="http://www.springframework.org/schema/jms"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
        http://www.springframework.org/schema/context
        http://www.springframework.org/schema/context/spring-context-4.0.xsd
        http://www.springframework.org/schema/jms
        http://www.springframework.org/schema/jms/spring-jms-4.0.xsd
        http://activemq.apache.org/schema/core
        http://activemq.apache.org/schema/core/activemq-core-5.9.0.xsd">
    <!-- 添加扫描 -->
    <context:component-scan base-package="com.littledyf.*"></context:component-scan>

    <!-- ActiveMQ 连接工厂 -->
    <amq:connectionFactory id="amqConnectionFactory"
                           brokerURL="tcp://192.168.232.135:61616" userName="admin" password="admin" />

    
    <!-- Spring用于管理ConnectionFactory的ConnectionFactory -->
    <bean id="connectionFactory"
          class="org.springframework.jms.connection.CachingConnectionFactory">
        <property name="targetConnectionFactory" ref="amqConnectionFactory"></property>
        <!-- Session缓存数量 -->
        <property name="sessionCacheSize" value="10" />
    </bean>

    <!-- 定义JmsTemplate对象 -->
    <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
        <constructor-arg ref="connectionFactory" />
        <!--队列模式, 可省略配置 -->
        <property name="pubSubDomain" value="false" /> 
    </bean>

   
</beans>

        接着建立生产者类：

public class SpringActiveMQProducer {

    @Test
    public void sendMessage(){
        ApplicationContext ac = new ClassPathXmlApplicationContext("application.xml");
        JmsTemplate jmsTemplate = (JmsTemplate)ac.getBean("jmsTemplate");
        jmsTemplate.send("test-spring", new MessageCreator() {
            @Override
            public Message createMessage(Session session) throws JMSException {
                TextMessage textMessage = session.createTextMessage("spring-activemq-test");
                System.out.println("生产消息成功...");
                return textMessage;
            }
        });

    }
}

        启动生产者后查看ActiveMQ管理界面，消息生产成功：

        建立消费者类：

public class SpringActiveMQCustomer implements MessageListener {
    @Override
    public void onMessage(Message message) {
        try {
            TextMessage textMessage = (TextMessage) message;
            System.out.println("消费消息: " + textMessage.getText());
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

        配置文件加入消费者：

    <jms:listener-container destination-type="queue"
                            container-type="default" connection-factory="connectionFactory"
                            acknowledge="auto">
        
        <jms:listener destination="test-spring" ref="orderReciver" />
    </jms:listener-container>

    
    <bean id="orderReciver" class="com.littledyf.customer.SpringActiveMQCustomer"/>

        再次启动生产者生产消息，然后打开ActiveMQ消息管理界面，两个消息均被消费掉：