分布式事务与 JTA

Spring Boot 通过使用从 JNDI 获取的事务管理器，支持跨多个 XA 资源的分布式 JTA 事务。

当检测到 JTA 环境时，Spring 的 JtaTransactionManager 被用于管理事务。自动配置的 JMS、DataSource 和 JPA Bean 会升级以支持 XA 事务。你可以使用标准的 Spring 用法，例如 @Transactional，来参与分布式事务。如果你处于 JTA 环境中但仍然希望使用本地事务，可以将 spring.jta.enabled 属性设置为 false 来禁用 JTA 自动配置。

使用 Jakarta EE 管理的事务管理器

如果你将你的 Spring Boot 应用打包成 war 或 ear 文件并部署到 Jakarta EE 应用服务器，你可以使用应用服务器内置的事务管理器。Spring Boot 会尝试通过查找常见的 JNDI 位置（java:comp/UserTransaction、java:comp/TransactionManager 等）来自动配置事务管理器。当使用应用服务器提供的事务服务时，你通常也需要确保所有资源都由服务器管理并通过 JNDI 暴露。Spring Boot 会通过在 JNDI 路径（java:/JmsXA 或 java:/XAConnectionFactory）查找 ConnectionFactory 来尝试自动配置 JMS，并且你可以使用 spring.datasource.jndi-name 属性来配置你的 DataSource。

混合使用 XA 和非 XA JMS 连接

当使用 JTA 时，主要的 JMS ConnectionFactory Bean 是 XA 感知的，并参与分布式事务。你无需使用任何 @Qualifier 即可将其注入到你的 Bean 中

Java
Kotlin

import jakarta.jms.ConnectionFactory;

public class MyBean {

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

}

import jakarta.jms.ConnectionFactory

class MyBean(connectionFactory: ConnectionFactory?)

在某些情况下，你可能希望使用非 XA ConnectionFactory 来处理特定的 JMS 消息。例如，你的 JMS 处理逻辑可能需要的时间比 XA 超时时间更长。

如果你想使用非 XA ConnectionFactory，你可以使用 nonXaJmsConnectionFactory Bean

Java
Kotlin

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?)

为了保持一致性，jmsConnectionFactory Bean 也通过 Bean 别名 xaJmsConnectionFactory 提供

Java
Kotlin

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，这些 Bean 会透明地参与分布式事务。如果你的 JtaTransactionManager Bean 和适当的 XA 包装器 Bean 注册在你的 ApplicationContext 中，DataSource 和 JMS 自动配置会使用 JTA 变体。