上一篇對JMS進行介紹了一下,接下來總結一下activemq點對點模式以及訂閱發布模式。
(1)下載:首先到官網http://activemq.apache.org下載activemq
(2)運行:解壓縮apache-activemq-5.14.0-bin.zip,然后雙擊apache-activemq-5.14.0-bin\apache-activemq-5.14.0\bin\win64\activemq.bat運行ActiveMQ程序。
解壓后,如下圖:
bin:其中包含MQ的啟動腳本
conf:包含MQ的所有配置文件
data:日志文件及持久性消息數據
example:MQ的示例
lib:MQ運行所需的所有Lib
webapps:MQ的Web控制台及一些相關的DEMO
(3) 啟動ActiveMQ以后,登陸:http://localhost:8161/admin/,賬號密碼默認都是admin,修改密碼可以在conf下的jetty.xml中進行修改,默認持久化策略是kahadb,可以在conf下的activemq.xml中進行修改。
Java代碼實現點對點模式,首先使用maven導入相關包:
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-core</artifactId>
<version>5.7.0</version>
</dependency>
實現代碼如下:生產者類HelloQueueProducer
消費者類HelloQueueConsumer(實現MessageListener接口就可以實現異步接收消息,onMessage方法中)
啟動activeMq,然后運行HelloQueueProducer,打開activemq控制台,點擊queue顯示如下:
點擊browse可以查看消息的一些信息,比如id,接收時間,是否持久化,以及消息內容等等。
點擊在運行HelloQueueConsumer,eclipse控制台輸出結果如下:
刷先activemq控制台顯示如下: