ActiveMQ-inAction-JMS-学习笔记

JMS 的基本构件

• 链接工厂
  • 链接工厂是客户用来建立链接的对象，例如ActiveMQ 提供的ActiveMQConnectionFactory。
• 链接
  • JMS Connection 封装了客户与JMS 提供者之间的一个虚拟的链接。
• 会话
  • JMS Session是生产和消费消息的一个单线程上下文。
  • 会话用于建立消息生产者（producer）、消息消费者（consumer）和消息 （message）等。
  • 会话提供了一个事务性的上下文，在这个上下文中，一组发送和接收被组合到了一个原子操做中。
• 目的地
  • 目的地是客户用来指定它生产的消息的目标和它消费的消息的来源的对象。

JMS1.0.2 规范中定义了两种消息传递域：点对点 （PTP）消息传递域和发布/订阅消息传递域。

• 点对点消息传递域的特色以下：
  • 每一个消息只能有一个消费者。
  • 消息的生产者和消费者之间没有时间上的相关性。不管消费者在生产者发送消息的时候是否处于运行状态，它均可以提取消息。
• 发布/订阅消息传递域的特色以下：
  • 每一个消息能够有多个消费者。
  • 生产者和消费者之间有时间上的相关性。
    • 订阅一个主题的消费者只能消费自它订阅以后发布的消息。
    • JMS规范容许客户建立持久订阅，这在必定程度上放松了时间上的相关性要求。
    • 持久订阅容许消费者消费它在未处于激活状态时发送的消息。
• 在点对点消息传递域中，目的地被成为队列（queue）；在发布/订阅消息传递域中，目的地被成为主题（topic）。

消息生产者

• 消息生产者是由会话建立的一个对象，用于把消息发送到一个目的地。

消息消费者

 

• 消息消费者是由会话建立的一个对象，它用于接收发送到目的地的消息。
• 消息的消费能够采用如下两种方法之一：
  • 同步消费。经过调用 消费者的receive方法从目的地中显式提取消息。
    • receive方法能够一直阻塞到消息到达。
  • 异步消费。客户能够为消费者注册一个消息监听器，以定义在消息到达时所采起的动做。

消息

• JMS消息由如下三部分组成：
  • 消息头。每一个消息头字段都有相应的getter和setter方法。
  • 消息属性。若是须要除消息头字段之外的值，那么可使用消息属性。
  • 消息体。JMS定义的消息类型有TextMessage、MapMessage、BytesMessage、StreamMessage和 ObjectMessage。

JMS 的可靠性机制

• 确认
  • JMS消息只有在被确认以后，才认为已经被成功地消费了。
  • 消息的成功消费一般包含三个阶段：客户接收消息、客户处理消息和消息被确认。
• 在事务性会话中，当一个事务被提交的时候，确认自动发生。
• 在非事务性会话中，消息什么时候被确认取决于建立会话时的应答模式（acknowledgement mode）。
• 该参数有如下三个可选值：
  • Session.AUTO_ACKNOWLEDGE。
    • 当客户成功的从receive方法返回的时候，或者从MessageListener.onMessage方法成功返回的时候，会话自动确认客户收到的消息。
  • Session.CLIENT_ACKNOWLEDGE。
    • 客户经过消息的acknowledge方法确认消息。
    • 须要注意的是，在这种模式中，确认是在会话层上进行：确认一个被消费的消息将自动确认全部已被会话消费的消息。
    • 例如，若是一个消息消费者消费了10个消息，而后确认第5个消息，那么全部10个消息都被确认。
  • Session.DUPS_ACKNOWLEDGE。
    • 该选择只是会话迟钝的确认消息的提交。
    • 若是JMS provider失败，那么可能会致使一些重复的消息。
    • 若是是重复的消息，那么JMS provider必须把消息头的JMSRedelivered字段设置为 true。
• 持久性
  • ​​​​​​​JMS 支持如下两种消息提交模式：
    • ​​​​​​​PERSISTENT。指示JMS provider持久保存消息，以保证消息不会由于JMS provider的失败而丢失。
    • NON_PERSISTENT。不要求JMS provider持久保存消息。
•  优先级
  • ​​​​​​​可使用消息优先级来指示JMS provider首先提交紧急的消息。
  • 优先级分10 个级别，从0（最低）到9（最高）。
  • 若是不指定优先级，默认级别是4。
  • 须要注意的是，JMS provider并不必定保证按照优先级的顺序提交消息。
• 消息过时
  • ​​​​​​​能够设置消息在必定时间后过时，默认是永不过时。
• 临时目的地
  • ​​​​​​​能够经过会话上的createTemporaryQueue方法和createTemporaryTopic方法来建立临时目的地。
  • 它们的存在时间只限于建立它们的链接所保持的时间。
  • 只有建立该临时目的地的链接上的消息消费者才可以从临时目的地中提取消息。
• 持久订阅
  • ​​​​​​​首先消息生产者必须使用PERSISTENT提交消息。
  • 客户能够经过会话上的 createDurableSubscriber方法来建立一个持久订阅，
  • 该方法的第一个参数必须是一个topic。
  • 第二个参数是订阅的名称。

  • JMS provider会存储发布到持久订阅对应的topic上的消息。

  • 若是最初建立持久订阅的客户或者任何其它客户使用相同的链接工厂和链接的客户ID、相同的主题和相同的订阅名再次调用会话上的createDurableSubscriber方法，那么该持久订阅就会被激活。

  • JMS provider会向客户发送客户处于非激活状态时所发布的消息。

  • 持久订阅在某个时刻只能有一个激活的订阅者。

  • 持久订阅在建立以后会一直保留，直到应用程序调用会话上的unsubscribe方法。 ​​​​​​​​​​​​​​

• 本地事务

  • ​​​​​​​在一个JMS客户端，可使用本地事务来组合消息的发送和接收。

    • JMS Session 接口提供了commit和rollback方法。

    • 事务提交意味着生产的全部消息被发送，消费的全部消息被确认；

    • 事务回滚意味着生产的全部消 息被销毁，消费的全部消息被恢复并从新提交，除非它们已通过期。 ​​​​​​​

  •  事务性的会话老是牵涉到事务处理中，commit或rollback方法一旦被调用，一个事务就结束了，而另外一个事务被开始。

    • 关闭事务性会话将回滚其中的事务。

  • 须要注意的是，

    • 若是使用请求/回复机制，即发送一个消息，同时但愿在同一个事务中等待接收该消息的回复，那么程序将被挂起，由于直到事务提交，发送操做才会真正执行。

    • 须要注意的还有一个，消息的生产和消费不能包含在同一个事务中。

如下是不一样消息传递域的相应接口：

JMS 公共	点对点域	发布/订阅域
ConnectionFactory	QueueConnectionFactory	TopicConnectionFactory
Connection	QueueConnection	TopicConnection
Destination	Queue	Topic
Session	QueueSession	TopicSession
MessageProducer	QueueSender	TopicPublisher
MessageConsumer	QueueReceiver	TopicSubscriber