您好,登錄后才能下訂單哦!
一,簡介
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
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。