使用 JTA 的分布式事务

Spring Boot 通过使用从 JNDI 检索的事务管理器来支持跨多个 XA 资源的分布式 JTA 事务。spring-doc.cn

当检测到 JTA 环境时， Spring 的JtaTransactionManager用于管理事务。自动配置的 JMS、DataSource 和 JPA bean 已升级以支持 XA 事务。您可以使用标准的 Spring 惯用语（例如 @Transactional）来参与分布式事务。如果您在 JTA 环境中，并且仍希望使用本地事务，则可以将该属性设置为以禁用 JTA 自动配置。spring.jta.enabledfalsespring-doc.cn

使用 Jakarta EE Managed Transaction Manager

如果将 Spring Boot 应用程序打包为 or 文件并将其部署到 Jakarta EE 应用程序服务器，则可以使用应用程序服务器的内置事务管理器。 Spring Boot 尝试通过查看常见的 JNDI 位置（、、等）来自动配置事务 Management 器。使用应用程序服务器提供的事务服务时，您通常还希望确保所有资源都由服务器管理并通过 JNDI 公开。 Spring Boot 尝试通过在 JNDI 路径（或）中查找 ConnectionFactory 来自动配置 JMS，你可以使用spring.datasource.jndi-name属性来配置DataSource。warearjava:comp/UserTransactionjava:comp/TransactionManagerjava:/JmsXAjava:/XAConnectionFactoryspring-doc.cn

混合 XA 和非 XA JMS 连接

使用 JTA 时，主 JMS ConnectionFactory Bean 是 XA 感知的，并参与分布式事务。你可以注入到 bean 中，而无需使用任何@Qualifier：spring-doc.cn

Javaspring-doc.cn
Kotlinspring-doc.cn

import jakarta.jms.ConnectionFactory;

public class MyBean {

	public MyBean(ConnectionFactory connectionFactory) {
		// ...
	}

}

import jakarta.jms.ConnectionFactory

class MyBean(connectionFactory: ConnectionFactory?)

在某些情况下，您可能希望使用非 XA ConnectionFactory 来处理某些 JMS 消息。例如，您的 JMS 处理逻辑可能比 XA 超时花费的时间更长。spring-doc.cn

如果要使用非 XA ConnectionFactory，则可以将 Bean：nonXaJmsConnectionFactoryspring-doc.cn

Javaspring-doc.cn
Kotlinspring-doc.cn

import jakarta.jms.ConnectionFactory;

import org.springframework.beans.factory.annotation.Qualifier;

public class MyBean {

	public MyBean(@Qualifier("nonXaJmsConnectionFactory") ConnectionFactory connectionFactory) {
		// ...
	}

}

import jakarta.jms.ConnectionFactory
import org.springframework.beans.factory.annotation.Qualifier

class MyBean(@Qualifier("nonXaJmsConnectionFactory") connectionFactory: ConnectionFactory?)

为了保持一致性，还通过使用 bean alias 来提供 bean：jmsConnectionFactoryxaJmsConnectionFactoryspring-doc.cn

Javaspring-doc.cn
Kotlinspring-doc.cn

import jakarta.jms.ConnectionFactory;

import org.springframework.beans.factory.annotation.Qualifier;

public class MyBean {

	public MyBean(@Qualifier("xaJmsConnectionFactory") ConnectionFactory connectionFactory) {
		// ...
	}

}

import jakarta.jms.ConnectionFactory
import org.springframework.beans.factory.annotation.Qualifier

class MyBean(@Qualifier("xaJmsConnectionFactory") connectionFactory: ConnectionFactory?)

支持嵌入式事务管理器

XAConnectionFactoryWrapper 和 XADataSourceWrapper 接口可用于支持嵌入式事务管理器。这些接口负责包装 XAConnectionFactory 和 XADataSource Bean，并将它们公开为常规 ConnectionFactory 和 DataSource Bean，它们透明地注册到分布式事务中。 DataSource和 JMS 自动配置使用 JTA 变体，前提是您在ApplicationContext中注册了JtaTransactionManager bean 和适当的 XA 包装器 bean。spring-doc.cn