JMS-activeMq点对点模式

Posted 2020-09-06 gdpuzxs

　　上一篇对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控制台显示如下：