Java-198 RabbitMQ JMS 模式详解：Queue/Topic、6 类消息与对象模型（JMS 2.0 / Jakarta Messaging 3.1）

TL;DR

• 场景：Java 系统做异步解耦与事件驱动，需要统一理解 JMS 的消息模型、对象模型与消息类型。
• 结论：JMS 是标准 API（类似 JDBC），关键在 Queue/Topic 语义、Session 与确认/事务边界、消息类型取舍。
• 产出：一篇可直接落地的 JMS 基础稿：概念—对象模型—消息类型—实现/版本差异速查。

版本矩阵

JMS模式

基本介绍

JMS（Java Message Service）是Java平台提供的一套标准API，专门用于实现面向消息中间件（MOM，Message Oriented Middleware）的编程接口。作为Java EE规范的重要组成部分，JMS定义了一组通用接口和语义，允许Java应用程序通过消息队列或发布/订阅模式进行异步通信。

核心特点：

技术类比： JMS与JDBC（Java Database Connectivity）在架构设计理念上高度相似：

• 都采用"接口+实现"的设计模式
• 都定义标准API，由不同厂商提供具体实现
• 都通过配置切换底层服务提供商而不需修改应用代码

典型应用场景：

通过JMS，Java开发者可以构建高可靠、可扩展的分布式消息系统，有效解决传统同步通信带来的性能瓶颈和系统耦合问题。

JMS消息

消息是JMS中的一种类型对象，由两部分组成：报文头和消息主题。 报文头包括消息头字段和消息头属性，字段是JMS协议规定的字段，属性可以由用户按需添加。 JMS 报文头全部字段：

消息主题携带应用程序的数据或有效负载，根据有效负载的不同格式和用途，JMS（Java Message Service）规范定义了以下几种标准消息类型，每种类型都有其特定的应用场景和优势：

每种消息类型都支持设置消息属性（Properties），这些属性可以包含消息的元数据，如：

• 消息优先级
• 过期时间
• 持久性设置
• 自定义业务属性

在实际应用中，选择哪种消息类型取决于：

体系架构

JMS由以下元素组成：

• JMS 供应商产品：JMS接口的一个实现，该产品可以是Java的JMS实现，也可以是非Java的面向消息中间件的适配器。
• JMS Client：生产或者消费基于消息的Java的应用程序或者对象
• JMS Producer：创建并发送消息的JMS客户
• JMS Consumer：接收消息的 JMS 客户
• JMS Message：包括可以在 JMS 客户之间传递的数据的对象
• JMS Queue：缓存消息的容器，消息的接受顺序并不一定非要与消息的发送顺序相同，消息被消费后将从消息队列中移除
• JMS Topic：Pub、Sub模式

对象模型

Connection Factory

Connection Factory（连接工厂）是JMS(Java Message Service)中一个重要的被管对象，它主要负责创建和管理与JMS提供者之间的连接。作为JMS架构中的关键组件，连接工厂提供了以下核心功能：

// 1. 通过JNDI查找连接工厂
Context ctx = new InitialContext();
ConnectionFactory cf = (ConnectionFactory)ctx.lookup("ConnectionFactory");

// 2. 创建连接
Connection connection = cf.createConnection();

// 3. 创建会话
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

// 4. 使用消息
// …

通过连接工厂的这种设计，JMS实现了客户端代码与具体消息服务的解耦，提高了系统的灵活性和可维护性。

Connection

连接，连接代表了应用程序和消息服务器之间的通信链路，在获得了连接工厂之后，就可以创建一个与JMS提供者的连接，根据不同的连接类型，连接允许用户创建会话，以发送和接收队列主题为目标。

Destination

目标是一个包装了消息目标标识符号的被管对象，消息目标是指消息发布和接收的地点，或者是队列，或者是主题，JMS管理员创建这些对象，然后用户通过JNDI发现他们，和连接工厂一样，管理员可以创建两种管理类型的目标，点对点模型的队列，以及发布者、订阅者模型的主题。

Session

表示一个单线程的上下文，用于发送和接收消息，由于会话是单线程的，所以消息是连续的，就是说消息是按照顺序一个一个接收的。 会话好处是它支持事务，如果用选择了事务支持，会话上下文会将保存一组消息，直到事务被提交了才发送这些消息。 在提交事务之前，用户可以使用回滚操作取消这些消息，一个会话允许用户创建消息，生产者发送消息，消费者来接收消息。

MessageConsumer

MessageConsumer 是 JMS (Java Message Service) 中的核心接口之一，代表消息消费者。它由 Session 会话对象创建，专门用于接收发送到 Destination（目标）的消息。消息消费者可以接收两种类型的消息目标：

MessageConsumer 提供两种消息接收模式：

同步接收（阻塞模式）：

• 通过 receive() 方法实现
• 线程会一直阻塞直到收到消息或超时
• 示例代码：

Message message = consumer.receive(); // 无限等待
Message message = consumer.receive(5000); // 等待5秒

异步接收（非阻塞模式）：

• 通过设置 MessageListener 实现
• 采用事件驱动机制，当消息到达时会自动触发 onMessage 方法
• 示例代码：

consumer.setMessageListener(new MessageListener() {
@Override
public void onMessage(Message message) {
// 处理接收到的消息
}
});

重要特性：

• 支持消息选择器（MessageSelector）来过滤消息
• 可以配置消息确认模式（AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE等）
• 支持持久化订阅（Durable Subscription）用于主题模式

MessageProducer

MessageProducer 是 JMS 中用于发送消息的核心接口，由 Session 会话对象创建。它负责将消息发送到指定的 Destination（目标）。MessageProducer 有两种创建方式：

MessageProducer producer = session.createProducer(destination);

MessageProducer producer = session.createProducer(null);
// 发送时指定目标
producer.send(specificDestination, message);

主要功能特性：

消息发送控制：

• 可设置消息的存活时间（TimeToLive）
• 可配置消息优先级（Priority）
• 支持持久化/非持久化消息传递模式

发送方法：

// 简单发送
producer.send(message);

// 带参数发送
producer.send(message, deliveryMode, priority, timeToLive);

典型应用场景：

注意事项：

• 发送完成后应调用 close() 方法释放资源
• 可通过 setDeliveryDelay() 设置消息延迟投递
• 支持事务性发送（当使用事务会话时）

Message

消息是分布式系统中用于在生产者（Producer）和消费者（Consumer）之间传输数据的核心载体。它本质上是一个结构化的数据对象，用于在不同应用程序或服务间实现异步通信和解耦。消息队列（Message Queue）或消息中间件（如RabbitMQ、Kafka）通常作为消息的传输媒介，确保消息的可靠传递和顺序性。

一个完整的消息通常由以下三部分组成：

应用场景

• 异步处理：订单系统将支付成功消息发送到队列，库存服务异步消费并扣减库存。
• 事件驱动架构：用户注册事件触发邮件服务和数据分析服务的并行处理。
• 跨系统集成：银行系统通过消息属性标记交易类型（如txn_type=transfer），便于风控系统过滤处理。

错误速查

其他系列

🚀 AI篇持续更新中（长期更新）

AI炼丹日志-29 – 字节跳动 DeerFlow 深度研究框斜体样式架 私有部署 测试上手 架构研究，持续打造实用AI工具指南！ AI研究-132 Java 生态前沿 2025：Spring、Quarkus、GraalVM、CRaC 与云原生落地 🔗 AI模块直达链接

💻 Java篇持续更新中（长期更新）

Java-196 消息队列选型：RabbitMQ vs RocketMQ vs Kafka MyBatis 已完结，Spring 已完结，Nginx已完结，Tomcat已完结，分布式服务已完结，Dubbo已完结，MySQL已完结，MongoDB已完结，Neo4j已完结，FastDFS 已完结，OSS已完结，GuavaCache已完结，EVCache已完结，RabbitMQ正在更新… 深入浅出助你打牢基础！ 🔗 Java模块直达链接

📊 大数据板块已完成多项干货更新（300篇）：

包括 Hadoop、Hive、Kafka、Flink、ClickHouse、Elasticsearch 等二十余项核心组件，覆盖离线+实时数仓全栈！ 大数据-278 Spark MLib – 基础介绍 机器学习算法 梯度提升树 GBDT案例 详解 🔗 大数据模块直达链接