zoukankan      html  css  js  c++  java
  • Java JMS 程序基础 与 ActiveMQ 安装(一)

    一 ActiveMQ安装

    从Apache官网上下载 ActivieMQ的安装包 apache-activemq-5.9.1-bin.tar.gz, 并拷贝到linux的安装目录解压

    # tar -zxvf   apache-activemq-5.9.1-bin.tar.gz    // 解压

    # cd ./apache-activemq-5.9.1/bin   // 进入bin目录

    # ./activemq                 // 执行启动命令, 程序会启动失败 ,老版本执行 ./activemq 就可以启动成功,但是新版本的会失败。

    按照失败信息提示 执行

    # ./activiemq  setup   /etc/default/.activemqrc

    再执行启动命令

    # ./activemq start

    命令提示启动成功。 acvtivemq默认服务端口为 61616  , web界面管理端口为 8161   通过 http://localhost:8161/admin 访问, 默认用户为 admin/admin

    二 JMS 基础

    1.1 JMS的基本构件

    111 连接工厂

    连接工厂是客户用来创建连接的对象,例如ActiveMQ提供的ActiveMQConnectionFactory。

    112 连接

    JMS Connection封装了客户与JMS提供者之间的一个虚拟的连接。

    113 会话

    JMS Session是生产和消费消息的一个单线程上下文。会话用于创建消息生产者(producer)、消息消费者(consumer)和消息(message)等。会话提供了一个事务性的上下文,在这个上下文中,一组发送和接收被组合到了一个原子操作中。

    114 目的地

    目的地是客户用来指定它生产的消息的目标和它消费的消息的来源的对象。JMS1.0.2规范中定义了两种消息传递域:点对点(PTP)消息传递域和发布/订阅消息传递域。 点对点消息传递域的特点如下:
    • 每个消息只能有一个消费者。
    • 消息的生产者和消费者之间没有时间上的相关性。无论消费者在生产者发送消息的时候是否处于运行状态,它都可以提取消息。
    发布/订阅消息传递域的特点如下:
    • 每个消息可以有多个消费者。
    • 生产者和消费者之间有时间上的相关性。订阅一个主题的消费者只能消费自它订阅之后发布的消息。JMS规范允许客户创建持久订阅,这在一定程度上放松了时间上的相关性要求。持久订阅允许消费者消费它在未处于激活状态时发送的消息。
    在点对点消息传递域中,目的地被成为队列(queue);在发布/订阅消息传递域中,目的地被成为主题(topic)。

     115 消息生产者

    消息生产者是由会话创建的一个对象,用于把消息发送到一个目的地。

    116 消息消费者

    消息消费者是由会话创建的一个对象,它用于接收发送到目的地的消息。消息的消费可以采用以下两种方法之一:
    • 同步消费。通过调用消费者的receive方法从目的地中显式提取消息。receive方法可以一直阻塞到消息到达。
    • 异步消费。客户可以为消费者注册一个消息监听器,以定义在消息到达时所采取的动作。

     117 消息

    JMS消息由以下三部分组成的:
    • 消息头。每个消息头字段都有相应的getter和setter方法。
    • 消息属性。如果需要除消息头字段以外的值,那么可以使用消息属性。
    • 消息体。JMS定义的消息类型有TextMessage、MapMessage、BytesMessage、StreamMessage和ObjectMessage。

  • 相关阅读:
    Java的日期类和日期格式化类
    Java中的内部类
    c#中的里氏转换和Java中强制类型转换在多态中的应用
    MySQL存储引擎
    如何控制多线程执行顺序
    为什么 1000==1000 返回为false,而 100==100 会返回为true
    HashMap和HashTable的区别
    打印昨天的当前时刻
    怎样将GB2312编码的字符串转换为ISO-8859-1编码的字符串?
    MyBatis中 # 和 $ 的区别?
  • 原文地址:https://www.cnblogs.com/piepie/p/3864803.html
Copyright © 2011-2022 走看看