`

(03)ActiveMQ学习-2017/2/22

 
阅读更多

一、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设置  

 

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消息结构(消息体)

消息体,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 转发消息到消费者的时间,接收时提供商设置

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

 

 

 

 

 

 

 

 

 

 

分享到:
评论

相关推荐

    activemq-cpp-library-3.9.5 编译的windows库文件,支持vs2015、vs2017

    总之,ActiveMQ-CPP Library 3.9.5为C++开发者提供了与ActiveMQ交互的便捷方式,结合Visual Studio 2015和2017的支持,能够在Windows平台上高效地构建消息驱动的应用程序。通过理解其核心组件和使用方法,开发者可以...

    activemq-cpp-library-3.9.5-src.zip

    2. **ActiveMQ-CPP库核心功能** - **连接管理**:ActiveMQ-CPP库提供了连接工厂,用于创建到ActiveMQ服务器的连接。这些连接可以是持久化的,即使服务器断开也能恢复。 - **会话与消费者**:库中的会话接口负责...

    apache-activemq-5.15.12-bin.tar.gz

    tar -zxvf apache-activemq-5.15.12-bin.tar.gz 2.进入bin目录 cd /apache-activemq-5.15.12/bin 3.运行,没有配置环境变量只能在bin目录下使用命令 ./activemq 4.配置环境变量,配置完环境变量之后...

    编译好的activemq-cpp动态库(2.2.6版本+vs2010)

    自己编译的activemq-cpp的2.X的最后版本,在windows + vs2010下测试通过。压缩包中包含了include\lib\dll文件。 由于尝试了N个3.X的版本都不同过,于是退到2.X版本,通过了,另外在vs2005下编译出来的也没有问题。...

    apache-activemq-5.9.0-bin

    这个“apache-activemq-5.9.0-bin”压缩包包含了Apache ActiveMQ 5.9.0版本的完整二进制文件,用于在本地或网络环境中安装和运行。 Apache ActiveMQ的核心功能包括: 1. **消息队列**:ActiveMQ支持多种消息模式,...

    activemq-protobuf-1.1-API文档-中文版.zip

    赠送jar包:activemq-protobuf-1.1.jar; 赠送原API文档:activemq-protobuf-1.1-javadoc.jar; 赠送源代码:activemq-protobuf-1.1-sources.jar; 包含翻译后的API文档:activemq-protobuf-1.1-javadoc-API文档-...

    activemqBroker-2.14-SNAPSHOT.war

    activemqBroker插件:activemqBroker-2.14-SNAPSHOT.war

    activemq-core-5.7.0-API文档-中英对照版.zip

    赠送jar包:activemq-core-5.7.0.jar; 赠送原API文档:activemq-core-5.7.0-javadoc.jar; 赠送源代码:activemq-core-5.7.0-sources.jar; 包含翻译后的API文档:activemq-core-5.7.0-javadoc-API文档-中文...

    apache-activemq-5.10到apache-activemq6.1大版本合集

    activemq-parent-5.10.0-source-release.zip activemq-parent-5.10.2-source-release.zip activemq-parent-5.12.3-source-release.zip apache-activemq-5.10.2-bin.tar.gz apache-activemq-5.11.4-bin.zip apache-...

    apache-activemq-5.8.0-bin.zip

    这个压缩包"apache-activemq-5.8.0-bin.zip"包含了ActiveMQ 5.8.0版本的二进制发行版,供用户在本地计算机上安装和运行。 1. **Apache ActiveMQ简介** - Apache ActiveMQ是业界广泛使用的消息代理,提供可靠的消息...

    activemq-web-console-5.11.2

    activemq-web-console的默认使用方式是通过在activemq.xml中导入jetty.xml配置一个jetty server来实现的。其实activemq-web-console完全可以和activemq-broker分开来部署。 activemq-web-console包含3个apps, 1.一...

    apache-activemq-5.15.8-bin.zip

    这个"apache-activemq-5.15.8-bin.zip"文件包含了ActiveMQ的可执行版本,用于在本地计算机上安装和运行ActiveMQ服务。 首先,我们需要了解ActiveMQ的核心概念。它是一个消息代理,扮演着消息生产者与消费者之间的...

    apache-activemq-5.12.0-bin

    在“apache-activemq-5.12.0-bin”这个压缩包中,包含了运行Apache ActiveMQ所需的所有文件,适用于Windows操作系统。 Apache ActiveMQ作为消息队列的实现,主要功能包括: 1. **消息传输**:ActiveMQ允许应用程序...

    activemq-broker-5.9.0.jar

    activemq/5.9.0/apache-activemq-5.9.0-bin.tar;activemq/5.9.0/apache-activemq-5.9.0-bin.tar

    activemq-all-5.2.0.jar包

    activemq-all-5.2.0.JAR包,欢迎下载。编写java中间件的时候会用到。这是activemq实现的jms中间件。希望能帮助到你。

    activemq自启动并设置用户名密码

    mv /usr/local/apache-activemq-5.13.4 /usr/local/apache-activemq ``` - **测试启动和停止ActiveMQ**: 进入`/usr/local/apache-activemq/bin/`目录,尝试启动和停止ActiveMQ: ```bash ./activemq start ....

    apache-activemq-5.15.0-bin.tar.7z

    MQ是消息中间件,是一种在分布式系统中应用程序借以传递消息的媒介,常用的有ActiveMQ,RabbitMQ,kafka。ActiveMQ是Apache下的开源项目,完全支持JMS1.1和J2EE1.4规范的JMS Provider实现。 特点: 1、支持多种...

    apache-activemq-5.8.0.zip

    apache-activemq-5.8.0,包解压后可以直接使用,用于系统间的消息的发布与消费。 pom添加: <groupId>org.apache.activemq</groupId> <artifactId>activemq-all</artifactId> <version>5.11.1</version> </...

    activemq安装包-apache-activemq-5.14.4-bin.tar.gz

    这个压缩包"apache-activemq-5.14.4-bin.tar.gz"包含了安装和运行ActiveMQ所需的所有文件。 **ActiveMQ简介** ActiveMQ是一个高性能、灵活且易于使用的消息代理,它允许应用程序通过消息传递进行通信,以解耦生产者...

    linux 下apache-activemq.zip

    配置文件位于`/opt/apache-activemq-5.x.x/conf`目录下,主要关注`activemq.xml`。这个文件定义了ActiveMQ的核心配置,包括消息存储、网络连接等。根据需求,你可以调整这些设置以优化性能或安全性。 3. **启动和...

Global site tag (gtag.js) - Google Analytics