JMS基本概念

JMS是什么

• JMS（Java Message Service），Java消息服务，是Java EE中的技术

JMS规范

• JMS定义了Java中访问消息中间件接口，并没有给予实现，实现JMS接口的消息中间件称为JMS Provider，例如：ActiveMQ
• JMS Provider：实现JMS接口和规范的消息中间件
• JMS Message：JMS的消息，JMS消息由以下三部分组成
  • 消息头：每个消息头字段都有相应的getter和setter方法
  • 消息属性：如果需要除消息头字段以外的值，那么可以使用消息属性
  • 消息体：封装具体的消息属性
• JMS producer：消息生产者，创建和发送JMS消息的客户端应用
• JMS consumer：消息消费者，接收和发送JMS消息的客户端应用
  • 消息的消费可以采用以下两种方式之一：

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

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

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

  • ​​​​​​​​​​​​​​点对点（point—to—point，简写PTP）​​​​​​​

  • 点对点消息传递域特点：

    • 每个消息只能有一个消费者

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

    • 

  • 消息传递域和发布 / 订阅消息传递域（publish / subscribe，简写pub / sub）

  • 发布/订阅消息传递域的特点：

    • ​​​​​​​每个消息可以有多个消费者

    • 生产者和消费者之间有时间上的相关性。订阅一个主题的消费者只能消费自它订阅之后发布的消息。JMS规范允许客户端创建持久订阅，这在一定程度上放松了时间上的相关性要求。持久订阅允许消费者消费它在未激活状态时发送的消息，举例：微博【关注了别人别人没发消息你收不到，只有发了才能收到，当我下线时，生产者可以发布消息，我们收不到，但当我们上线时才能收到】

  • 

JMS开发用到的一些对象

• Connection factory：连接工厂，用来创建连接对象，以连接到JMS的Provider

//创建一个连接工程对象，需要指定服务的IP以及端口
ConnectionFactory connectionFactory=new ActiveMQConnectionFactory("tcp://192.168.0.107:61616");

• JMS Connection：封装了客户与JMS提供者之间的一个虚拟连接

//使用工程对象创建一个Connection对象
Connection connection=connectionFactory.createConnection();

• JMS Session：是生产和消费消息的一个单线程上下文
  • 会话用于创建消息生产者（producer） 、消息消费者（consumer）和消息（message）等。会话提供了一个事务性的上下文，在这个上下文中，一组发送和接收被组合到一个院子操作中

//创建一个Session对象
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
//使用Session对象创建一个Destination【目的地对象】对象，两种形式:queue,topic，现在应该使用queue
Queue queue = session.createQueue("my-queue");
//使用Session对象创建一个producer对象
MessageProducer producer = session.createProducer(queue);

• Destination：消息发送的目的地
• Acknowledge：签收
• Transaction：事务

/**
 * 第一个参数：是否开启事务。如果true开启事务那么第二个参数没有意义。一般不开启事务false
 * 【如果消息没有发出去那就重发，一般和分布式的事务配合使用，数据库的分布式事务：同时提交多个数据库，保证这些事务都在一个事务中完成】
 * 第二个参数：应答模式。一般是自动应答
 * 【接受到了之后是自动应答，还是手动应答】
 *      CLIENT_ACKNOWLEDGE: 手动应答
 *      AUTO_ACKNOWLEDGE:   自动应答
 */
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

• JMS client：用来收发消息的Java应用
• Non-JMS client：使用JMS provider本地API写的应用，用来代替JMS API实现收发消息的功能，通常会提供其他的一些特性，比如：CORBA、RMI等
• Admininistered objects：预定的JMS对象，通常在 provider 规范中有定义，提供给JMS客户端来访问，比如：ConnectionFactory 和 Destination

JMS的消息结构

• JMS消息由一下几部分组成：消息头，属性，消息体
• 消息头包含消息的识别信息和路由信息，消息头包含一些标准的属性如下：
  • JMSDestination：由send方法设置
  • JMSDeliveryMode：由send方法设置
  • JMSExpiration：由send方法设置
  • JMSPriority：由send方法设置
  • JMSMessageID：由send方法设置
  • JMSTimestamp：由客户端设置
  • JMSCorrelationID：由客户端设置
  • JMSReplyTo：由客户端设置
  • JMSType：由客户端设置
  • JMSRedelivered：由JMS Provider设置
• ​​​​​​​标准的JMS消息头包含以下属性：
  • ​​​​​​​JMSDestination：消息发送的目的地：主要是指Queue和Topic，自动分配
  • JMSDeliveryMode：传送模式。有两种：持久模式和非持久模式。一条持久性的消息应该被传送“一次仅仅一次”，这就意味着如果JMS提供者出现故障，该消息并不会丢失，它会在服务器恢复之后再次传递。一条非持久性的消息最多会传送一次，这意味着服务器出现故障，该消息将永远丢失。自动分配
  • JMSExpiration：消息过期设置，等于Destination的send方法中的timeToLive值加上发送时刻的GMT时间值。如果timeToLive值等于0，则JMSExpiration被设为0，表示该消息永远不过期。如果发送后，在消息过期时间之后消息还没有被发送到目的地，则该消息被清除。自动分配
  • JMSPriority：消息优先级，从0—9十个级别，0—4是普通消息，5—9是加急消息。JMS不要求JMS Provider严格按照这十个优先级发送消息，但必须保证加急消息要优先与普通消息到达。默认是4级。自动分配
  • JMSMessageID：唯一识别每个消息的标识，由JMS Provider产生。自动分配
  • JMSTimestamp：一个JMS Provider在调用send ( ) 方法时自动设置的。它是消息被发送和消费者实际接收的时间差。自动分配
  • JMSCorrelationID：用来连接到另一个消息，典型的应用是在恢复消息中连接到原消息。在大多数情况下，JMSCorrelationID用于将一条消息标记为对JMSMessageID标示的上一条消息的应答，不过，JMSCorrelationID可以是任何值，不仅仅是JMSMessageID。由开发者设置
  • JMSReplyTo：提供本消息恢复消息的目的地址。【这里生产者发送完消息，消费者接收消息，还可以返回消息，返回给生产者】由开发者设置
  • JMSType：消息类型的识别符。由开发者设置
  • JMSRedelivered：如果一个客户端收到一个设置了JMSRedelivered属性的消息，则表示可能客户端曾经在早些时候收到过该消息，但并没有签收（acknowledge）。如果该消息被重新传送，JMSRedelivered=true反之，JMSRedelivered=false。自动设置
• ​​​​​​​消息体：JMS API定义了5种消息格式，也叫消息类型，可以使用不同形式发送接收数据，并可以兼容现有的消息格式。包括：TestMessage【普通文本信息】、MapMessage【Map集合格式（key，value）】、ByteMessage【Byte数组类型的消息】、StreamMessage【流式消息】 和 ObjectMessage【对象消息】
• 消息属性，包含以下三种类型的数据：
  • ​​​​​​​应用程序设置和添加的属性，比如：
    • 
  • JMS定义的属性：
    • 使用 “JMSX” 作为属性名的前缀，connection.getMetaData().getJMSXPropertyNames()，方法返回所有连接支持 JMSX 属性的名字。
  • ​​​​​​​JMS提供商特定的属性
• ​​​​​​​JMS定义的属性如下：
  • ​​​​​​​JMSXUserID：发送消息的用户标识，发送时提供商设置
  • JMSXAPPID：发送消息的应用识别，发送时提供商设置
  • JMSXDeliverCount：转发消息重试次数，第一次1，第二次2，。。。，发送时提供商设置
  • JMSXGroupID：消息所在消息组的标识，由客户端设置
  • JMSXGroupSeq：；组内消息的序号，第一个消息是1，第二个是2，。。。，由客户端设置
  • JMSXProducerTXID：产生消息的事务的事务识别，发送时提供方设置
  • JMSXConsumerTXID：消费消息的事务的事务标识，接收是提供方设置
  • JMSRcvTimestamp：JMS转发消息到消费者的时间，接收是提供方设置
  • JMSXState：假定存在一个消息仓库，它存储了每个消息的单独拷贝，且这些消息从原始消息被发送时开始。每个拷贝的状态有：1（等待），2（准备），3（到期），4（保留）。由于状态与产生者和消费者无关，所以它不是由他们来提供。它只和在仓库中查找消息相关，因此JMS没有提供这种API。由提供商设置