ActiveMQ_in_Action.pdf

《ActiveMQ_in_Action.pdf》由会员上传分享，免费在线阅读，更多相关内容在学术论文-天天文库。

1、http://www.javaeye.com-做最棒的软件开发交流社区ActiveMQinAction作者:whitesockhttp://whitesock.javaeye.com我的博客文章精选第1/46页本书由JavaEye提供的电子书DIY功能自动生成于2008-12-31http://whitesock.javaeye.com目录1.EE1.1ActiveMQinAction(1).............................................................31.2Active

2、MQinAction(2)............................................................151.3ActiveMQinAction(3)............................................................201.4ActiveMQinAction(4)............................................................231.5ActiveMQinAction(5)...

3、.........................................................271.6ActiveMQinAction(6)............................................................341.7ActiveMQinAction(7)............................................................40第2/46页http://whitesock.javaeye.com1.1Acti

4、veMQinAction(1)1.1ActiveMQinAction(1)发表时间:2008-02-25关键字:activemq1JMS在介绍ActiveMQ之前，首先简要介绍一下JMS规范。1．1JMS的基本构件1．1．1连接工厂连接工厂是客户用来创建连接的对象，例如ActiveMQ提供的ActiveMQConnectionFactory。1．1．2连接JMSConnection封装了客户与JMS提供者之间的一个虚拟的连接。1．1．3会话JMSSession是生产和消费消息的一个单线程上下文。会话用于创建消息生产者（produc

5、er）、消息消费者（consumer）和消息（message）等。会话提供了一个事务性的上下文，在这个上下文中，一组发送和接收被组合到了一个原子操作中。1．1．4目的地目的地是客户用来指定它生产的消息的目标和它消费的消息的来源的对象。JMS1.0.2规范中定义了两种消息传递域：点对点（PTP）消息传递域和发布/订阅消息传递域。点对点消息传递域的特点如下：•每个消息只能有一个消费者。•消息的生产者和消费者之间没有时间上的相关性。无论消费者在生产者发送消息的时候是否处于运行状态，它都可以提取消息。发布/订阅消息传递域的特点如下：•每个

6、消息可以有多个消费者。•生产者和消费者之间有时间上的相关性。订阅一个主题的消费者只能消费自它订阅之后发布的消息。JMS规范允许客户创建持久订阅，这在一定程度上放松了时间上的相关性要求。持久订阅允许消费者消费它在未处于激活状态时发送的消息。在点对点消息传递域中，目的地被成为队列（queue）；在发布/订阅消息传递域中，目的地被成为主题（topic）。第3/46页http://whitesock.javaeye.com1.1ActiveMQinAction(1)1．1．5消息生产者消息生产者是由会话创建的一个对象，用于把消息发送到一个

7、目的地。1．1．6消息消费者消息消费者是由会话创建的一个对象，它用于接收发送到目的地的消息。消息的消费可以采用以下两种方法之一：•同步消费。通过调用消费者的receive方法从目的地中显式提取消息。receive方法可以一直阻塞到消息到达。•异步消费。客户可以为消费者注册一个消息监听器，以定义在消息到达时所采取的动作。1．1．7消息JMS消息由以下三部分组成：•消息头。每个消息头字段都有相应的getter和setter方法。•消息属性。如果需要除消息头字段以外的值，那么可以使用消息属性。•消息体。JMS定义的消息类型有TextMe

8、ssage、MapMessage、BytesMessage、StreamMessage和ObjectMessage。1．2JMS的可靠性机制1．2．1确认JMS消息只有在被确认之后，才认为已经被成功地消费了。消息的成功消费通常包含三个阶段：客户接收