【上海校区】SpringBoot多数据源中的分布式事务 - 黑马程序员技术交流社区

接下来，我们简单的做一个基于 SpringBoot 的分布式事务控制。

[AppleScript] 纯文本查看 复制代码

@Configuration

@MapperScan(basePackages = "com.example.mapper.db1", sqlSessionFactoryRef = "db1SqlSessionFactory")

public class DB1DataSourcesConfig {

 

    @Primary

    @Bean(name = "db1DataSource")

    public DataSource dataSource(DB1Config DB1Config) {

 

        // 设置数据库连接

        MysqlXADataSource mysqlXADataSource = new MysqlXADataSource();

        mysqlXADataSource.setUrl(DB1Config.getUrl_jdbc());

        mysqlXADataSource.setUser(DB1Config.getUsername());

        mysqlXADataSource.setPassword(DB1Config.getPassword());

        mysqlXADataSource.setPinGlobalTxToPhysicalConnection(true);

 

        // 交给事务管理器进行管理

        AtomikosDataSourceBean atomikosDataSourceBean = new AtomikosDataSourceBean();

        atomikosDataSourceBean.setXaDataSource(mysqlXADataSource);

        atomikosDataSourceBean.setUniqueResourceName("db1DataSource");

        return atomikosDataSourceBean;

    }

 

    @Primary

    @Bean(name = "db1SqlSessionFactory")

    public SqlSessionFactory sqlSessionFactory(@Qualifier("db1DataSource") DataSource dataSource) throws Exception {

        SqlSessionFactoryBean sessionFactoryBean = new SqlSessionFactoryBean();

        sessionFactoryBean.setDataSource(dataSource);

        sessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath*:/mapper/db1/*.xml"));

 

        org.apache.ibatis.session.Configuration configuration = new org.apache.ibatis.session.Configuration();

        configuration.setMapUnderscoreToCamelCase(true);

 

        sessionFactoryBean.setConfiguration(configuration);

        return sessionFactoryBean.getObject();

    }

 

    @Primary

    @Bean(name = "db1SqlSessionTemplate")

    public SqlSessionTemplate sqlSessionTemplate(@Qualifier("db1SqlSessionFactory") SqlSessionFactory sqlSessionFactory) {

        return new SqlSessionTemplate(sqlSessionFactory);

    }

}

这样基本就配置完了，这里我只写了一个数据库的配置，另外一个同这个一样，就是数据库信息变了而已。

这里设计到两个数据的修改，学生姓名和学生分数成绩，这两个数据分别存储在不同的数据库。我们通过接口先修改用户信息，接着再修改用户的分数信息。

我们先没不加事务，先看下如果再修改分数的时候出现异常，用户信息会不会回滚回去。

首先代码在39行报错，如果按照我们的逻辑，如果修改分数失败，那么相应的用户的年龄修改也是不成功的，但是结果显示用户的年龄还是被修改了，显然这个接口并没有被分布式事务所管理。

我们先把数据改回原来，然后我们再把事务加上，看还不会出现这种问题。（方法上加@Transactional注解即可）

加了分布式事务之后，通过结果就可以看到，如果后面的结果出现了错误，前面的数据也是会进行回滚的，保证了事务的前后一致性，确保了数据的安全准确。

总结：以上就是 JTA + Atomikos 实现分布式事务的整个过程，相对实现功能来说还是比较简单的，以上的测试是基于单个的 SpringBoot 项目的，相对于真正的微服务来说，这样的方式我还没有进行测试，如果需要进行微服务之间的事务管理，也可以通过 mq 或者 dubbo 去进行事务的一致性管理。等以后研究了再来跟大家分享。