首页 > 代码库 > JMS基本概念

JMS基本概念

JMS是什么

JMS java message service, java消息服务,是java EE中的一个技术。

JMS定义了java中访问消息中间件的接口,并没有给予实现,实现了JMS接口的消息中间件叫做JMS Provider,比如ActiveMQ。

 

JMS provider:实现了JMS接口和规范的消息中间件。

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

1、消息头:每个消息头字段都有相应的getter和setter方法

2、消息属性:如果需要除消息头字段意外的值,那么可以使用消息属性

3、消息体:封装具体的消息数据

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

JMS consumer:消息消费者,接收和处理JMS消息的客户端应用

消息的消费可以采用以下两种方法之一:

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

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

 

JMS domains:消息传递域,JMS规范中定义了两种消息传递域,点对点(ptp),发布订阅(pub/sub)

 

1、点对点:

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

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

技术分享

 

2、发布订阅

(1)每个消息有多个消费者

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

技术分享

 

3、在点对点消息传递域中,目的地被称为队列,在发布订阅中被称为主题。

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

JMS Connection:封装了科幻与JMS提供者之间的一个虚拟的连接

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

Destination:消息发送到的目的地

Acknowledge:签收

Transaction: 事物

JMS client:用来收发消息的java应用

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

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

 

JMS的消息结构:

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

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

1、JMSDestination:由Send方法设置

2、JMSDeliveryMode:由send方法设置

3、JMSExpiration:由send方法设置

4、JMSPriority:由send方法设置

5、JMSMessageID:由send方法设置

6、JMSTimestamp: 由客户端设置

7、JMSCorrelationID:由客户端设置

8、JMSRelyTo:由科幻端设置

9、JMSType:由客户端设置

10、JMSRedelivered: 由JMS Provider设置

标准的JMS消息头包含以下属性:

1、JMSDefinition: 消息发送的目的地,主要指Queue和Topic,自动分配

2、JMSDleiverMode:传送模式。持久化和非持久化

3、JMSExpiration:消息过期时间

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

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的消息体,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、JMSDeliveryCount: 转发消息重试次数,第一次是1,第二次是2,。。。,发送时提供商设置

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

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

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

7、JMSXConsumerTXID:消费消息的事物标识,接收时提供商设置。

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

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

JMS基本概念