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

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

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

    
    

    




    







												


        


    


    俊星的BLOG
    

    

    




    
	
					
	
    
		
    
			ActiveMQ初探
		
    
		Apache ActiveMQ是一個(gè)高性能的消息代理，實(shí)現(xiàn)了JMS 1.1。
    
目前的最新版本是5.4.1
    
1、下載相關(guān)包，并將activemq-all-5.4.1.jar加入到工程中。
    

    
2、運(yùn)行bin目錄下的actionmq.bat文件，啟動(dòng)broker，在conf下是相關(guān)的配置文件，例如activemq.xml
    

    
3、可通過訪問http://localhost:8161/admin/來查看啟動(dòng)情況，有可通過netstat -an|find "61616" 來查看端口，因?yàn)橥ㄟ^查看activemq.xml中即可發(fā)現(xiàn)傳輸連接器即配置的占用61616端口：
    
<transportConnectors>
    
        <transportConnector name="openwire" uri="tcp://0.0.0.0:61616"/>
    
 </transportConnectors>
    

    
4、編寫消息接收類：
    

    import javax.jms.Connection;
    
    import javax.jms.ConnectionFactory;
    
    import javax.jms.Destination;
    
    import javax.jms.JMSException;
    
    import javax.jms.MessageConsumer;
    
    import javax.jms.Session;
    
    import javax.jms.TextMessage;
    

    
    import org.apache.activemq.ActiveMQConnection;
    
    import org.apache.activemq.ActiveMQConnectionFactory;
    

    
    public class JmsReceiver {
    
        public static void main(String[] args) throws JMSException {
    
        ConnectionFactory connectionFactory     = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER,
    
                ActiveMQConnection.DEFAULT_PASSWORD,     "tcp://localhost:61616");
    
        Connection connection     = connectionFactory.createConnection();
    
        connection.start();
    
        Session session     = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
    
            // 需要在activemq的控制臺(tái)中創(chuàng)建queue：testqueue
    
            Destination destination = session.createQueue("testqueue");
    
        MessageConsumer consumer     = session.createConsumer(destination);
    
        
    
            while (true) {
    
            TextMessage message     = (TextMessage) consumer.receive(1000);
    
                if (null != message)
    
                System.out.println(    "收到消息：" + message.getText());
    
                else
    
                    break;
    
        }
    
        session.close();
    
        connection.close();
    
    }
    
}
    

    

    
5、編寫消息產(chǎn)生類：
    

    import javax.jms.Connection;
    
    import javax.jms.ConnectionFactory;
    
    import javax.jms.DeliveryMode;
    
    import javax.jms.Destination;
    
    import javax.jms.JMSException;
    
    import javax.jms.MessageProducer;
    
    import javax.jms.Session;
    
    import javax.jms.TextMessage;
    

    
    import org.apache.activemq.ActiveMQConnection;
    
    import org.apache.activemq.ActiveMQConnectionFactory;
    

    
    public class JmsSender {
    
        public static void main(String[] args) throws JMSException {
    
        ConnectionFactory connectionFactory     = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER,
    
                ActiveMQConnection.DEFAULT_PASSWORD,     "tcp://localhost:61616");
    
        Connection connection     = connectionFactory.createConnection();
    
        connection.start();
    
        Session session     = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
    
        Destination destination     = session.createQueue("testqueue");
    
        MessageProducer producer     = session.createProducer(destination);
    
        producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
    
        sendMsg(session, producer);
    
        session.commit();
    
        connection.close();
    
    }
    

    
        public static void sendMsg(Session session, MessageProducer producer) throws JMSException {
    
            // 創(chuàng)建一條文本消息
    
            TextMessage message = session.createTextMessage("你好 ActiveMQ！");
    
        producer.send(message);
    
        System.out.println(    "");
    
    }
    
}
    

    

    
6、通過訪問http://localhost:8161/admin/，在queue中創(chuàng)建testqueue，先執(zhí)行消息發(fā)送類，后執(zhí)行消息接收類，借看看到消息接收類的如下執(zhí)行結(jié)果：
    
收到消息：你好 ActiveMQ！
    
收到消息：你好 ActiveMQ！
    

    
（執(zhí)行多次消息發(fā)送類，則會(huì)接受到多條“你好 ActiveMQ!”消息）

		
    
			posted on 2010-10-28 17:53 俊星 閱讀(2905) 評(píng)論(1)  編輯  收藏  
		
    
	
    
	
	





    
	    
    


    

    評(píng)論
    
	
	
			
    
				# re: ActiveMQ初探
					
						2011-04-21 16:10
					
				71569973
			
    
			
    
				測試通過。多謝  回復(fù)  更多評(píng)論
				  
			
    
		

    




    





    


    

	
    
		
    
				
		
	
		
    
		
		
    只有注冊用戶登錄后才能發(fā)表評(píng)論。
    
		
    
			
		
    
			
		
    
		
		
    
		


    

		    		
		
    
		
    			
		
		
		
		
    
		
    
		
		
    
		
    
			網(wǎng)站導(dǎo)航:
		
		
    
		
    
			
		
    	
		
    
			 
		
    
		
    
			
		
    
		
    
			
				
		
    		
	
    	

    



    

				

    



    







    
        
	



主站蜘蛛池模板：
吃奶摸下高潮60分钟免费视频|
十八禁在线观看视频播放免费|
四虎永久在线精品免费观看视频|
国产精品久久久亚洲|
日韩一级片免费观看|
国产亚洲精品免费|
亚洲AV网一区二区三区
|
久久国产精品国产自线拍免费|
国产成人99久久亚洲综合精品
|
中文字幕亚洲日韩无线码|
视频一区在线免费观看|
国产精品嫩草影院免费|
国产亚洲日韩在线a不卡|
免费又黄又爽的视频|
国产三级在线免费观看|
亚洲综合日韩久久成人AV|
在线看片免费人成视频福利|
亚洲色四在线视频观看|
精品女同一区二区三区免费站|
亚洲制服丝袜第一页|
四虎影视大全免费入口|
污污视频免费观看网站|
国产亚洲精久久久久久无码|
久久国产乱子免费精品|
亚洲成a人片在线观看中文!!!|
成人黄18免费视频|
免费国产va在线观看|
亚洲国产成人精品无码区在线观看|
久章草在线精品视频免费观看|
亚洲一区二区三区在线|
国产成人无码a区在线观看视频免费|
免费大片av手机看片高清|
国产av无码专区亚洲av果冻传媒
|
日韩一级片免费观看|
国产精品亚洲а∨无码播放|
99在线观看视频免费|
亚洲国产精品网站在线播放|
亚洲精品美女久久久久99小说|
**真实毛片免费观看|
亚洲国产AV无码一区二区三区|
亚洲综合色在线观看亚洲|