activeMQ(1):理解和掌握JMS(-)

JMS是什么

JMSJava Message Service，java消息服务，是java EE的一中技术。

JMS定义了java中访问消息中间件的接口，并没有给予实现，实现JMS 接口的消息中间件称为JMS Provider，例如activeMQ。

基本概念

JMSMessage:JMS的消息，JMS消息由一下三部分组成：

消息头，每个消息头字段都有相应getter和setter方法

    消息属性，如果需要除消息头字段以外的值，那么可以使用消息属性

    消息体，封装具体的消息数据

JMSProducer消息生产者，创建和发送JMS消息的客户端应用

JMS Consumer消息消费者，接收和处理JMS消息的客户端应用

消息的消费可以采用以下两种方式之一:

1：同步消费：通过调用消费者的receive方法从目的地显示的提取消息，receive方法可以一直阻塞到消息到达。

2:异步消费:客户可以为消费者注册一个消息监听器，以定义在消息到达时所采取的动作。

Connectionfactory 连接工厂，用来创建连接对象，以连接到JMS的Provider

JMSConnection封装了客户端与JMS Provider之间的一个虚拟连接

JMSSession是生产和消费消息的一个单线程上下文

   session会话用于创建生产者、消费者和消息(message)等。会话提供了一个事务性的上下文，在这个上下文中，一组发送和接收被组合到了一个原子操作中。

Destination消息发送到的目的地

Acknowledge签收

Transaction事务

JMSClient用来收发消息的java应用

Non-JMSClient 使用JMS Provider本地API写的应用，用来替换JMS API实现收发消息的功能，通常会提供其他的一些特性，比如CORBA、RMI等。

Administeredobjects预定义的JMS对象，通常会在Provider规范中有定义，提供给JMS客户端来访问，比如：ConnectionFactory、Destination。

JMS消息结构

JMS消息由以下几部分组成：消息头，属性和消息体。

消息头包含消息的识别信息和路由信息，消息头包含一些标准的属性如下：

JMSDestination由send方法设置

    消息发送的目的地，主要指Queue和Topic

JMSDeliveryMode由send方法设置

    传送模式，有两种：持久模式和非持久模式。一条持久性的消息应该被传送“一次仅仅一次”，这就意味着JMS提供者出现故障，该消息并不会丢失，它会在服务器恢复之后再次传递。一条非持久的消息最多会传送一次，这意味着服务器出现故障，该消息将永远丢失。

JMSExpiration由send方法设置

    消息过期时间，producer的send方法中的timeToLive值加上发送时刻的GMT时间值。如果timeTolive值等于0，则JMSExpiration值被设为0，表示消息永不过期。如果消息发送之后，在过期时间之后，还没有被发送到目的地，则该消息被清除。

JMSPriority由send方法设置

消息优先级，从0-9十个级别，0-4是普通消息，5-9是加急消息。JMS不要求JMS Provider严格按照这十个优先级发送消息，但必须保证加急消息要先于普通消息到达。默认是4级。默认是永不过期。

JMSMessageId由send方法设置

唯一识别每个消息的标识

JMSTimestamp由客户端设置message属性

一个JMS Provider在调用send方法时自动设置的。它是消息被发送和消费者实际接收的时间差。

JMSCorrelationID由客户端设置message属性

    同来连接到另外一个消息，典型的应用的在回复消息中连接到原消息。在大多数情况下，JMSCorrelationID用于将一条消息标记为对JMSMessageID标识的上一条消息的应答，不过JMSCorrelationID可以是任何值，不仅仅是JMSMessageID。

JMSReplyTo由客户端设置message属性

    提供本消息回复消息的目的地址

JMSType由客户端设置message属性

    消息类型的识别符

JMSRedelivered由客户端设置message属性

    如果一个客户端收到一个设置JMSRedelivered属性的消息，则表示可能客户端曾经在早些时候收到过该消息，但并没有签收(acknowledged)。如果该消息被重复发送，JMSRedelivered=true，反之，JMSRedelivered=false。

如下代码示例:

        for(int i=0;i<30;i++){

            TextMessage textMessage = session.createTextMessage("messageaa"+i);

            //设置消息属性

            //textMessage.setJMSRedelivered(redelivered);

            producer.send(textMessage);

            //通过send方法设置不同属性值

            //producer.send(destination,message, deliveryMode, priority, timeToLive);

        }

消息体

JMSAPI定义了5种消息体格式，也叫消息类型，可以使用不同形式发送接收数据，并可以兼容现有的消息格式。包括：TextMessage、MapMessage、ByteMessage、StreamMessage和ObjectMessage

要求 发送的是什么类型的消息，接收的时候也必须是什么类型

消息属性

应用程序设置和添加的属性:

Message.serStringProperty(“username”,username);

JMS 定义的属性

使用“JMSX”作为属性名的前缀，connection.getMetaData().getJMSXPropertyNames(),方法返回所有连接支持的JMSX属性的名字。

JMS定义的属性

JMSXUserID发送消息的用户标识

JMSXAppID发送消息的应用标识

JMSXDeliveryCount转发消息重试次数，第一次是1，第二次是2，。。。

JMSXGroupID消息所在消息组标识

JMSXGroupSeq组内消息的序号，第一个消息是1，第二个消息是2，。。。

JMSXProducerTXID产生消息的事务的事务标识

JMSXConsumerTXID消费消息的事务的事务标识

JMSXRCVTimestampJMS转发消息到消费者的时间

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

消息传递域

JMS规范中定义了两种消息传递域：

点对点消息传递域

点对点消息传递域，point-to-point，简写成PTP，消息目的地被称为队列(queue)。

点对点消息传递域特点如下：

   每个(条)消息只能有一个消费者，但是一个消息队列可以有多个消费者，消息被消费之后，消息就会被移出队列，其他的消费者就不能在去消费这条消息了。

   消息的生产者和消费者之间没有时间上的相关性，无论消费者在生产者发送消息的时候是否处于运行状态，它都可以提取消息。

                              

点对点方式，生产者和消费者之间是一个队列。既然是一个队列，那么消息的就遵循先进先出的原则，消费者接收到的消息，是按照生产者发送的顺序接收的。

如果在session关闭时，有一些消息已被收到，但还没有签收(acknowledge),那么。当消费者下次连接到相同的队列时，这些消息还会被再次接收

如果用户在receive方法中设定了消息选择条件，那么不符合条件的消息会留在队列中，不会被接收到

队列可以长久保存消息直到消费者接收消息。消费者不需要因为担心消息丢失而时刻和队列保持激活的连接状态，充分体现了异步传输模式的优势

发布/订阅消息传递域

发布/订阅消息传递域，publish/subscribe，简写成pub/sub,消息目的地被称为主题(topic)

发布/订阅消息传递域特点如下：

   每个(条)消息可以有多个消费者

   生产者和消费者之间有时间上的相关性。订阅一个主题的消费者只能消费自它订阅之后发布的消息(类似与微博)。JMS规范允许客户创建持久订阅，这在一定程度上放松了时间上的相关性要求。持久订阅允许消费者消费它在处于未激活状态时发送的消息。

消息订阅分为非持久订阅和持久订阅

非持久订阅只有当客户端处于激活(在线)状态，也就是和JMS Provider保持连接状态才能收到发送到某个topic的消息，而当客户端处于离线状态，这个时间段发到topic的消息将会丢失，永远不会收到。

持久订阅时，客户端向JMS注册一个识别自己身份ID，当这个客户端处于离线时，JMS Provider会为这个ID保存所有发送到topic的消息，当客户端再次连接到JMS Provider时，会根据自己的ID得到所有当自己处于离线时发送到topic的消息。

如果用户在receive方法中设定了消息选择条件，那么不符合条件的消息不会被接收

非持久订阅状态下，不能恢复或重新发送一个未签收的消息。只有持久订阅才能恢复或重新发送一个未签收的消息。

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

性能上肯定是非持久订阅好，就不用保存以前的消息了