在Java中配置双数据源回滚可以通过使用@Transactional
注解来实现。@Transactional
注解可以应用在方法上,表示该方法是一个事务方法,当方法执行过程中发生异常时,会自动回滚事务。
首先,需要确保你的项目中已经引入了Spring事务管理的依赖,比如spring-boot-starter-data-jpa
和spring-boot-starter-jdbc
。
接下来,需要在配置文件(比如application.properties或application.yml)中配置两个数据源,并分别指定其对应的事务管理器。例如:
spring:
datasource:
primary:
url: jdbc:mysql://localhost:3306/db1
username: root
password: password
secondary:
url: jdbc:mysql://localhost:3306/db2
username: root
password: password
jpa:
database-platform: org.hibernate.dialect.MySQL5Dialect
hibernate.ddl-auto: update
jta:
enabled: true
接下来,需要创建两个数据源的配置类,用于配置数据源和事务管理器。例如:
@Configuration
@EnableTransactionManagement
public class PrimaryDataSourceConfig {
@Primary
@Bean(name = "primaryDataSource")
@ConfigurationProperties(prefix = "spring.datasource.primary")
public DataSource primaryDataSource() {
return DataSourceBuilder.create().build();
}
@Primary
@Bean(name = "primaryTransactionManager")
public PlatformTransactionManager primaryTransactionManager(
@Qualifier("primaryDataSource") DataSource dataSource) {
return new DataSourceTransactionManager(dataSource);
}
}
@Configuration
@EnableTransactionManagement
public class SecondaryDataSourceConfig {
@Bean(name = "secondaryDataSource")
@ConfigurationProperties(prefix = "spring.datasource.secondary")
public DataSource secondaryDataSource() {
return DataSourceBuilder.create().build();
}
@Bean(name = "secondaryTransactionManager")
public PlatformTransactionManager secondaryTransactionManager(
@Qualifier("secondaryDataSource") DataSource dataSource) {
return new DataSourceTransactionManager(dataSource);
}
}
最后,在你的Service层方法上添加@Transactional
注解,并指定对应的事务管理器。例如:
@Service
public class ExampleService {
@Autowired
@Qualifier("primaryTransactionManager")
private PlatformTransactionManager primaryTransactionManager;
@Autowired
@Qualifier("secondaryTransactionManager")
private PlatformTransactionManager secondaryTransactionManager;
@Transactional(rollbackFor = Exception.class, transactionManager = "primaryTransactionManager")
public void saveToPrimaryDataSource(Data data) {
// 保存数据到主数据源
}
@Transactional(rollbackFor = Exception.class, transactionManager = "secondaryTransactionManager")
public void saveToSecondaryDataSource(Data data) {
// 保存数据到从数据源
}
}
以上配置中,@Transactional
注解通过transactionManager
属性指定了对应的事务管理器,从而实现了双数据源的回滚。