消息中間件之ActiveMQ

一，簡介
ActiveMQ是較優(yōu)秀的JMS實(shí)現(xiàn)框架，在異步消息通信方面有簡單便捷，性能良好的優(yōu)點(diǎn)。

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

三，啟動(dòng)
windows啟動(dòng)
linux啟動(dòng)

四，java應(yīng)用
依賴的包：activemq-all-5.12.0.jar
發(fā)送消息：
// 構(gòu)造ConnectionFactory實(shí)例對象，此處采用ActiveMq的實(shí)現(xiàn)jar<br/>ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(<br/>ActiveMQConnection.DEFAULT_USER,<br/>ActiveMQConnection.DEFAULT_PASSWORD,<br/>"tcp://localhost:61616");<br/>// 構(gòu)造從工廠得到連接對象<br/>Connection connection = connectionFactory.createConnection();<br/>// 啟動(dòng)<br/>connection.start();<br/>// 獲取操作連接<br/>Session session = connection.createSession(Boolean.TRUE,<br/>Session.AUTO_ACKNOWLEDGE); <br/>Destination destination = session.createQueue("FirstQueue");<br/>// 得到消息生成者【發(fā)送者】<br/>MessageProducer producer = session.createProducer(destination);<br/>// 設(shè)置不持久化，此處學(xué)習(xí)，實(shí)際根據(jù)項(xiàng)目決定<br/>producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT); <br/>
到此生產(chǎn)者對象生成，下一步發(fā)送數(shù)據(jù)
//創(chuàng)建消息<br/>TextMessage message = session<br/>.createTextMessage("ActiveMq 發(fā)送的消息");<br/>//發(fā)送<br/>producer.send(message);<br/>
消費(fèi)者接受數(shù)據(jù)
創(chuàng)建連接如上
`//消息消費(fèi)者對象
MessageConsumer consumer = session.createConsumer(destination);
//接收消息
TextMessage message = (TextMessage) consumer.receive(100000);

    `

五，消息管理
自帶管理：http://127.0.0.1:8161/admin/
用戶名密碼：默認(rèn)用戶名密碼admin，admin
設(shè)置

    管理頁面主要幾個(gè)菜單：
    1，home:當(dāng)前ActiveMq的信息，名稱，id，版本等
    2，queues:在當(dāng)前消息中運(yùn)行的隊(duì)列，以及隊(duì)列的生產(chǎn)者，消費(fèi)者數(shù)目，入隊(duì)出隊(duì)消息數(shù)目等
    3，topic
    4，Subscribers 
    5，Connections