1.XML配置

<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:jms="http://www.springframework.org/schema/jms"
    xsi:schemaLocation="http://www.springframework.org/schema/aop 
        http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd 
        http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms.xsd">

<!-- 配置messageQueue連接工廠 -->
<bean id="connectionFactory" class="org.apache.activemq.spring.ActiveMQConnectionFactory">
       <property name="brokerURL" value="${mq.brokerURL}"></property>
</bean>
<!-- 配置jms消息發(fā)送模板 -->
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="connectionFactory"></property>
</bean>
<!-- 配置消息隊列 -->
<bean id="commonMsgQueue" class="org.apache.activemq.command.ActiveMQQueue">
        <!-- 構(gòu)造函數(shù)參數(shù)  隊列的名稱 -->
        <constructor-arg value="${queue.name.commonMsgQueue}"></constructor-arg>
</bean>
<!-- 自定義監(jiān)聽類 -->
<bean id="commonMsgListener" class="listener.CommonMsgListener">
</bean>
<!-- 配置監(jiān)聽器容器 -->
<bean id="commonMsgListenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
    <!-- MQ連接工廠 -->
    <property name="connectionFactory" ref="connectionFactory"></property>
    <!-- 消息隊列 -->
    <property name="destination" ref="jpushQueue" ></property>
    <!-- 消息監(jiān)聽器 -->
    <property name="messageListener" ref="commonMsgListener"></property>
</bean>

brokerURL= failover:(tcp://ip1:61616)?randomize=false
ip為ActiveMQ安裝的服務(wù)器的地址
randomize=false 在使用多個地址時，按照先后順序進(jìn)行連接，如 failover:(tcp://ip1:61616,tcp://ip2:61616)?randomize=false ，這時會先嘗試與ip1連接，如果連接不上再連接ip2。此參數(shù)默認(rèn)為true

2.加入消息隊列 && 監(jiān)聽器獲取消息

Put

public class PutMessage {


//加載消息發(fā)送模板
@Resource    //根據(jù)名字檢索加載類，找不到再根據(jù)類型檢索加載
private JmsTemplate jmsTemplate;
//加載公共消息隊列
@Resource   
private ActiveMQQueue commonMsgQueue;

@Transactional
public void put(final Object message){
    try{
        jmsTemplate.send(commonMsgQueue, new MessageCreator(){
            public Message createMessage(Session session) throws JMSException {
                MapMessage mapMessage = session.createMapMessage();
                mapMessage.setString("messageJson",JSON.toJSONString());
            }
        });
        LOGGER.success("加入隊列commonMsgQueue成功,消息內(nèi)容："+JSON.toJSONString(message));
    }catch(JMSException e){
         LOGGER.warn("加入隊列commonMsgQueue失敗,消息內(nèi)容："+JSON.toJSONString(message));
    }
}

Get

public Class CommonMsgListener implements messageListener{
 
    public void onMessage(Message message){            
          if(message instanceof ObjectMessage){
              //實現(xiàn)messageListener即可在實現(xiàn)方法中獲取到message對象
          }    
    }    
}

3.在服務(wù)器上查看隊列生產(chǎn)消費(fèi)情況

訪問地址 ip:8161/admin
ip為安裝ActiveMQ服務(wù)的地址，與配置中的brokerURL相同

管理頁面頭部.png