Shulou(Shulou.com)06/01 Report--

Today, I would like to share with you how to use JTA components in SpringBoot2 to achieve multi-source transaction management related knowledge points, detailed content, clear logic, I believe that most people still know too much about this knowledge, so share this article for your reference, I hope you can learn something after reading this article, let's take a look at it.

1. Introduction to JTA components 1. Basic concepts of JTA

JTA, or Java-Transaction-API,JTA, allows applications to perform distributed transactions, that is, accessing and updating data on two or more network computer resources. The JDBC driver's support for JTA greatly enhances data access.

XA protocol is a set of distributed transaction management specifications at the database level. JTA is the implementation of XA protocol in Java. Multiple databases or message vendors implement JTA interfaces. Developers only need to call SpringJTA interfaces to achieve JTA transaction management functions.

JTA transactions are more powerful than JDBC transactions. A JTA transaction can have multiple participants, while a JDBC transaction is limited to a single database connection. Any of the following Java platform components can participate in a JTA transaction

2. Distributed transaction

A distributed transaction (DistributedTransaction) includes a transaction manager (TransactionManager) and one or more resource managers (Resource Manager) that support the XA protocol.

Resource managers are any type of persistent data storage containers, such as relational databases commonly used in development: MySQL,Oracle, message middleware RocketMQ, RabbitMQ and so on.

The transaction manager provides functions such as transaction declaration, transaction resource management, synchronization, transaction context propagation and so on, and is responsible for the communication of all transaction participants. The JTA specification defines the interface between the transaction manager and other transaction participants, who interact with the transaction manager.

II. SpringBoot integrates JTA

Overall structure diagram of the project

1. The core depends on org.springframework.boot spring-boot-starter-web org.springframework.boot spring-boot-starter-jta-atomikos2 and environment configuration

Here the configuration of jtaManager is critical in the log output.

Spring: jta: transaction-manager-id: jtaManager # data source configuration datasource: type: com.alibaba.druid.pool.DruidDataSource data01: driverClassName: com.mysql.jdbc.Driver dbUrl: jdbc:mysql://localhost:3306/data-one username: root password: 000000 data02: driverClassName: com.mysql.jdbc.Driver dbUrl: jdbc:mysql://localhost:3306/data-two username: root password: 0000003, core container

Here the configuration method of the two database connections is the same, you can download and read it in the source code. The basic idea is to hand over the data source to the JTA component for unified management to facilitate the communication of transactions.

Data source parameters

@ Component@ConfigurationProperties (prefix = "spring.datasource.data01") public class DruidOneParam {private String dbUrl; private String username; private String password; private String driverClassName;}

JTA component configuration

Package com.jta.source.conifg;@Configuration@MapperScan (basePackages = {"com.jta.source.mapper.one"}, sqlSessionTemplateRef = "data01SqlSessionTemplate") public class DruidOneConfig {private static final Logger LOGGER = LoggerFactory.getLogger (DruidOneConfig.class); @ Resource private DruidOneParam druidOneParam; @ Primary @ Bean ("dataSourceOne") public DataSource dataSourceOne () {/ / set database connection MysqlXADataSource mysqlXADataSource = new MysqlXADataSource (); mysqlXADataSource.setUrl (druidOneParam.getDbUrl ()) MysqlXADataSource.setUser (druidOneParam.getUsername ()); mysqlXADataSource.setPassword (druidOneParam.getPassword ()); mysqlXADataSource.setPinGlobalTxToPhysicalConnection (true); / / transaction manager AtomikosDataSourceBean atomikosDataSourceBean = new AtomikosDataSourceBean (); atomikosDataSourceBean.setXaDataSource (mysqlXADataSource); atomikosDataSourceBean.setUniqueResourceName ("dataSourceOne"); return atomikosDataSourceBean } @ Primary @ Bean (name = "sqlSessionFactoryOne") public SqlSessionFactory sqlSessionFactoryOne (@ Qualifier ("dataSourceOne") DataSource dataSourceOne) throws Exception {/ / configure Session factory SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean (); sessionFactory.setDataSource (dataSourceOne); ResourcePatternResolver resolver = new PathMatchingResourcePatternResolver (); sessionFactory.setMapperLocations (resolver.getResources ("classpath*:/dataOneMapper/*.xml")); return sessionFactory.getObject () } @ Primary @ Bean (name = "data01SqlSessionTemplate") public SqlSessionTemplate sqlSessionTemplate (@ Qualifier ("sqlSessionFactoryOne") SqlSessionFactory sqlSessionFactory) {/ / configure Session template return new SqlSessionTemplate (sqlSessionFactory);}} 4. Test comparison

Here, the test results of the two methods are compared. When performing data operations between the two data sources, you only need to annotate the interface method with @ Transactional to ensure the consistency of the data between the two data sources.

@ Servicepublic class TransferServiceImpl implements TransferService {@ Resource private UserAccount01Mapper userAccount01Mapper; @ Resource private UserAccount02Mapper userAccount02Mapper; @ Override public void transfer01 () {userAccount01Mapper.transfer ("jack", 100); System.out.println ("I =" + 1max 0); userAccount02Mapper.transfer ("tom", 100);} @ Transactional @ Override public void transfer02 () {userAccount01Mapper.transfer ("jack", 200) System.out.println ("I =" + 1 tom 0); userAccount02Mapper.transfer ("tom", 200);}} that is all of the content of the article "how to use JTA components in SpringBoot2 to implement multi-source transaction management". Thank you for reading! I believe you will gain a lot after reading this article. The editor will update different knowledge for you every day. If you want to learn more knowledge, please pay attention to the industry information channel.

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.