使用 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 和 Non-XA JMS 连接
使用 JTA 时,主 JMS ConnectionFactory Bean 是 XA 感知的,并参与分布式事务。你可以直接注入到你的 Bean 中,而无需使用任何 @Qualifier:
- 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 暴露出来,从而透明地加入分布式事务。只要您注册了 JtaTransactionManager Bean 以及适当的 XA 包装器 Bean 到您的 ApplicationContext 中,DataSource 和 JMS 的自动配置就会使用 JTA 变体。