zoukankan      html  css  js  c++  java
  • JMS-activeMq点对点模式

      上一篇对JMS进行介绍了一下,接下来总结一下activemq点对点模式以及订阅发布模式。

      (1)下载:首先到官网http://activemq.apache.org下载activemq

      (2)运行:解压缩apache-activemq-5.14.0-bin.zip,然后双击apache-activemq-5.14.0-binapache-activemq-5.14.0inwin64activemq.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控制台显示如下:

      

      

  • 相关阅读:
    关于slot标签的使用
    vue组件
    template和component的理解(待更正)
    input 的属性autocomplete
    关于render: h => h(App)和components: { App }的区别
    关于vue的简单知识
    获取页面跳转携带的参数
    关于跨域的简单想法(此想法是错误的,特此备注)
    关于jq建立类似与双向绑定的函数
    关于jq将一个页面引入另一个页面,类似与组件化的解决方案
  • 原文地址:https://www.cnblogs.com/gdpuzxs/p/6618791.html
Copyright © 2011-2022 走看看