使用 @Transactional
除了基于 XML 的声明式事务配置方法之外,你还可以使用基于注解的方法。直接在 Java 源代码中声明事务语义使得声明与受影响的代码更加接近。过度耦合的危险不大,因为旨在用于事务的代码几乎总是以这种方式部署的。
标准的 |
使用 @Transactional
注解所带来的易用性最好通过一个示例来说明,该示例将在下面的文本中解释。
考虑以下类定义:
-
Java
-
Kotlin
// the service class that we want to make transactional
@Transactional
public class DefaultFooService implements FooService {
@Override
public Foo getFoo(String fooName) {
// ...
}
@Override
public Foo getFoo(String fooName, String barName) {
// ...
}
@Override
public void insertFoo(Foo foo) {
// ...
}
@Override
public void updateFoo(Foo foo) {
// ...
}
}
// the service class that we want to make transactional
@Transactional
class DefaultFooService : FooService {
override fun getFoo(fooName: String): Foo {
// ...
}
override fun getFoo(fooName: String, barName: String): Foo {
// ...
}
override fun insertFoo(foo: Foo): Mono<Void> {
// ...
}
override fun updateFoo(foo: Foo): Mono<Void> {
// ...
}
}
如上所示,在类级别使用时,该注解表示声明类(及其子类)的所有方法的默认设置。或者,每个方法可以单独注解。有关 Spring 认为哪些方法是事务性的更多详细信息,请参阅 方法可见性。请注意,类级别注解不适用于类层次结构中的祖先类;在这种情况下,需要局部重新声明继承的方法才能参与子类级别注解。
当像上面这样的 POJO 类在 Spring 上下文中定义为 bean 时,你可以通过 @Configuration
类中的 @EnableTransactionManagement
注解使 bean 实例具有事务性。有关完整详细信息,请参阅 javadoc。
在 XML 配置中,<tx:annotation-driven/>
标签提供了类似的便利:
<!-- from the file 'context.xml' -->
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:tx="http://www.springframework.org/schema/tx"
xsi:schemaLocation="
http://www.springframework.org/schema/beans
https://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/tx
https://www.springframework.org/schema/tx/spring-tx.xsd
http://www.springframework.org/schema/aop
https://www.springframework.org/schema/aop/spring-aop.xsd">
<!-- this is the service object that we want to make transactional -->
<bean id="fooService" class="x.y.service.DefaultFooService"/>
<!-- enable the configuration of transactional behavior based on annotations -->
<!-- a TransactionManager is still required -->
<tx:annotation-driven transaction-manager="txManager"/> [id="CO1-1"]1
<bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<!-- (this dependency is defined somewhere else) -->
<property name="dataSource" ref="dataSource"/>
</bean>
<!-- other <bean/> definitions here -->
</beans>
<1> 使 bean 实例具有事务性的行。
如果希望连接的 |
与命令式编程安排相比,响应式事务方法使用响应式返回类型,如以下列表所示:
-
Java
-
Kotlin
// the reactive service class that we want to make transactional
@Transactional
public class DefaultFooService implements FooService {
@Override
public Publisher<Foo> getFoo(String fooName) {
// ...
}
@Override
public Mono<Foo> getFoo(String fooName, String barName) {
// ...
}
@Override
public Mono<Void> insertFoo(Foo foo) {
// ...
}
@Override
public Mono<Void> updateFoo(Foo foo) {
// ...
}
}
// the reactive service class that we want to make transactional
@Transactional
class DefaultFooService : FooService {
override fun getFoo(fooName: String): Flow<Foo> {
// ...
}
override fun getFoo(fooName: String, barName: String): Mono<Foo> {
// ...
}
override fun insertFoo(foo: Foo): Mono<Void> {
// ...
}
override fun updateFoo(foo: Foo): Mono<Void> {
// ...
}
}
请注意,对于返回的 Publisher
,关于 Reactive Streams 取消信号有一些特殊考虑。有关更多详细信息,请参阅“使用 TransactionalOperator”下的 取消信号 部分。
代理模式下方法可见性和
@Transactional
Spring TestContext Framework 也默认支持非私有的 |
你可以将 @Transactional
注解应用于接口定义、接口上的方法、类定义或类上的方法。然而,仅仅存在 @Transactional
注解不足以激活事务行为。@Transactional
注解仅仅是元数据,可以由相应的运行时基础设施消费,该基础设施使用该元数据配置具有事务行为的适当 bean。在前面的示例中,<tx:annotation-driven/>
元素在运行时开启实际的事务管理。
Spring 团队建议你使用 |
在代理模式(默认)下,只有通过代理进行的外部方法调用才会被拦截。这意味着自调用(实际上是目标对象内的一个方法调用目标对象的另一个方法)即使被调用的方法被标记为 |
如果你希望自调用也能被事务包装,请考虑使用 AspectJ 模式(请参阅下表中的 mode
属性)。在这种情况下,根本没有代理。相反,目标类被织入(即,其字节码被修改),以支持任何类型方法的 @Transactional
运行时行为。
XML 属性 | 注解属性 | 默认值 | 描述 |
---|---|---|---|
|
N/A (请参阅 |
|
要使用的事务管理器的名称。仅当事务管理器的名称不是 |
|
|
|
默认模式 ( |
|
|
|
仅适用于 |
|
|
|
定义应用于 |
处理 |
|
|
在评估方法的事务设置时,最派生的位置优先。在以下示例中,DefaultFooService
类在类级别使用只读事务设置进行注解,但同一类中 updateFoo(Foo)
方法上的 @Transactional
注解优先于类级别定义的事务设置。
-
Java
-
Kotlin
@Transactional(readOnly = true)
public class DefaultFooService implements FooService {
public Foo getFoo(String fooName) {
// ...
}
// these settings have precedence for this method
@Transactional(readOnly = false, propagation = Propagation.REQUIRES_NEW)
public void updateFoo(Foo foo) {
// ...
}
}
@Transactional(readOnly = true)
class DefaultFooService : FooService {
override fun getFoo(fooName: String): Foo {
// ...
}
// these settings have precedence for this method
@Transactional(readOnly = false, propagation = Propagation.REQUIRES_NEW)
override fun updateFoo(foo: Foo) {
// ...
}
}
@Transactional
设置
@Transactional
注解是元数据,它指定接口、类或方法必须具有事务语义(例如,“当调用此方法时,启动一个全新的只读事务,暂停任何现有事务”)。
默认的 @Transactional
设置如下:
-
传播设置是
PROPAGATION_REQUIRED.
-
隔离级别是
ISOLATION_DEFAULT.
-
事务是读写的。
-
事务超时默认为底层事务系统的默认超时,如果不支持超时则为无。
-
任何
RuntimeException
或Error
都会触发回滚,任何检查型Exception
则不会。
你可以更改这些默认设置。下表总结了 @Transactional
注解的各种属性:
属性 | 类型 | 描述 |
---|---|---|
|
可选限定符,指定要使用的事务管理器。 |
|
|
|
|
|
|
标签可以由事务管理器评估,以将特定于实现的行为与实际事务关联起来。 |
|
可选的传播设置。 |
|
|
|
可选的隔离级别。仅适用于 |
|
|
可选的事务超时。仅适用于 |
|
|
替代方式,以 |
|
|
读写与只读事务。仅适用于 |
|
|
必须引起回滚的异常类型的可选数组。 |
|
异常名称模式数组。 |
必须引起回滚的异常名称模式的可选数组。 |
|
|
必须不引起回滚的异常类型的可选数组。 |
|
异常名称模式数组。 |
必须不引起回滚的异常名称模式的可选数组。 |
有关回滚规则语义、模式以及关于基于模式的回滚规则可能意外匹配的警告,请参阅 回滚规则 以获取更多详细信息。 |
从 6.2 开始,你可以全局更改默认回滚行为——例如,通过 |
目前,你无法显式控制事务的名称,其中“名称”是指事务监视器和日志输出中出现的事务名称。对于声明式事务,事务名称始终是事务性建议类的完全限定类名 + .
+ 方法名。例如,如果 BusinessService
类的 handlePayment(..)
方法启动了一个事务,则事务的名称将是 com.example.BusinessService.handlePayment
。
带有 @Transactional
的多个事务管理器
大多数 Spring 应用程序只需要一个事务管理器,但在某些情况下,你可能希望在单个应用程序中拥有多个独立的事务管理器。你可以使用 @Transactional
注解的 value
或 transactionManager
属性来可选地指定要使用的 TransactionManager
的标识。这可以是事务管理器 bean 的 bean 名称或限定符值。例如,使用限定符表示法,你可以将以下 Java 代码与应用程序上下文中的以下事务管理器 bean 声明结合使用:
-
Java
-
Kotlin
public class TransactionalService {
@Transactional("order")
public void setSomething(String name) { ... }
@Transactional("account")
public void doSomething() { ... }
@Transactional("reactive-account")
public Mono<Void> doSomethingReactive() { ... }
}
class TransactionalService {
@Transactional("order")
fun setSomething(name: String) {
// ...
}
@Transactional("account")
fun doSomething() {
// ...
}
@Transactional("reactive-account")
fun doSomethingReactive(): Mono<Void> {
// ...
}
}
以下列表显示了 bean 声明:
<tx:annotation-driven/>
<bean id="transactionManager1" class="org.springframework.jdbc.support.JdbcTransactionManager">
...
<qualifier value="order"/>
</bean>
<bean id="transactionManager2" class="org.springframework.jdbc.support.JdbcTransactionManager">
...
<qualifier value="account"/>
</bean>
<bean id="transactionManager3" class="org.springframework.data.r2dbc.connection.R2dbcTransactionManager">
...
<qualifier value="reactive-account"/>
</bean>
在这种情况下,TransactionalService
上的各个方法在不同的事务管理器下运行,通过 order
、account
和 reactive-account
限定符进行区分。如果没有找到特定限定的 TransactionManager
bean,则仍使用默认的 <tx:annotation-driven>
目标 bean 名称 transactionManager
。
如果同一类上的所有事务方法共享相同的限定符,请考虑声明一个类型级别的 |
自定义复合注解
如果你发现你经常在许多不同的方法上重复使用 @Transactional
的相同属性,
Spring 的元注解支持
允许你为特定的用例定义自定义复合注解。例如,考虑以下注解定义:
-
Java
-
Kotlin
@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Transactional(transactionManager = "order", label = "causal-consistency")
public @interface OrderTx {
}
@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Transactional(transactionManager = "account", label = "retryable")
public @interface AccountTx {
}
@Target(AnnotationTarget.FUNCTION, AnnotationTarget.TYPE)
@Retention(AnnotationRetention.RUNTIME)
@Transactional(transactionManager = "order", label = ["causal-consistency"])
annotation class OrderTx
@Target(AnnotationTarget.FUNCTION, AnnotationTarget.TYPE)
@Retention(AnnotationRetention.RUNTIME)
@Transactional(transactionManager = "account", label = ["retryable"])
annotation class AccountTx
前面的注解允许我们将上一节的示例编写如下:
-
Java
-
Kotlin
public class TransactionalService {
@OrderTx
public void setSomething(String name) {
// ...
}
@AccountTx
public void doSomething() {
// ...
}
}
class TransactionalService {
@OrderTx
fun setSomething(name: String) {
// ...
}
@AccountTx
fun doSomething() {
// ...
}
}
在前面的示例中,我们使用了语法来定义事务管理器限定符和事务标签,但我们也可以包含传播行为、回滚规则、超时和其他功能。