01、JMS规范介绍

本文主要是介绍01、JMS规范介绍，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

01、JMS规范介绍

在我们正式学习Kafka之前，先来了解下JMS，因为这可以在一定程度上帮助你更加深入的理解和学习Kafka。

1、 JMS简介

JMS，全称Java Mesage Service，即Java消息服务应用程序接口，是一个Java平台中关于面向消息中间件的AP!，用于在两个应用程序之间、或者分布式系统中发送消息，进行异步通信。

JMS是一种与厂商无关的API，用来访问消息、收发系统消息，它类似于JDBC。

JMS可以自己使用Java代码或者别的代码来编写，开源的实现有Active MQ、阿里的Rocket MQ(已贡献给Apache)、Kafka等。

JMS（Java Message Service）是Java平台中关于面向消息中间件（MOM）的一个API，用于在两个应用程序之间，或分布式系统中发送消息，进行异步通信。JMS API定义了一组规范，允许应用程序组件通过消息传递进行通信，从而实现松耦合的消费者和生产者。JMS支持两种消息发送和接收模型：点对点（P2P）模型和发布/订阅模型。

在点对点模型中，消息生产者发送消息到队列，消息消费者从队列中接收消息，每个消息只有一个消费者。而在发布/订阅模型中，消息生产者向主题发布消息，而消息消费者订阅主题以接收消息，允许一个消息被多个消费者消费。

我们为什么要使用消息队列呢?

有些网站会在某些时间段的访间量暴增，何如各电商购物平台的秒杀活动、12306枪票等场最，而在访问量暴增的时候，对服务器就是一个非常大的孝验!服务器能够处理的访问最是有眼的，例如某公司的服务器能够同时处理50W连接消求，但是在活动的期间，访问最到达了70W，那么此时婴么会有20W的访问被丢弃，婴么干能服务器崔爽，无论是哪一种结果，对于用户都是非常不友好的!那么，如何去处理这样的场最的?此时犹借要消息队列了!

面对比较大的流量冲击，在网站系统中一般都会有一个消息存储/缓存系统，网站就可以按照自己的负载能力来消费这些消息，这就是一个消息队列，或者叫消息中间件。

2、 JMS 核心组件

JMS定义了几种核心概念，包括：

JMS Provider：实现JMS接口和规范的消息中间件，也就是MQ服务器（如ActiveMQ, RabbitMQ, Kafka等）。
JMS Producer（消息生产者）：创建和发送JMS消息的客户端应用。
JMS Consumer（消息消费者）：接收和处理JMS消息的客户端。
JMS Message：JMS中用于传递的数据对象，由消息头、消息属性和消息体组成。
Destination（目的地）：消息发送的目标位置，可以是队列（Queue）或主题（Topic）。
Connection Factory：用于创建与JMS提供者之间的连接的工厂对象。
Connection：代表客户端与JMS提供者之间的通信链路。
Session：提供创建、发送和接收消息的操作环境，可以是点对点或发布订阅。
Message Listener：消息监听器，用于异步接收消息。

JMS消息由三部分组成：消息头、消息属性和消息体。消息头包含了如JMSDestination、JMSDeliveryMode、JMSExpiration、JMSPriority、JMSMessageID等属性，这些属性提供了关于消息如何发送和接收的重要信息。

JMS提供可靠性、灵活性和可扩展性，支持事务处理、持久化消息、异步消息处理等特性。它还可以与其他企业级技术集成，如企业服务总线（ESB）、业务流程管理（BPM）系统和云计算平台。

JMS广泛应用于分布式系统的通信中，特别是在需要解耦、异步处理、高可靠性和可扩展性的场景中。通过使用JMS，开发者可以构建出强大且灵活的消息驱动应用程序。

3、 JMS 消息传输模型

JMS（Java Message Service）支持两种主要的消息传输模型：

点对点（Point-to-Point，P2P）模型：
- 在这个模型中，消息生产者发送消息到队列（Queue），消息消费者从队列中接收消息。
- 每个消息只能被一个消费者接收，一旦消息被消费，它就会从队列中移除，确保消息不会重复处理。
- 这种模型适用于需要确保消息只被处理一次的场景，例如订单处理、用户请求处理等。
发布/订阅（Publish/Subscribe，Pub/Sub）模型：
- 在发布/订阅模型中，消息生产者（发布者）将消息发送到主题（Topic），而消息消费者（订阅者）订阅感兴趣的主题。
- 一个发布者发送的消息可以被多个订阅者接收，这使得发布/订阅模型非常适合需要一对多通信的场景。
- 订阅者可以设置过滤条件，只接收满足特定条件的消息，这增加了消息传输的灵活性。

两种模型的特点对比：

一对一 vs 一对多：
- P2P模型是一对一的消息传输，每条消息只有一个消费者。
- Pub/Sub模型是一对多的消息传输，一条消息可以被多个订阅者接收。
队列 vs 主题：
- 在P2P模型中，使用队列作为消息的容器，队列保证了消息的顺序性和独立性。
- 在Pub/Sub模型中，使用主题作为消息的发布点，主题允许多个订阅者接收消息。
消息确认：
- 在P2P模型中，消费者通常需要显式确认消息，告知消息服务器消息已被成功处理。
- 在Pub/Sub模型中，订阅者可能需要确认消息，也可能不需要，这取决于具体的实现和配置。
消息持久性：
- 在两种模型中，都可以配置消息的持久性，确保消息不会因为系统故障而丢失。

JMS的这两种消息传输模型为不同的应用场景提供了灵活的消息传递机制，允许开发者根据业务需求选择合适的模型来实现消息通信。

4、 JMS 消息接收

JMS（Java Message Service）支持多种消息接收方式，这些方式主要与JMS的两种消息传输模型（点对点和发布/订阅）相关。以下是一些常见的消息接收方式：

点对点（P2P）模型的消息接收方式：

同步接收：
- 消费者使用receive()方法从队列中同步接收消息。这是一种阻塞调用，如果在队列中没有消息可用，调用将一直阻塞直到消息到达。
异步接收：
- 消费者可以注册一个MessageListener接口的实现。当消息到达时，JMS提供者会自动调用MessageListener的onMessage()方法，这是一种非阻塞的接收方式。
消息选择：
- 通过设置消息选择器（一个SQL92查询），消费者可以根据特定的消息属性过滤接收的消息。
事务性接收：
- 在事务性会话中，消息的接收可以是事务的一部分。如果事务回滚，那么接收的消息也会回滚，确保数据的一致性。

发布/订阅（Pub/Sub）模型的消息接收方式：

持久订阅：
- 订阅者可以创建一个持久订阅，即使订阅者当前不处于活动状态，消息服务器也会为订阅者保留消息。
非持久订阅：
- 订阅者创建的是非持久订阅，如果订阅者当前不处于活动状态，那么它将错过发布的消息。
同步/异步接收：
- 类似于P2P模型，订阅者可以使用receive()方法进行同步接收，或者注册MessageListener进行异步接收。
消息选择：
- 订阅者也可以使用消息选择器来过滤接收到的消息。
分布式订阅：
- 在分布式系统中，订阅者可能分布在不同的节点上，每个节点上的订阅者都可以接收到发布的消息。
事务性订阅：
- 与P2P模型类似，发布/订阅模型也可以在事务性会话中进行消息接收。

其他考虑因素：

消息确认：
- 消费者在处理完消息后，需要确认消息，以防止消息重复处理。在自动确认模式下，消息服务器会自动确认。在手动确认模式下，消费者需要显式地确认消息。
消息优先级：
- JMS允许消息具有不同的优先级，高优先级的消息会优先被消费者接收。
消息持久性：
- 可以根据消息的重要性设置消息的持久性，持久化消息在系统故障时更不容易丢失。

JMS的灵活性允许开发者根据具体的场景和需求选择最合适的消息接收方式。

5、 JMS 消息结构

JMS（Java Message Service）定义了一种标准的消息结构，以确保不同JMS提供者（如ActiveMQ, RabbitMQ, Kafka等）之间的互操作性。一个JMS消息由以下几个主要部分组成：

消息头（Message Header）：
- 消息头是消息的元数据，包含了用于识别消息和为消息寻找路由的操作设置。
- 消息头的属性是固定的，由JMS规范定义，包括：
  - JMSDestination：消息的目标目的地（队列或主题）。
  - JMSDeliveryMode：消息的持久性，可以是持久（PERSISTENT）或非持久（NON_PERSISTENT）。
  - JMSExpiration：消息的过期时间，超过这个时间消息将不再被传递。
  - JMSPriority：消息的优先级，取值范围是0-9，数字越大优先级越高。
  - JMSMessageID：消息的唯一标识，通常由JMS提供者自动生成。
消息属性（Message Properties）：
- 消息属性是一组可选的属性，用于提供额外的信息或用于消息过滤。
- 可以包含客户端自定义的属性和内容，支持通过消息选择器进行过滤。
消息体（Message Body）：
- 消息体是消息中实际承载数据的部分，JMS定义了几种不同的消息体类型，用于不同的数据传输需求：
  - TextMessage：用于存储字符串信息。
  - MapMessage：一个键值对的集合，键和值都是String类型。
  - BytesMessage：用于二进制数据的传输。
  - StreamMessage：用于存储原始字节流，类似于Java的序列化机制。
  - ObjectMessage：用于存储一个Java对象，该对象需要实现Serializable接口。