zoukankan      html  css  js  c++  java
  • ActiveMQ学习笔记(2)----JMS的基本概念和模型

    1. JMS 的基本概念

      1. JMS是什么?

        JMS Java Message Service,Java消息服务,是Java EE中的一种技术。

      2. JMS规范

        JMS定义了Java中访问消息中间件的接口,并没有给予实现,实现JMS接口的消息中间件称为JMS Provider,例如ActiveQM

        3. JMS provider

        实现JMS接口和规范的消息中间件

          4. JMS message

        JMS message: JMS的消息,JMS消息由以下三部分组成:

        1. 消息头:每个消息头字段都有对应的getter和setter方法。

        2. 消息属性: 如果需要除消息头字段以外的值,可以使用消息属性。

        3. 消息体: 封装具体的消息数据。

      5. JMS Producer

        消息生产者,创建和发送JMS消息的客户端应用。

      6. JMS consumer

        消息消费者,接受和处理JMS消息的客户端应用。消息的消费可以采用以下两种方法之一:

        1. 同步消费:可以通过调用消费者的receive方法从目的地中显示的提取消息,receive方法可以一直阻塞到消息到达。

        2. 异步消费:客户可以为消费者注册一个消息监听器,以定义在消息到达时所采取的动作

      7. JMS domains

        消息传递域,JMS规范中定义了两种消息传递域:点对点(point-to-point,简写成PTP)消息传递域和发布/订阅消息传递域(publish/subscribe,简写成pub/sub)。

        1. 点对点消息传递域的特点如下:

          (1) 每个消息只能有一个消费者

          (2)消息的生产者和消费者之间没有时间上的相关性。无论消费者在生产者发送消息的时候是否处于运行状态,它都可以提取消息。

      

      2. 发布/订阅消息传递域的特点如下:

        (1)每个消息都可以有多个消费者

        (2) 生产者和消费者之间有时间上的相关性。订阅一个主题的消费者只能消费自它订阅之后发布的消息,JMS规范允许客户创建持久订阅,这在一定程度上放松了时间上的相关性要求,持久订阅允许消费者消费它在处于未激活状态时生产者发送的消息。

      3. 在点对点消息传递域中,目的地被称为队列(Queue);在发布/订阅消息传递域中,目的地被称为主题(topic)

      

      8. ConnectionFactory

        连接工厂,用来创建连接对象,以连接到JMS的provider

      9. JMS  Connection

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

      10. JMS Session 

        是生产和消费消息的一个单线程上下文。

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

      11. Destination

        消息发送到的目的地

      12.  Acknowledge

        签收

      13. Transaction

        事务

      14. JMS client

        用来收发消息的Java运用

      15 Non-JMS client

        使用JMS provider本地API写的应用,用来替换JMS API实现收发消息的功能,通常会提供一些特性,比如:CORBA,RMI等。

      16. Administered objects

        预定义的JMS对象,通常在provider规范中有定义,提供给JMS客户端来访问,比如:ConnectionFactory和Destination

    2. JMS消息结构

      JMS消息由以下几个部分组成的:消息头,属性和消息体

      (一). 消息头

        1.消息头包含消息的识别信息和路由信息 ,消息头包含一些标准的属性属下:

        1. JMSDestination: 由send方法设置。(消息目的地queue/topic)

        2. JMSDeliveryMode:由send方法设置

        3. JMSExpiration: 由send方法设置

        4. JMSPririty: 由send方法设置

        5. JMSTimestamp: 由客户端设置

        6. JMSMessageID:由send方法设置

        7. JMSCorrelationID:由客户端设置

        8. JMSReplyTo:由客户端设置

        9. JMSType: 由客户端设置

        10. JMSRedelivered: 由JMS Peovider设置

      2.JMSDeliveryMode

        传送模式。有两种:持久模式和非持久模式。一条持久模式的消息应该被传送“一次仅仅一次”,这就意味着如果JMS提供者出现故障,该消息不会丢失,他会在服务器恢复之后再次传递。一条非持久的消息最多会传送一次,这意味这服务器出现故障,该消息将永远丢失。自动分配

      3. JMSExpiration

        消息过期时间,等于Destination的send方法中的timeToLive值加上发送时刻的GMT时间值。如果timeToLive值等于零,则JMSExpiration被设为零,表示该消息永不过期。如果发送后,在消息过期时间之后消息还没被发送到目的地,则该消息被清除,自动分配。

      4.JMSPriority

        消息优先级,从0-9十个级别,0-4是普通消息,5-9是加急消息。JMS不要求JMS Provider严格按照这是个优先级发送消息,但是必须保证加急消息要小于普通消息,默认是4级。自动分配。

      5. JMSMessageID

        唯一识别每个消息的标识,由JMS Provider产生。自动分配

      6. JMSTimestamp

        一个JMS Provider在调用send方法时自动设置的,它是消息被发送和消费者实际接收的时间差。自动分配

      7. JMSCorrelationID

        用来连接另外一个消息,典型的应用是在回复消息中连接到原消息。在大多数情况下,JMSCorrelationID用于将一条消息标记为对JMSMessageID标识上的一条消息的应答,不过,JMSCorrelationID可以是任何的值,不仅仅是JMSMessageID,由开发者设置

      8. JMSReplyTo

        提供本消息回复消息的目的地址,有开发者设置

      9. JMSType

        消息类型标识符,有开发者设置

      10. JMSRedelivered

        如果一个客户端收到一个设置类JMSRedelivered属性的消息,则表示可能客户端曾经在早些时候收到过该消息,但并没有签收(acknowledge)。如果该消息被重新传送,JMSRedelivered=true.反之 JMSRedelivered=false。自动设置

     (二)消息体

        JMS API定义了五种消息体格式,也叫消息类型,可以使用不同形式发送接收数据,并可以兼容现有得消息格式。包括:TextMessage,MapMessage,BytesMessage,StreamMessage和ObjectMessage

     (三) 消息属性

        包含了以下三种类型得属性

        1. 应用程序设置和添加得属性,比如:

          Message.setStringProperty("username", username);

        2. JMS定义得属性

          使用“JMSX” 作为属性名的前缀

        connection.getMetaData().getJMSXPropertyNames(),方法返回所有连接支持的JMSX属性的名字。

        3. JMS供应商特定的属性。

     (四) JMS定义的属性

        1. JMSXUserID:发送消息的用户标识,发送时提供商设置。

        2. JMSXAppID: 发送时应用标识,发送时提供商设置。

        3. JMSXDeliveryCount: 转发消息重试次数,第一次是1. 第二次是2,.....发送时供应商提供。

        4.  JMSXGroupID: 消息所在消息组的标识,有客户端设置

        5.  JMSXGroupSeq:组内消息的序号第一个消息是1,第二个消息是2. ......由客户端设置

        6.  JMSXProducerTXID: 产生消息事务的事务标识,发送时提供商设置。

        7.  JMSXCousumerTXID: 消费消息事务的事务标识,接收时提供商设置

        8.  JMSXRevTimestamp: JMS转发消息到消费者的时间,接收时提供商设置

        9.  JMSXState: 假定存在一个消息仓库,它存储了每个消息的单独拷贝,且这些消息从原始消息被发送时开始,每个拷贝的状态有:1(等待),2.(准备),3. (到期)或4(保留)。由于状态与生产者和消费者无关,所以它不是由他们来提供。它只和在仓库中查找消息相关,因此JMS没有提供这种API,由供应商提供。

    原文 ActiveMQ学习笔记(2)----JMS的基本概念和模型

  • 相关阅读:
    TCP的发送缓冲区和接收缓冲区
    【 Linux 】单台服务器上并发TCP连接数(转)
    Mosquitto----服务器日志
    Mqtt ----心跳机制
    class文件无论是32位还是64位jdk编译出来的,都可以通用
    启动eclipse时出现“Failed to load the JNI shared library jvm.dll”错误及解决-及eclipse版本查看
    Ant编译提示“Unsupported major.minor version 52.0”
    HanLP自然语言处理包介绍
    Lazarus安装使用
    Java中字符串转为16进制表示
  • 原文地址:https://www.cnblogs.com/xiaoshen666/p/10844395.html
Copyright © 2011-2022 走看看