<rt id="bn8ez"></rt>
<label id="bn8ez"></label>
  • 

    • <span id="bn8ez"></span>
    

    <label id="bn8ez"><meter id="bn8ez"></meter></label>
    

    
    

    




    







												


        

    
	
    
		
			

    

    風人園
    

    弱水三千，只取一瓢，便能解渴；佛法無邊，奉行一法，便能得益。
    

    

    

    隨筆 - 99, 文章 - 181, 評論 - 56, 引用 - 0
    

    


    		
	
    

    

    
	
    
		
			
    
				數據加載中……
			
    
		    		
		
			
    
				
					
	
    
		
    
			ActiveMq 的安裝及整合spring 使用
		
    
		
    
		
    1、下載 安裝
    在windows xp 上，直接解壓就可以使用
    在2003 上，還需要配置一下，缺一個文件，否則無法啟動

    2、mq 配置
    默認使用 文件持久化的方式，無需進行配置，只需要通過代碼，標記消息為持久化即可

    //設置 消息為 ‘持久化’ 消息，隊列服務器重啟后，會重新載入
    message.setJMSDeliveryMode(DeliveryMode.PERSISTENT);
    message.setString("context", context);

    2、整合spring
    mq的spring 配置文件， 此處三個bean
     mq 服務器配置，sender ，監聽器
    完成系統的消息發送和接收

    

    <bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
                <property name="brokerURL" value="tcp://10.10.1.31:61616" />
            </bean>
        
            <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
                <property name="connectionFactory" ref="connectionFactory" />
            </bean>
         
            <!--  ============================  消息發送 ============================== -->
        
            <!-- ecp.sd.log -->
            <bean id="logDestination" class="org.apache.activemq.command.ActiveMQQueue">
                <constructor-arg value="km.wlog"/>
            </bean>
        
            <bean id="logMessageSender" class="com.chint.mq.sender.LogMessageSender">
                <property name="destination" ref="logDestination" />
                <property name="jmsTemplate" ref="jmsTemplate" />
            </bean>
        
            <!--=============================  隊列監聽器  ==========================  -->
        
            <!-- 日志 隊列監聽器 
            <bean id="logContextListener" class="com.chint.mq.listener.LogContextListener">
            </bean>
        
            <bean class="org.springframework.jms.listener.SimpleMessageListenerContainer">
                <property name="connectionFactory" ref="connectionFactory"/>
                <property name="destinationName" value="km.wlog"/>
                <property name="messageListener" ref="logContextListener"/>
            </bean>
            -->

    消息發送者
    

    @Service
    public class LogMessageSender extends BaseMessageSender{
        
            public void sendMessage(final String context) {
            jmsTemplate.send(destination,     new MessageCreator(){

                @Override
                    public Message createMessage(Session session) throws JMSException {
                    MapMessage message     = session.createMapMessage();
                    
                        //設置 消息為 ‘持久化’ 消息，隊列服務器重啟后，會重新載入
                    message.setJMSDeliveryMode(DeliveryMode.PERSISTENT);
                    message.setString(    "context", context);
                    
                    logger.info(    "KM INFO [LogMessageSender] send message context ({})", context);
                    
                        return message;
                }
                
            }    );
        }

    }

    消息接受者
    

    /**
     *     @author wxf
     *
         */
    public class LogContextListener extends BaseContextListener implements MessageListener{

        @Autowired
            private WorkLogManager workLogManager;
        
        @Override
            public void onMessage(Message arg) {
                if(arg instanceof MapMessage) {
                MapMessage message     = (MapMessage)arg;
                
                    try {
                    String context     = message.getString("context");
                    logger.info(    "KM INFO [LogContextListener] get message context ({})", context);   
                }     catch (JMSException e) {
                        throw JmsUtils.convertJmsAccessException(e);
                }
            }     else {
                System.out.println(arg.toString());
            }
        }

    }


    以上就完成了 MQ的使用，比較簡單。

    通過spring使用mq從代碼來講還是很簡單的，但是mq的性能可能需要額外的調整一下才能達到最佳的狀態，特別是大數量的情況下。

    僅作記錄
		
    
		
    
			posted on 2011-11-09 09:25 風人園 閱讀(632) 評論(0)  編輯  收藏  所屬分類: MQ 
		
    
	
    
	
	


	


    
	    
    




    





    


    

	
    
		
    
				
		
	
		
    
		
		
    只有注冊用戶登錄后才能發表評論。
    
		
    
			
		
    
			
		
    
		
		
    
		


    

		    		
		
    
		
    			
		
		
		
		
    
		
    
		
		
    
		
    
			網站導航:
		
		
    
		
    
			
		
    	
		
    
			 
		
    
		
    
			
		
    
		
    
			
				
		
    		
	
    	

    



    

				
			
    
		    		
	
    
	
    
		
			

		
	
    

    


    







    
        
	



主站蜘蛛池模板：
亚洲高清视频免费|
国产精品亚洲片在线|
亚洲精品在线免费看|
99久久人妻精品免费二区|
亚洲AV本道一区二区三区四区|
久久国产乱子伦免费精品|
亚洲欧洲精品久久|
青青视频观看免费99|
久久久国产亚洲精品|
国产精品自在自线免费观看|
美女免费精品高清毛片在线视|
亚洲A∨午夜成人片精品网站|
一级黄色片免费观看|
亚洲精品午夜无码电影网|
久热免费在线视频|
亚洲人成激情在线播放|
处破痛哭A√18成年片免费|
菠萝菠萝蜜在线免费视频|
九月丁香婷婷亚洲综合色|
最近免费字幕中文大全视频|
在线观看日本亚洲一区|
啊灬啊灬别停啊灬用力啊免费看|
久久精品成人免费国产片小草|
久久精品亚洲中文字幕无码网站|
最近免费中文字幕mv在线电影|
亚洲一本一道一区二区三区|
亚洲国产香蕉人人爽成AV片久久
|
国产免费一区二区视频|
少妇中文字幕乱码亚洲影视|
妞干网在线免费观看|
中文字幕a∨在线乱码免费看
|
97精品免费视频|
亚洲人成未满十八禁网站|
亚洲电影日韩精品
|
相泽南亚洲一区二区在线播放|
色久悠悠婷婷综合在线亚洲|
4hu四虎最新免费地址|
免费在线观看自拍性爱视频|
99久久亚洲综合精品成人网|
免费人成在线观看网站品爱网日本|
aa在线免费观看|