<?xml version="1.0" encoding="UTF-8"?>

 <web-app version="3.0" xmlns="http://java.sun.com/xml/ns/javaee"

     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

     xsi:schemaLocation="http://java.sun.com/xml/ns/javaee

     http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd">  

     <display-name>activemq</display-name>

     <!-- Spring ApplicationContext配置文件的路径,可使用通配符，用于后面的Spring Context Loader -->

     <context-param>

         <param-name>contextConfigLocation</param-name>

         <param-value>

             classpath:applicationContext.xml

         </param-value>

     </context-param>

     <!--Spring ApplicationContext 载入 -->

     <listener>

         <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>

     </listener>

     <!-- Spring MVC Servlet -->

     <servlet>

         <servlet-name>dispatcher</servlet-name>

         <servlet-class>com.alibaba.dubbo.remoting.http.servlet.DispatcherServlet</servlet-class>

         <init-param>

             <param-name>contextConfigLocation</param-name>

             <param-value>classpath:DispatcherServlet.xml</param-value>

         </init-param>

         <load-on-startup>1</load-on-startup>

     </servlet>

     <servlet-mapping>

         <servlet-name>dispatcher</servlet-name>

         <url-pattern>/</url-pattern>

     </servlet-mapping>

     <welcome-file-list>

         <welcome-file>index.html</welcome-file>

     </welcome-file-list>

 </web-app>

 <?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:context="http://www.springframework.org/schema/context"

         xmlns:goldfish="http://www.fangdd.com/schema/goldfish"

         xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd

           http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd

           http://www.fangdd.com/schema/goldfish http://www.fangdd.com/schema/goldfish/goldfish-1.0.0.xsd">

       <context:annotation-config/>

     <context:component-scan base-package="com.zp.test" >

     </context:component-scan>

     <!-- 使用annotation 自动注册bean,并保证@Required,@Autowired的属性被注入 -->

     <context:component-scan base-package="com.activemqtest.*"/>

     <!-- 配置JMS连接工厂 -->

     <bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">

         <property name="brokerURL" value="failover:(tcp://localhost:61616)" />

     </bean>

     <!-- 定义消息队列（Queue） -->

     <bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">

         <!-- 设置消息队列的名字 -->

         <constructor-arg>

             <value>queue1</value>

         </constructor-arg>

     </bean>

     <!-- 配置JMS模板（Queue），Spring提供的JMS工具类，它发送、接收消息。 -->

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

         <property name="connectionFactory" ref="connectionFactory" />

         <property name="defaultDestination" ref="queueDestination" />

         <property name="receiveTimeout" value="10000" />

     </bean>

     <!--queue消息生产者 -->

     <bean id="producerService" class="com.activemqtest.serviceImpl.ProducerServiceImpl">

         <property name="jmsTemplate" ref="jmsTemplate"></property>

     </bean>

     <!--queue消息消费者 -->

     <bean id="consumerService" class="com.activemqtest.serviceImpl.ConsumerServiceImpl">

         <property name="jmsTemplate" ref="jmsTemplate"></property>

     </bean>

     <!-- 定义消息队列（Queue），我们监听一个新的队列，queue2 -->

     <bean id="queueDestination2" class="org.apache.activemq.command.ActiveMQQueue">

         <!-- 设置消息队列的名字 -->

         <constructor-arg>

             <value>queue2</value>

         </constructor-arg>

     </bean>

     <!-- 配置消息队列监听者（Queue），代码下面给出，只有一个onMessage方法 -->

     <bean id="queueMessageListener" class="com.activemqtest.serviceImpl.QueueMessageListener" />

     <!-- 消息监听容器（Queue），配置连接工厂，监听的队列是queue2，监听器是上面定义的监听器 -->

     <bean id="jmsContainer"

         class="org.springframework.jms.listener.DefaultMessageListenerContainer">

         <property name="connectionFactory" ref="connectionFactory" />

         <property name="destination" ref="queueDestination2" />

         <property name="messageListener" ref="queueMessageListener" />

     </bean>

     <!-- 定义消息主题（Topic） -->

     <bean id="topicDestination" class="org.apache.activemq.command.ActiveMQTopic">

         <constructor-arg>

             <value>JY_topic</value>

         </constructor-arg>

     </bean>

     <!-- 配置JMS模板（Topic），pubSubDomain="true"-->

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

         <property name="connectionFactory" ref="connectionFactory" />

         <property name="defaultDestination" ref="topicDestination" />

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

         <property name="receiveTimeout" value="10000" />

     </bean>

     <!--topic消息发布者 -->

     <bean id="topicProvider" class="com.activemqtest.serviceImpl.TopicProvider">

         <property name="topicJmsTemplate" ref="topicJmsTemplate"></property>

     </bean>

     <!-- 消息主题监听者 和 主题监听容器 可以配置多个，即多个订阅者 -->

     <!-- 消息主题监听者(Topic) -->

     <bean id="topicMessageListener" class="com.activemqtest.serviceImpl.TopicMessageListener" />

     <!-- 主题监听容器 （Topic） -->

     <bean id="topicJmsContainer"

         class="org.springframework.jms.listener.DefaultMessageListenerContainer">

         <property name="connectionFactory" ref="connectionFactory" />

         <property name="destination" ref="topicDestination" />

         <property name="messageListener" ref="topicMessageListener" />

     </bean>

     </beans>

 <?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:context="http://www.springframework.org/schema/context"

        xmlns:mvc="http://www.springframework.org/schema/mvc"

        xsi:schemaLocation="http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd

         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">

     <context:annotation-config />

     <context:component-scan base-package="com.zp.test.controller">

         <context:include-filter type="annotation" expression="org.springframework.stereotype.Controller"/>

     </context:component-scan>

  </beans>