不为有趣之事,何遣有涯之生
不失其所者久,死而不亡者寿

AMQ简明教程(3) JMS消息结构

JMS消息结构

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

消息头

包含消息的识别信息和路由信息,消息头包含一些标准的属性如下:
1:JMSDestination:由send方法设置
2:JMSDeliveryMode:由send方法设置
3:JMSExpiration:由send方法设置
4:JMSPriority:由send方法设置
5:JMSMessageID:由send方法设置
6:JMSTimestamp:由客户端设置
7:JMSCorrelationID :由客户端设置
8:JMSReplyTo :由客户端设置
9:JMSType :由客户端设置
10:JMSRedelivered:由JMS Provider设置

标准的JMS 消息头包含以下属性:
1:JMSDestination:消息发送的目的地:主要是指Queue和Topic,自动分配
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属性的消息,则表示可能客户端曾经在早些时候收到过该消息,
但并没有签收(acknowledged)。如果该消息被重新传送,JMSRedelivered=true 反之,JMSRedelivered =false。

消息体

JMS API定义了5种消息体格式,也叫消息类型,可以使用不同形式发送接收数据,并可以兼容现有的消息格式。

包括: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:JMSXConsumerTXID :消费消息的事务的事务标识,接收时提供商设置
8:JMSXRcvTimestamp :JMS 转发消息到消费者的时间,接收时提供商设置

JMSXUserID:发送消息的用户标识,发送时提供商设置
JMSXAppID:发送消息的应用标识,发送时提供商设置
JMSXDeliveryCount:转发消息重试次数,第一次是1,第二次是2,… ,发送时提供商设置
JMSXGroupID:消息所在消息组的标识,由客户端设置
JMSXGroupSeq:组内消息的序号第一个消息是1,第二个是2,…,由客户端设置
JMSXProducerTXID :产生消息的事务的事务标识,发送时提供商设置
JMSXConsumerTXID :消费消息的事务的事务标识,接收时提供商设置
JMSXRcvTimestamp :JMS 转发消息到消费者的时间,接收时提供商设置
JMSXState:假定存在一个消息仓库,它存储了每个消息的单独拷贝,且这些消息从原始消息被发送时开始。

每个拷贝的状态有:1(等待),2(准备),3(到期)或4(保留)。由于状态与生产者和消费者无关,所以它不是由它们来提供。
它只和在仓库中查找消息相关,因此JMS没有提供这种API。由提供商设置

未经允许不得转载:菡萏如佳人 » AMQ简明教程(3)

欢迎加入极客江湖

进入江湖关于作者