首页 > 代码库 > JMS-activeMq点对点模式

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控制台显示如下:

  技术分享

 

 

  

JMS-activeMq点对点模式