JMS-activeMq點對點模式


  上一篇對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控制台顯示如下:

  

 

 

  


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM