1、pom.xml依賴的jar

<dependency>
            <groupId>org.apache.activemq</groupId>
            <artifactId>activemq-spring</artifactId>
            <version>5.14.5</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jms</artifactId>
            <version>${spring.version}</version>
        </dependency>
 

<?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:amq="http://activemq.apache.org/schema/core"
xmlns:jms="http://www.springframework.org/schema/jms"
xmlns:context
 
="http://www.springframework.org/schema/context"
xmlns:mvc="http://www.springframework.org/schema/mvc"
xsi:schemaLocation="
        http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans-4.1.xsd
        http://www.springframework.org/schema/context
        http://www.springframework.org/schema/context/spring-context-4.1.xsd
 
        http://www.springframework.org/schema/mvc
        http://www.springframework.org/schema/mvc/spring-mvc-4.1.xsd
        http://www.springframework.org/schema/jms
        http://www.springframework.org/schema/jms/spring-jms-4.1.xsd
        http://activemq.apache.org/schema/core
        http://activemq.apache.org/schema/core/activemq-core-5.14.5.xsd"
>
    <amq:connectionFactory id="amqConnectionFactory"
brokerURL="${activemq_url}"
userName="${activemq_username}"
password="${activemq_password}" />
<!-- 配置JMS連線工長 -->
<bean id="connectionFactory"
class="org.springframework.jms.connection.CachingConnectionFactory">
        <constructor-arg ref="amqConnectionFactory" />
        <property name="sessionCacheSize" value="100" />
    </bean>
<!-- 定義訊息佇列（Queue） -->
<bean id="demoQueueDestination" class="org.apache.activemq.command.ActiveMQQueue">
<!-- 設定訊息佇列的名字 -->
<constructor-arg>
            <value>${activemq_topic}</value>
        </constructor-arg>
    </bean>
    <bean id="demoTopicDestination" class="org.apache.activemq.command.ActiveMQTopic">
<!-- 設定訊息佇列的名字 -->
<constructor-arg>
            <value>${activemq_topic}</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="demoTopicDestination" />
        <property name="receiveTimeout" value="10000" />
<!-- true是topic，false是queue，預設是false，此處顯示寫出false -->
<property name="pubSubDomain" value="true" />
    </bean>
    <bean id="topicMessageListen" class="com.ultrapower.secsight.core.filter.TopicMessageListener"  />
<!--&lt;!&ndash; 顯示注入訊息監聽容器（Queue），配置連線工廠，監聽的目標是demoQueueDestination，監聽器是上面定義的監聽器 &ndash;&gt;-->
<bean id="queueListenerContainer"
class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="connectionFactory" ref="connectionFactory" />
        <property name="destination" ref="demoTopicDestination" />
        <property name="messageListener" ref="topicMessageListen" />
    </bean>
</beans>

3.配置檔案ActiveMQ.properties

##MQ 伺服器
activemq_url=tcp://192.168.170.69:61616
##使用者名稱
activemq_username=admin
#密碼
activemq_password=admin
#主題
activemq_topic=TOPIC

4、程式碼監聽器

importjavax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
/**
 * @author xiefg
 * @create 2017-09-11 16:35
 * @desc
**/
public class TopicMessageListener implements MessageListener {

    @Override
public void onMessage(Message message) {
        TextMessage tm = (TextMessage) message;
        try {
            System.out.println("TopicMessageListener監聽到了文字訊息：\t"
+ tm.getText());
//do something ...
} catch (JMSException e) {
            e.printStackTrace();
}
    }
}

<!-- 配置檔案來源 -->
<bean id="propertyConfigurer"
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
   <property name="locations">
      <list>         <value>classpath:ActiveMQ.properties</value>
      </list>
   </property>
</bean>

6、進入伺服器管理介面點選j頁面上的 send ，看圖上標註寫

點選下面的send  傳送主題訊息，java web配置的監聽器，會監聽到相應的主題，web啟動後看看後臺是否有相關輸出，輸出 一下資訊表示成功

TpicMessageListener監聽到了文字訊息：