ActiveMQ使用手册(2)

JMSExpiration 消息过期时间，等于Destination 的send 方法中的 timeToLive 值加上发送时刻的GMT 时间值。如果timeToLive 值等于零，则JMSExpiration 被设为零，表示该消息永不过期。 如果发送后，在消息过期时间之后消息还没有被发送到目 的地，则该消息被清除。 消息优先级，从0-9 十个级别，0-4 是普通消息，5-9 是加急消息。JMS 不要求JMS Provider 严格按照这十个 优先级发送消息，但必须保证加急消息要先于普通消息到达。 唯一识别每个消息的标识，由JMS Provider 产生。 一个消息被提交给JMS Provider 到消息被发出的时间。 用来连接到另外一个消息，典型的应用是在回复消息中连接到原消息。 提供本消息回复消息的目的地址 消息类型的识别符。 如果一个客户端收到一个设置了JMSRedelivered 属性的消息， 则表示可能客户端曾经在早些时候收到过该消息，但并没有签收(acknowledged)。 JMSPriority JMSMessageID JMSTimestamp JMSCorrelationID JMSReplyTo JMSType JMSRedelivered

?

消息体。JMS定义的消息类型有TextMessage、MapMessage、BytesMessage、StreamMessage和ObjectMessage。

2.1.2 JMS的可靠性机制

当所有的消息必须被接收，则用持久订阅模式。当丢失消息能够被容忍，则用非持久订阅模式。

2.1.2.1 消息确认

JMS消息只有在被确认之后，才认为已经被成功地消费了。消息的成功消费通常包含三个阶段：客户接收消息、客户处理消息和消息被确认。 在事务性会话中，当一个事务被提交的时候，确认自动发生。在非事务性会话中，消息何时被确认取决于创建会话时的应答模式（acknowledgement mode）。该参数有以下三个可选值： Session.AUTO_ACKNOWLEDGE。当客户成功的从receive方法返回的时候，或者从MessageListener.onMessage方法成功返回的时候，会话自动确认客户收到的消息。

? Session.CLIENT_ACKNOWLEDGE。客户通过消息的acknowledge方法确认消息。需要注意的是，在这种模式中，确认 是在会话层上进行：确认一个被消费的消息将自动确认所有已被会话消费的消息。例如，如果一个消息

?

第3页

消费者消费了10个消息，然后确认第5个消息，那么所有 10个消息都被确认。

? Session.DUPS_ACKNOWLEDGE。该选择只是会话迟钝第确认消息的提交。如果JMS provider失败，那么可能会导致一些重复的消息。如果是重复的消息，那么JMS provider必须把消息头的JMSRedelivered字段设置为true。

2.1.2.2 持久性

JMS 支持以下两种消息提交模式：

PERSISTENT。指示JMS provider持久保存消息，以保证消息不会因为JMS provider的失败而丢失。

? NON_PERSISTENT。不要求JMS provider持久保存消息。

?

2.1.2.3 优先级

可以使用消息优先级来指示JMS provider首先提交紧急的消息。优先级分10个级别，从0（最低）到9（最高）。如果不指定优先级，默认级别是4。需要注意的是，JMS provider并不一定保证按照优先级的顺序提交消息。

2.1.2.4 消息过期

可以设置消息在一定时间后过期，默认是永不过期。

2.1.2.5 临时目的地

可以通过会话上的createTemporaryQueue方法和createTemporaryTopic方法来创建临时目的地。它们的存在时间只限于创建它们的连接所保持的时间。只有创建该临时目的地的连接上的消息消费者才能够从临时目的地中提取消息。

2.1.2.6 持久订阅

首先消息生产者必须使用PERSISTENT提交消息。客户可以通过会话上的createDurableSubscriber方法来创建一个持久订阅，该方法的第一个参数必须是一个topic。第二个参数是订阅的名称。

JMS provider会存储发布到持久订阅对应的topic上的消息。如果最初创建持久订阅的客户或者任何其它客户使用相同的连接工厂和连接的客户ID、相同的主题和相同的订阅名再次调用会话上的

第4页

createDurableSubscriber方法，那么该持久订阅就会被激活。JMS provider会象客户发送客户处于非激活状态时所发布的消息。

持久订阅在某个时刻只能有一个激活的订阅者。持久订阅在创建之后会一直保留，直到应用程序调用会话上的unsubscribe方法。

2.1.2.7 本地事务

在一个JMS客户端，可以使用本地事务来组合消息的发送和接收。JMS Session接口提供了commit和rollback方法。事务提交意味着生产的所有消息被发送，消费的所有消息被确认；事务回滚意味着生产的所有消息被销毁，消费的所有消息被恢复并重新提交，除非它们已经过期。

事务性的会话总是牵涉到事务处理中，commit或rollback方法一旦被调用，一个事务就结束了，而另一个事务被开始。关闭事务性会话将回滚其中的事务。需要注意的是，如果使用请求/回复机制，即发送一个消息，同时希望在同一个事务中等待接收该消息的回复，那么程序将被挂起，因为知道事务提交，发送操作才会真正执行。需要注意的还有一个，消息的生产和消费不能包含在同一个事务中。

2.2 ActiveMQ基本配置

ActiveMQ配置文件：$AcrtiveMQ/conf/activemq.xml

2.2.1 配置ActiveMQ服务IP和端口

第5页

在 transportConnectors标识中配置ActiveMQ服务IP和端口，其中name属性指定协议的名称，uri属性指定协议所对应的协议 名，IP地址和端口号。上述IP地址和端口可以根据实际需要指定。Java客户端默认使用openwire协议，所以ActiveMQ服务地址为 tcp://localhost:61616

2.2.2 监控ActiveMQ

本节将使用JXM和JXM控制台（JDK1.5控制台）监控ActiveMQ。

?

?

配置JXM步骤如下：

1． 设置broker标识的useJmx属性为true；

2． 取消对managementContext标识的注释（系统默认注释managementContext标识），监控的默认端口为1099。

在Windows平台监控

进入%JAVA_HOME%/bin，双击jconsole.exe，在对话框中输入ActiveMQ服务主机的地址，JXM的端口和主机登陆帐号。

第6页

2.3 ActiveMQ的Broker

ActiveMQ中，Broker是消息的代理者，消费者和生产者实际是通过Broker来进行消息的传递，生产者和消费者之间是无法直接通信的。

Broker的实现可以分为如下几种方式：

2.3.1 Running Broker:

ActiveMQ5.0 的二进制发布包中bin目录中包含一个名为activemq的脚本，直接运行这个脚本就可以启动一个broker。

此外也可以通过Broker Configuration URI或Broker XBean URI对broker进行配置，以下是一些命令行参数的例子： Example Description Runs a broker using the default 'xbean:activemq.xml' as the broker configuration file. Runs a broker using the file myconfig.xml as the broker configuration file that is located in the classpath. Runs a broker using the file broker1.xml as the broker configuration file that is located in the relative file path ./conf/broker1.xml activemq activemq xbean:myconfig.xml activemq xbean:file:./conf/broker1.xml 第7页

百度搜索“77cn”或“免费范文网”即可找到本站免费阅读全部范文。收藏本站方便下次阅读，免费范文网，提供经典小说综合文库ActiveMQ使用手册(2)在线全文阅读。