不论人生多不幸，聪明的人总会从中获得一点利益；不论人生多幸福，愚蠢的人总觉得无限悲哀。 —— 拉·罗休弗克
1. 基本概念
JMS（JAVA Message Service,java消息服务）API是一个消息服务的标准或者说是规范，允许应用程序组件基于JavaEE平台创建、发送、接收和读取消息。它使分布式通信耦合度更低，消息服务更加可靠以及异步性。
2. JMS基本组件
2.1 JMS provider
实现了JMS规范的消息系统，该系统还提供必须的用于管理和控制全方位的功能，如ActiveMQ。
2.2 JMS message
JMS的消息，JMS消息由一下三部组成：
1：消息头：每个消息头字段都有相应的getter和setter方法。
2：消息属性：如果需要除消息头字段以外的值，那么可以使用消息属性。
3：消息体：封装具体的消息数据。
2.3 JMS producer
消息生产者由Session创建，并用于将消息发送到Destination。同样，消息生产者分两种类型：QueueSender和TopicPublisher。可以调用消息生产者的方法（send或publish方法）发送消息。
// 创建生产者
MessageProducer messageProducer = session.createProducer(destination);
2.4 JMS consumer
消息消费者由Session创建，用于接收被发送到Destination的消息。两种类型：QueueReceiver和TopicSubscriber。可分别通过session的createReceiver(Queue)或createSubscriber(Topic)来创建。当然，也可以session的creatDurableSubscriber方法来创建持久化的订阅者。
消息的消费可以采用以下两种方法之一：
1：同步消费：消费者调用receive方法来接收消息，receive方法在能够接收到消息之前（或超时之前）将一直阻塞。
2：异步消费：消费者可以注册为一个消息监听器。当消息到达之后，系统自动调用监听器的onMessage方法。
// 创建消费者
MessageConsumer messageConsumer = session.createConsumer(destination);
2.5 ConnectionFactory
创建Connection对象的工厂，针对两种不同的jms消息模型，分别有QueueConnectionFactory和TopicConnectionFactory两种。可以通过JNDI来查找ConnectionFactory对象。
// 实例化连接工厂
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(USERNAME, PASSWORD, BOKER_URL);
2.6 Destination
Destination的意思是消息生产者的消息发送目标或者说消息消费者的消息来源。对于消息生产者来说，它的Destination是某个队列（Queue）或某个主题（Topic）；对于消息消费者来说，它的Destination也是某个队列或主题（即消息来源）。
// 创建队列
Destination destination = session.createQueue(queue);
2.7 Connection
Connection表示在客户端和JMS系统之间建立的链接（对TCP/IP socket的包装）。Connection可以产生一个或多个Session。跟ConnectionFactory一样，Connection也有两种类型：QueueConnection和TopicConnection。
// 通过连接工厂获取连接
Connection connection = connectionFactory.createConnection();
// 启动连接
connection.start();
2.8 Session
Session是我们操作消息的接口。可以通过session创建生产者、消费者、消息等。Session提供了事务的功能。当我们需要使用session发送/接收多个消息时，可以将这些发送/接收动作放到一个事务中。同样，也分QueueSession和TopicSession。
session = connection.createSession(Boolean.FALSE,Session.AUTO_ACKNOWLEDGE);
2.9 MessageListener
消息监听器。如果注册了消息监听器，一旦消息到达，将自动调用监听器的onMessage方法。
public class JmsListener implements MessageListener {
@Override
public void onMessage(Message message) {
try {
System.out.println("收到的消息：" + ((TextMessage) message).getText());
} catch (JMSException e) {
e.printStackTrace();
}
}
}
3. JMS消费模型
JMS规范中定义了两种消息模型：
1：点对点 （point-to-point，简写成PTP）。
2：发布/订阅（publish/subscribe，简写:成pub/sub）。
4. JMS消息结构
4.1 消息头
消息头包含消息的识别信息和路由信息。
- JMSDestination：消息发送的目的地，由send方法设置。
- JMSDeliveryMode：传送模式，由send方法设置。传送模式，有两种 ：持久模式和非持久模式。一条持久性的消息应该被传送“一次仅仅一次”，这就意味者如果JMS提供者出现故障，该消息并不会丢失，它会在服务器恢复之后再次传递。
- JMSExpiration：消息过期时间，由send方法设置。
消息过期时间，等于Destination的send方法中的timeToLive值加上发送时刻的GMT时间值。
如果timeToLive值等于零，则JMSExpiration 被设为零，表示该消息永不过期。
如果timeToLive值不等于零，在消息过期时间之后消息还没有被发送到目的地，则该消息被清除。 - JMSPriority：消息优先级，由send方法设置。
从 0-9 十个级别，0-4 是普通消息，5-9 是加急消息。
JMS不要求JMSProvider严格按照这十个优先级发送消息，但必须保证加急消息要先于普通消息到达。默认是4级。 - JMSMessageID：由send方法设置，唯一识别每个消息的标识，由JMS Provider 产生。
- JMSTimestamp：由客户端设置。
一个JMS Provider在调用send()方法时自动设置的。它是消息被发送和消费者实际接收的时间差。 - JMSCorrelationID ：由客户端设置。
用来连接到另外一个消息，典型的应用是在回复消息中连接到原消息。在大多数情况下，JMSCorrelationID用于将一条消息标记为对JMSMessageID标示的上一条消息的应答，不过，JMSCorrelationID可以是任何值，不仅仅是JMSMessageID，由开发者设置。 - JMSReplyTo ：由客户端设置。
提供本消息回复消息的目的地址，由开发者设置。 - JMSType ：由客户端设置。
消息类型的识别符，由开发者设置。 - JMSRedelivered：由JMS Provider设置。
4.2 消息属性
消息属性，包含以下三种类型的属性：
- 应用程序设置和添加的属性，比如：
Message.setStringProperty("username",username);
- JMS定义的属性：使用“JMSX”作为属性名的前缀，connection.getMetaData().getJMSXPropertyNames()方法返回所有连接支持的JMSX 属性的名字。
JMS定义的属性如下：
1：JMSXUserID：发送消息的用户标识，发送时提供商设置。
2：JMSXAppID：发送消息的应用标识，发送时提供商设置。
3：JMSXDeliveryCount：转发消息重试次数,第一次是1，第二次是2，… ，发送时提供商设置。
4：JMSXGroupID：消息所在消息组的标识，由客户端设置。
5：JMSXGroupSeq：组内消息的序号第一个消息是1，第二个是2，…，由客户端设置。
6：JMSXProducerTXID ：产生消息的事务的事务标识，发送时提供商设置。
7：JMSXConsumerTXID ：消费消息的事务的事务标识，接收时提供商设置。
8：JMSXRcvTimestamp ：JMS 转发消息到消费者的时间，接收时提供商设置。
9：JMSXState：假定存在一个消息仓库，它存储了每个消息的单独拷贝，且这些消息从原始消息被发送时开始。每个拷贝的状态有：1（等待），2（准备），3（到期）或4（保留）。
由于状态与生产者和消费者无关，所以它不是由它们来提供。它只和在仓库中查找消息相关，因此JMS没有提供这种API。由提供商设置。 - JMS供应商特定的属性
4.3 消息体
消息体，JMS API定义了5种消息体格式，也叫消息类型，可以使用不同形式发送接收数据，并可以兼容现有的消息格式。
包括：TextMessage、MapMessage、BytesMessage、StreamMessage和ObjectMessage。
5. 使用JMS的好处
- 提供消息灵活性
- 松散耦合
- 异步性
总结成一句话：削峰限流异步化。
