1. 程式人生 > >消息中間件之ActiveMQ

消息中間件之ActiveMQ

消息中間件 ActiveMQ

一,簡介
ActiveMQ是較優秀的JMS實現框架,在異步消息通信方面有簡單便捷,性能良好的優點。

二,安裝
下載地址:http://mirror.bit.edu.cn/apache/activemq/
解壓即可

三,啟動
windows啟動
linux啟動

四,java應用
依賴的包:activemq-all-5.12.0.jar
發送消息:
// 構造ConnectionFactory實例對象,此處采用ActiveMq的實現jar<br/>ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(<br/>ActiveMQConnection.DEFAULT_USER,<br/>ActiveMQConnection.DEFAULT_PASSWORD,<br/>"tcp://localhost:61616");<br/>// 構造從工廠得到連接對象<br/>Connection connection = connectionFactory.createConnection();<br/>// 啟動<br/>connection.start();<br/>// 獲取操作連接<br/>Session session = connection.createSession(Boolean.TRUE,<br/>Session.AUTO_ACKNOWLEDGE); <br/>Destination destination = session.createQueue("FirstQueue");<br/>// 得到消息生成者【發送者】<br/>MessageProducer producer = session.createProducer(destination);<br/>// 設置不持久化,此處學習,實際根據項目決定<br/>producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT); <br/>


到此生產者對象生成,下一步發送數據
//創建消息<br/>TextMessage message = session<br/>.createTextMessage("ActiveMq 發送的消息");<br/>//發送<br/>producer.send(message);<br/>
消費者接受數據
創建連接如上
`//消息消費者對象
MessageConsumer consumer = session.createConsumer(destination);
//接收消息
TextMessage message = (TextMessage) consumer.receive(100000);

    `

五,消息管理
自帶管理:http://127.0.0.1:8161/admin/
用戶名密碼:默認用戶名密碼admin,admin
設置

    管理頁面主要幾個菜單:
    1,home:當前ActiveMq的信息,名稱,id,版本等
    2,queues:在當前消息中運行的隊列,以及隊列的生產者,消費者數目,入隊出隊消息數目等
    3,topic
    4,Subscribers 
    5,Connections

消息中間件之ActiveMQ