上一篇我們已經介紹了activeMQ的伺服器端的開發和程式碼，那麼這一篇就介紹一下怎麼獲取對應的activeMQ裡面的資訊，並

通過websocket推送到前端。

        首先來看一下接收端專案結構：

專案結構中主要的就是listener包裡面的內容，用於監聽MQ中的訊息，我們來看其中一個UserPushListener.java類：

package com.lwl.activemq.listener;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

import org.apache.log4j.Logger;
import org.springframework.stereotype.Component;

import com.alibaba.fastjson.JSON;
import com.lwl.activemq.domain.User;
import com.lwl.activemq.controller.websocket.WebsocketController;

@Component("userPushListener")
public class UserPushListener implements MessageListener {
	 protected static final Logger logger = Logger.getLogger(UserPushListener.class);
	@Override
	public void onMessage(Message message) {
		 logger.info("[UserPushListener.onMessage]:begin onMessage.");
	        TextMessage textMessage = (TextMessage) message;
	        try {
	        	//獲取資料
	            String jsonStr = textMessage.getText();
	            logger.info("[UserPushListener.onMessage]:receive message is,"+ jsonStr);
	            if (jsonStr != null) {
	                User info = JSON.parseObject(jsonStr, User.class);
	                System.out.println("==============================接受到的使用者資訊 開始====================================");
	                System.out.println(info.toString());
	                System.out.println("==============================接受到的使用者資訊 結束====================================");
	                WebsocketController.broadcast("user", jsonStr);
	            }
	        } catch (JMSException e) {
	            logger.error("[UserPushListener.onMessage]:receive message occured an exception",e);
	        }
	        logger.info("[UserPushListener.onMessage]:end onMessage.");
	    }
}
 

還記得我們在配置伺服器端使用的MQ的配置檔案嘛，當然在接收端也會使用相應的配置檔案：activemq_config.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:context="http://www.springframework.org/schema/context"  
    xmlns:jms="http://www.springframework.org/schema/jms"  
    xsi:schemaLocation="http://www.springframework.org/schema/beans  
     http://www.springframework.org/schema/beans/spring-beans-3.0.xsd  
     http://www.springframework.org/schema/context  
     http://www.springframework.org/schema/context/spring-context-3.0.xsd  
    http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd  
    http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms-3.0.xsd">  
     
    <!-- 內部統一使用的MQ地址 -->
    <bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
        <property name="brokerURL" value="tcp://localhost:61616"/>
    </bean>
    <bean id="connectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory" destroy-method="stop">  
        <property name="connectionFactory" ref="targetConnectionFactory"/>  
        <property name="maxConnections" value="50"/>
    </bean>
    <!-- Spring提供的JMS工具類，它可以進行訊息傳送、接收等 -->
    <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">  
        <property name="connectionFactory" ref="connectionFactory"/>
    </bean>

   <!-- 推送給使用者資訊 -->
	<bean id="userPushListenerMQ" class="org.apache.activemq.command.ActiveMQQueue">
		<constructor-arg>
			<value>user.service.queue</value>
		</constructor-arg>
	</bean>
	<!-- 推送給新聞資訊 -->
	<bean id="newsPushListenerMQ" class="org.apache.activemq.command.ActiveMQQueue">
		<constructor-arg>
			<value>news.service.queue</value>
		</constructor-arg>
	</bean>
	<!-- 推送給客戶資訊 -->
	<bean id="clientPushListenerMQ" class="org.apache.activemq.command.ActiveMQQueue">
		<constructor-arg>
			<value>client.service.queue</value>
		</constructor-arg>
	</bean>
	
	<!-- 使用者接受推送 -->
    <bean id="userPushListenerConsumer"
          class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="connectionFactory" ref="connectionFactory" />
        <property name="destination" ref="userPushListenerMQ" />
        <property name="messageListener" ref="userPushListener" />
    </bean>
    
	<!-- 新聞接受推送 -->
    <bean id="newsPushListenerConsumer"
          class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="connectionFactory" ref="connectionFactory" />
        <property name="destination" ref="newsPushListenerMQ" />
        <property name="messageListener" ref="newsPushListener" />
    </bean>
    
	<!-- 客戶接受推送 -->
    <bean id="clientPushListenerConsumer"
          class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="connectionFactory" ref="connectionFactory" />
        <property name="destination" ref="clientPushListenerMQ" />
        <property name="messageListener" ref="clientPushListener" />
    </bean>
</beans>
 

文章裡了：http://blog.csdn.net/lovelong8808/article/details/52212566 有興趣的可以看看，這2個是同一個專案使用，重在結合

知識和運用。

ActiveMQ的相關程式碼也已經提交到github上，有興趣的同學可以去看看 https://github.com/1181888200/activeMQ.git