Spring中使用atomikos+druid实现经典分布式事务的方法-eolink官网

Spring中使用atomikos+druid实现经典分布式事务的方法

经典分布式事务，是相对互联网中的柔性分布式事务而言，其特性为ACID原则，包括原子性（Atomictiy）、一致性（Consistency）、隔离性（Isolation）、持久性（Durabilit）：

原子性：事务是一个包含一系列操作的原子操作。事务的原子性确保这些操作全部完成或者全部失败。

一致性：一旦事务的所有操作结束，事务就被提交。然后你的数据和资源将处于遵循业务规则的一直状态。

隔离性：因为同时在相同数据集上可能有许多事务处理，每个事务应该与其他事务隔离，避免数据破坏。

持久性：一旦事务完成，他的结果应该能够承受任何系统错误（想象一下在事务提交过程中机器的电源被切断的情况）。通常，事务的结果被写入持续性存储。

XA是啥？

XA是由X/Open组织提出的分布式事务的架构（或者叫协议）。XA架构主要定义了（全局）事务管理器（Transaction Manager）和（局部）资源管理器（Resource Manager）之间的接口。XA接口是双向的系统接口，在事务管理器（Transaction Manager）以及一个或多个资源管理器（Resource Manager）之间形成通信桥梁。也就是说，在基于XA的一个事务中，我们可以针对多个资源进行事务管理，例如一个系统访问多个数据库，或即访问数据库、又访问像消息中间件这样的资源。这样我们就能够实现在多个数据库和消息中间件直接实现全部提交、或全部取消的事务。XA规范不是java的规范，而是一种通用的规范，

目前各种数据库、以及很多消息中间件都支持XA规范。

JTA是满足XA规范的、用于Java开发的规范。所以，当我们说，使用JTA实现分布式事务的时候，其实就是说，使用JTA规范，实现系统内多个数据库、消息中间件等资源的事务。

JTA(Java Transaction API)，是J2EE的编程接口规范，它是XA协议的JAVA实现。它主要定义了：

一个事务管理器的接口javax.transaction.TransactionManager，定义了有关事务的开始、提交、撤回等>操作。

一个满足XA规范的资源定义接口javax.transaction.xa.XAResource，一种资源如果要支持JTA事务，就需要让它的资源实现该XAResource接口，并实现该接口定义的两阶段提交相关的接口。如果我们有一个应用，它使用JTA接口实现事务，应用在运行的时候，就需要一个实现JTA的容器，一般情况下，这是一个J2EE容器，像JBoss，Websphere等应用服务器。但是，也有一些独立的框架实现了JTA，例如 Atomikos, bitronix 都提供了jar包方式的JTA实现框架。这样我们就能够在Tomcat或者Jetty之类的服务器上运行使用JTA实现事务的应用系统。在上面的本地事务和外部事务的区别中说到，JTA事务是外部事务，可以用来实现对多个资源的事务性。它正是通过每个资源实现的XAResource来进行两阶段提交的控制。感兴趣的同学可以看看这个接口的方法，除了commit, rollback等方法以外，还有end(), forget(), isSameRM(), prepare()等等。光从这些接口就能够想象JTA在实现两阶段事务的复杂性。

本篇以Spring MVC+Maven+Atomikos+Druid+MyBatis演示分布式事务的实现。

Mave 的pom.xml

1.8

8.0.11

1.1.17

5.1.8.RELEASE

3.2.12

5.0.0

1.9.4

1.5.4

1.1

3.2.0

1.2.0

1.2.17

4.12

3.2.4

org.mybatis

mybatis

${mybatise.version}

org.mybatis

mybatis-spring

${mybatis.spring}

com.atomikos

atomikos-util

${atomikos.version}

com.atomikos

transactions

${atomikos.version}

com.atomikos

transactions-jta

${atomikos.version}

com.atomikos

transactions-jdbc

${atomikos.version}

com.atomikos

transactions-api

${atomikos.version}

javax.transaction

jta

${jta.verhttp://sion}

cglib

cglib-nodep

${cglib.version}

org.springframework

spring-test

${spring.version}

org.springframework

spring-web

${spring.version}

org.springframework

spring-tx

${spring.version}

org.springframework

spring-beans

${spring.version}

org.springframework

spring-jdbc

${spring.version}

org.springframework

spring-webmvc

${spring.version}

org.springframework

spring-orm

${spring.version}

org.springframework

spring-context-support

${spring.version}

org.aspectj

aspectjweaver

${aspectjweaver.version}

aspectj

aspectjrt

${aspectjrt.version}

cglib

${cglib.version}

mysql

mysql-connector-java

${mysql.version}

com.alibaba

druid

${druid.version}

junit

${junit.version}

test

spring-application-context.xml

xmlns:xsi="http://w3.org/2001/XMLSchema-instance"

xmlns:p="http://springframework.org/schema/p"

xmlns:tx="http://springframework.org/schema/tx"

xmlns:context="http://springframework.org/schema/context"

xmlns:aop="http://springframework.org/schema/aop"

xmlns:mvc="http://springframework.org/schema/mvc"

xmlns:task="http://springframework.org/schema/task"

xsi:schemaLocation="http://springframework.org/schema/beans

http://springframework.org/schema/beans/spring-beans-3.1.xsd

http://springframework.org/schema/mvc

http://springframework.org/schema/mvc/spring-mvc-3.1.xsd

http://springframework.org/schema/context

http://springframework.org/schema/context/spring-context-3.1.xsd

http://springframework.org/schema/task http://springframework.org/schema/task/spring-task.xsd

http://springframework.org/schema/tx http://springframework.org/schema/tx/spring-tx-3.1.xsd

http://springframework.org/schema/aop http://springframework.org/schema/aop/spring-aop-3.1.xsd">

xmlns:xsi="http://w3.org/2001/XMLSchema-instance"

xmlns:p="http://springframework.org/schema/p"

xmlns:tx="http://springframework.org/schema/tx"

xmlns:context="http://springframework.org/schema/context"

xmlns:aop="http://springframework.org/schema/aop"

xmlns:mvc="http://springframework.org/schema/mvc"

xmlns:task="http://springframework.org/schema/task"

xsi:schemaLocation="http://springframework.org/schema/beans

http://springframework.org/schema/beans/spring-beans-3.1.xsd

http://springframework.org/schema/mvc

http://springframework.org/schema/mvc/spring-mvc-3.1.xsd

http://springframework.org/schema/context

http://springframework.org/schema/context/spring-context-3.1.xsd

http://springframework.org/schema/task http://springframework.org/schema/task/spring-task.xsd

http://springframework.org/schema/tx http://springframework.org/schema/tx/spring-tx-3.1.xsd

http://springframework.org/schema/aop http://springframework.org/schema/aop/spring-aop-3.1.xsd">

spring-mybatis-atomikos-druid.xml

xmlns:xsi="http://w3.org/2001/XMLSchema-instance"

xmlns:jee="http://springframework.org/schema/jee"

xmlns:tx="http://springframework.org/schema/tx"

xmlns:context="http://springframework.org/schema/context"

xmlns:aop="http://springframework.org/schema/aop"

xsi:schemaLocation="http://springframework.org/schema/beans

http://springframework.org/schema/beans/spring-beans-3.0.xsd

http://springframework.org/schema/tx

http://springframework.org/schema/tx/spring-tx-3.0.xsd

http://springframework.org/schema/jee

http://springframework.org/schema/jee/spring-jee-3.0.xsd

http://springframework.org/schema/aop

http://springframework.org/schema/aop/spring-aop-3.0.xsd

http://springframework.org/schema/context

http://springframework.org/schema/context/spring-context-3.0.xsd"

default-lazy-init="true">

${jdbc.driverClassName}

100

60000

300000

SELECT 'x'

true

false

stat

dataSourceOne

${jdbc.url}

${jdbc.username}

${jdbc.password}

dataSourceTwo

${jdbc.two.url}

${jdbc.two.username}

${jdbc.two.password}

xmlns:xsi="http://w3.org/2001/XMLSchema-instance"

xmlns:jee="http://springframework.org/schema/jee"

xmlns:tx="http://springframework.org/schema/tx"

xmlns:context="http://springframework.org/schema/context"

xmlns:aop="http://springframework.org/schema/aop"

xsi:schemaLocation="http://springframework.org/schema/beans

http://springframework.org/schema/beans/spring-beans-3.0.xsd

http://springframework.org/schema/tx

http://springframework.org/schema/tx/spring-tx-3.0.xsd

http://springframework.org/schema/jee

http://springframework.org/schema/jee/spring-jee-3.0.xsd

http://springframework.org/schema/aop

http://springframework.org/schema/aop/spring-aop-3.0.xsd

http://springframework.org/schema/context

http://springframework.org/schema/context/spring-context-3.0.xsd"

default-lazy-init="true">

${jdbc.driverClassName}

100

60000

300000

SELECT 'x'

true

false

stat

dataSourceOne

${jdbc.url}

${jdbc.username}

${jdbc.password}

dataSourceTwo

${jdbc.two.url}

${jdbc.two.username}

${jdbc.two.password}

jdbc.properties

#mysql 6.*以上

jdbc.driverClassName = com.mysql.cj.jdbc.Driver

jdbc.url = jdbc:mysql://127.0.0.1:3306/test?serverTimezone=UTC&useUnicode=true&characterEncoding=UTF-8&pinGlobalTxToPhysicalConnection=true&useSSL=false

jdbc.username =root

jdbc.password =root

jdbc.two.url = jdbc:mysql://127.0.0.1:3306/test?serverTimezone=UTC&useUnicode=true&characterEncoding=UTF-8&pinGlobalTxToPhysicalConnection=true&useSSL=false

jdbc.two.username =root

jdbc.two.password =root

jta.properties

com.atomikos.icatch.service=com.atomikos.icatch.standalone.UserTransactionServiceFactory

com.atomikos.icatch.console_file_name=tm.release.out

com.atomikos.icatch.log_base_name=tm.releaselog

com.atomikos.icatch.tm_unique_name=com.atomikos.spring.jdbc.tm.release

com.atomikos.icatch.console_log_level=INFO

TestInsert.java

@ContextConfiguration(value = {"classpath:spring-application-context.xml"})

@RunWith(SpringJUnit4ClassRunner.class)

public class TestInsert {

private Logger logger = LoggerFactory.getLogger(TestInsert.class);

@Autowired

private BatchInsertService batchInsertService;

@Test

public void insert(){

long startTime = System.currentTimeMillis();

User user = new User();

user.setName("User_"+(int)(Math.random()*100));

user.setAge((int)(Math.random()*100));

CustInfo info = new CustInfo();

info.setPhone("123456789"+(int)(Math.random()*100));

batchInsertService.insert(user,info);

long endTime = System.currentTimeMillis();

logger.info("共耗时：{}毫秒",endTime -startTime);

}

BatchInsertService.java

@Service

public class BatchInsertService {

private Logger logger = LoggerFactory.getLogger(BatchInsertService.class);

@Autowired

private UserService userService;

@Autowired

private CustInfoService custInfoService;

@Transactional(rollbackFor= {Exception.class,RuntimeException.class})

public void insert(User user,CustInfo custInfo) {

int insertUser = userService.insert(user);

logger.info("insertUser={}",insertUser);

int insertCustInfo = custInfoService.insert(custInfo);

logger.info("insertCustInfo={}",insertCustInfo);

}

UserService.java

@Service

public class UserService {

@Autowired

private UserMapper userMapper;

public int insert(User record) {

int result = userMapper.insert(record);

return result;

}

CustInfoService.java

@Service

public class CustInfoService {

@Autowired

private CustInfoMapper custInfoMapper;

public int insert(CustInfo record) {

int result = custInfoMapper.insert(record);

long now = System.currentTimeMillis();

// 模拟一个异常

if (now % 2 == 0) {

throw new RuntimeException("CustInfoMapper throws test insert exception");

}

return result;

}

Mapper和Bean等就不列出来了，完成的示例工程在github： https://github.com/fenglibin/DruidWithAtomikos

Flask接口签名sign原理与实例代码浅析

396 2023-01-04

Spring中使用atomikos+druid实现经典分布式事务的方法

多平台统一管理软件接口，如何实现多平台统一管理软件接口

Flask接口签名sign原理与实例代码浅析

java中的接口是类吗

推荐文章

接口调用是什么意思？几种常用接口调用方式

接口设计原则

8款在线 API 接口文档管理工具

api管理系统是什么？

什么是接口调试？接口调试的步骤有哪些？

api 接口管理系统有哪些？

接口测试有几种测试方法

API文档生成工具有哪些？

微服务和api网关区别

交换机配置步骤

最近发表

热评文章

在线接口文档管理工具推荐，支持在线测试，HTTP接口

开源的在线接口文档wiki工具Mindoc的介绍与使

如何优雅的进行接口设计？接口设计的六大原则是什么？

什么是API测试,api检测公司

软件接口设计怎么做？前后端分离软件接口设计思路

接口管理平台推荐，几大接口管理平台总有一款适合你！