使用 Spring JMS (Using Spring JMS) _ Spring Framework6.1.13中文文档(官方文档中文翻译)|Spring 教程 —

本节介绍如何使用 Spring 的 JMS 组件。spring-doc.cn

用`JmsTemplate`

该类是 JMS 核心包中的中心类。它简化了使用 JMS，因为它在发送或同步接收消息。JmsTemplatespring-doc.cn

使用 the 的代码只需要实现提供它们的回调接口明确定义的高级合同。回调接口会创建一个消息。自允许对 JMS API 进行更复杂的使用，提供 JMS 会话，并公开 and 对。JmsTemplateMessageCreatorSessionJmsTemplateSessionCallbackProducerCallbackSessionMessageProducerspring-doc.cn

JMS API 公开了两种类型的 send 方法，一种采用 delivery mode、priority 和和 time to live 作为服务质量（QOS）参数，并且不采用 QOS 参数并使用默认值。由于 send 方法很多，设置 QOS 参数已作为 Bean 属性公开给避免 send 方法的数量重复。同样，的同步接收调用是使用 property 设置的。JmsTemplatesetReceiveTimeoutspring-doc.cn

某些 JMS 提供程序允许通过的配置 .这具有对实例的 method （）的调用使用的 QOS 默认值与 JMS 规范中指定的值不同。挨次因此，为了提供对 QOS 值的一致管理，必须通过将 boolean 属性设置为 .ConnectionFactoryMessageProducersendsend(Destination destination, Message message)JmsTemplateisExplicitQosEnabledtruespring-doc.cn

为方便起见，还公开了一个基本的请求-回复操作，该操作允许发送消息并等待临时队列的回复，该队列是作为的一部分创建的操作。JmsTemplatespring-doc.cn

类的实例一旦配置，就是线程安全的。这是重要，因为这意味着您可以配置单个 A 实例，然后将此共享引用安全地注入多个协作者。成为 clear，它是有状态的，因为它维护对 a 的引用，但此状态不是会话状态。JmsTemplateJmsTemplateJmsTemplateConnectionFactory

从 Spring Framework 4.1 开始，它构建在消息传递抽象之上并提供与消息传递抽象的集成，即 .这样，您就可以将消息创建到以通用方式发送。JmsMessagingTemplateJmsTemplateorg.springframework.messaging.Messagespring-doc.cn

连接

这需要对 .它是 JMS 规范的一部分，用作使用 JMS 的入口点。它被客户端应用程序用作工厂来创建与 JMS 的连接 provider 并封装各种配置参数，其中许多是特定于供应商的，例如 SSL 配置选项。JmsTemplateConnectionFactoryConnectionFactoryspring-doc.cn

在 EJB 中使用 JMS 时，供应商提供 JMS 接口的实现以便它们可以参与声明式事务管理并执行池化连接和会话。为了使用此实现，Jakarta EE 容器通常要求您将 JMS 连接工厂声明为 inside EJB 或 Servlet 部署描述符。为了确保在 EJB 内部使用这些功能，客户端应用程序应确保它引用的 managed 实现。resource-refJmsTemplateConnectionFactoryspring-doc.cn

缓存消息收发资源

标准 API 涉及创建许多中间对象。要发送消息，执行以下 'API' 遍历：spring-doc.cn

ConnectionFactory->Connection->Session->MessageProducer->send

在和操作之间，三个中间对象被创建和销毁。优化资源使用并提高性能，Spring 提供了 .ConnectionFactorySendConnectionFactoryspring-doc.cn

用`SingleConnectionFactory`

Spring 提供了接口的实现，该接口在所有调用中返回相同的值，并忽略对 .这对于测试和独立环境，以便同一连接可用于可能跨越任意数量的事务的多个调用。引用通常来自 JNDI 的标准。ConnectionFactorySingleConnectionFactoryConnectioncreateConnection()close()JmsTemplateSingleConnectionFactoryConnectionFactoryspring-doc.cn

用`CachingConnectionFactory`

扩展了、和实例的功能并添加了、和实例的缓存。初始缓存大小设置为。您可以使用该属性增加缓存会话的数量。请注意，实际缓存的会话数大于该数字，因为会话是根据其确认模式缓存的，因此，最多可以有四个缓存的 Session 实例（每个确认模式一个） when 设置为 1。和实例缓存在其拥有的会话中，并且还考虑了唯一属性的创建者和使用者。MessageProducers 根据其目的地。MessageConsumers 基于由目标、选择器、 noLocal delivery 标志和持久订阅名称（如果创建持久使用者）。CachingConnectionFactorySingleConnectionFactorySessionMessageProducerMessageConsumer1sessionCacheSizesessionCacheSizeMessageProducerMessageConsumerspring-doc.cn

临时队列和主题的 MessageProducers 和 MessageConsumers （TemporaryQueue/TemporaryTopic）永远不会被缓存。不幸的是，WebLogic JMS 发生了要在其常规目标实现上实现临时 queue/topic 接口，错误地表示无法缓存其任何目标。请使用其他连接 pool/cache 的 WebLogic 上，或为 WebLogic 目的进行自定义。CachingConnectionFactoryspring-doc.cn

目的地管理

作为实例，目标是可以存储的 JMS 管理对象并在 JNDI 中检索。在配置 Spring 应用程序上下文时，您可以使用 JNDI 工厂类或执行依赖项注入对象对 JMS 目标的引用。但是，此策略如果应用程序中有大量目标，或者存在是 JMS 提供程序独有的高级目标管理功能。示例此类高级目标管理包括创建动态目标或支持目标的分层命名空间。委托将目标名称解析为实现接口的 JMS 目标对象。是默认值 implementation used by and accommodate 解析动态目标。还提供了 A 作为 destinations 包含在 JNDI 中，并且可以选择回退到 .ConnectionFactoryJndiObjectFactoryBean<jee:jndi-lookup>JmsTemplateDestinationResolverDynamicDestinationResolverJmsTemplateJndiDestinationResolverDynamicDestinationResolverspring-doc.cn

通常，JMS 应用程序中使用的目的地仅在运行时才知道，并且因此，在部署应用程序时无法以管理方式创建。这是通常是因为交互的系统组件之间存在共享的应用程序逻辑，它们根据众所周知的命名约定在运行时创建目标。甚至尽管创建动态目标不是 JMS 规范的一部分，但大多数供应商已提供此功能。动态目标是使用用户定义的名称创建的。这使它们与临时目的地区分开来，并且通常是未在 JNDI 中注册。用于创建动态目标的 API 因提供商而异 to provider，因为与目标关联的属性是特定于供应商的。但是，供应商有时会做出一个简单的实现选择，即忽略 JMS 规范中的警告，并使用 method 或 method 创建具有 default destination 属性的新目标。取决于在 vendor 实现上，还可以创建一个 physical destination 而不是仅解析一个。TopicSessioncreateTopic(String topicName)QueueSessioncreateQueue(String queueName)DynamicDestinationResolverspring-doc.cn

boolean 属性用于配置了解正在使用的 JMS 域。默认情况下，此属性的值为 false，则表示使用点对点域。此属性（使用者）通过以下方式确定动态目标解析的行为接口的实现。pubSubDomainJmsTemplateQueuesJmsTemplateDestinationResolverspring-doc.cn

您还可以通过财产。默认目标是发送和接收不引用特定目标的操作。JmsTemplatedefaultDestinationspring-doc.cn

消息侦听器容器

在 EJB 世界中，JMS 消息最常见的用途之一是驱动消息驱动的 Beans （MDB）。Spring 提供了一种解决方案，以某种方式创建消息驱动的 POJO （MDP）不会将用户绑定到 EJB 容器。（有关详细信息，请参阅异步接收：消息驱动的 POJO Spring 的 MDP 支持覆盖率。从 Spring Framework 4.1 开始，端点方法可以 annotated with — 有关更多详细信息，请参阅 Annotation-driven Listener Endpoints。@JmsListenerspring-doc.cn

消息侦听器容器用于从 JMS 消息队列接收消息，并且驱动注入其中的 That。侦听器容器是负责将消息接收和 dispatch 的所有线程处理到侦听器中加工。消息侦听器容器是 MDP 和消息传递提供商，并负责注册以接收消息、参与事务、资源获取和释放、异常转换等。这允许您编写（可能很复杂的）业务逻辑与接收消息（并可能响应消息）相关联，并委托框架的样板 JMS 基础设施问题。MessageListenerspring-doc.cn

有两个与 Spring 打包在一起的标准 JMS 消息侦听器容器，每个容器都带有它的专业功能集。spring-doc.cn

用`SimpleMessageListenerContainer`

此消息侦听器容器是两种标准风格中较简单的一种。它创建启动时固定数量的 JMS 会话和使用者，使用标准 JMS 方法，并将其留给 JMS provider 执行侦听器回调。此变体不允许动态适应运行时需求或参与外部管理的事务。在兼容性方面，它非常接近独立 JMS 的精神规范，但通常与 Jakarta EE 的 JMS 限制不兼容。MessageConsumer.setMessageListener()spring-doc.cn

虽然不允许外部参与 managed transactions，它确实支持本机 JMS 事务。要启用此功能，您可以将标志切换到 XML，或者在 XML 命名空间中将属性设置为。从侦听器引发的异常然后引导进行回滚，并重新传递消息。或者，考虑使用 mode，它在出现异常时也提供重新传递，但不使用事务处理实例，因此，在事务协议中不包括任何其他操作（例如发送响应消息）。SimpleMessageListenerContainersessionTransactedtrueacknowledgetransactedCLIENT_ACKNOWLEDGESessionSession

默认模式不提供适当的可靠性保证。当侦听器执行失败时，消息可能会丢失（因为提供程序会自动在侦听器调用后确认每条消息，没有要传播到的异常提供程序）或侦听器容器关闭时（您可以通过设置标志）。请确保在以下情况下使用事务处理会话可靠性需求（例如，用于可靠的队列处理和持久主题订阅）。AUTO_ACKNOWLEDGEacceptMessagesWhileStopping

用`DefaultMessageListenerContainer`

此消息侦听器容器在大多数情况下使用。与相反，此容器变体允许动态适应满足运行时需求，并能够参与外部管理的事务。当配置了 .因此，处理可能会利用 XA 事务语义学。这个侦听器容器在 JMS 提供程序、高级功能（例如参与外部管理的 transactions 的 TRANSACTIONS 以及与 Jakarta EE 环境的兼容性。SimpleMessageListenerContainerJtaTransactionManagerspring-doc.cn

您可以自定义容器的缓存级别。请注意，当未启用缓存时，将为每个消息接收创建一个新连接和一个新会话。结合这个对于具有高负载的非持久订阅，可能会导致消息丢失。请确保在这种情况下，请使用适当的缓存级别。spring-doc.cn

当代理出现故障时，此容器还具有可恢复功能。默认情况下，简单实现每 5 秒重试一次。您可以指定用于更精细恢复选项的自定义实现。有关示例，请参阅 ExponentialBackOff。BackOffBackOffspring-doc.cn

与它的兄弟姐妹（SimpleMessageListenerContainer）一样，支持原生 JMS 事务并允许自定义 acknowledgment 模式。如果对您的方案可行，则 This is strongly 推荐而不是外部管理的交易 — 也就是说，如果您能忍受在 JVM 死亡的情况下偶尔出现重复消息。自定义重复消息业务逻辑中的检测步骤可以涵盖此类情况 — 例如，以业务实体存在检查或协议表检查的形式。任何此类安排都比替代方案更有效：使用 XA 事务包装整个处理（通过使用配置）以覆盖接收 JMS 消息以及在您的消息侦听器（包括数据库操作等）。DefaultMessageListenerContainerDefaultMessageListenerContainerJtaTransactionManager

事务管理

Spring 提供了一个 Management 单个 JMS 的事务。这允许 JMS 应用程序利用托管事务 Spring 的功能，如 Data Access 一章的 Transaction Management 部分所述。执行本地资源事务，绑定 JMS 从指定到线程的 Connection/Session 对。自动检测此类事务性资源并运行相应地对他们。JmsTransactionManagerConnectionFactoryJmsTransactionManagerConnectionFactoryJmsTemplatespring-doc.cn

在 Jakarta EE 环境中，池 Connection 和 Session 实例因此，这些资源可以在事务中有效地重用。在独立环境中，在共享的 JMS 中使用 Spring 的结果，其中每个事务都有自己独立的 .或者，考虑使用特定于提供程序的池适配器，例如 ActiveMQ 的类。ConnectionFactorySingleConnectionFactoryConnectionSessionPooledConnectionFactoryspring-doc.cn

您还可以与支持 XA 的 JMS 一起使用来执行分布式事务。请注意，这需要使用 JTA 事务管理器以及正确配置的 XA ConnectionFactory。（请查看 Jakarta EE 服务器或 JMS 提供商的文档。JmsTemplateJtaTransactionManagerConnectionFactoryspring-doc.cn

在托管和非托管事务环境中重用代码可能会令人困惑使用 JMS API 从 .这是因为 JMS API 只有一个工厂方法来创建一个，并且它需要 transaction 和 acknowledgment 模式。在托管环境中，设置这些值为环境的事务性基础设施的责任，因此这些值被供应商的 JMS Connection 包装器忽略。在非托管环境中使用时，可以通过使用 properties 和 .当您使用 with 时，模板始终会得到一个事务性 JMS 。SessionConnectionSessionJmsTemplatesessionTransactedsessionAcknowledgeModePlatformTransactionManagerJmsTemplateSessionspring-doc.cn

用JmsTemplate

连接

缓存消息收发资源

用SingleConnectionFactory

用CachingConnectionFactory