集成Stata分布式事务

一.事务协调器TC

1．安装Seata-server
下载：https://github.com/seata/seata/tags
启动：seata-server.bat -p 8091 -h 127.0.0.1 -m file
关闭其他服务，先启动它
2．配置文件修改

二.主业务端TM

1．导入依赖

<!--seata-->
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-alibaba-seata</artifactId><version>2.1.0.RELEASE</version><exclusions><exclusion><artifactId>seata-all</artifactId><groupId>io.seata</groupId></exclusion></exclusions>
</dependency>
<dependency><groupId>io.seata</groupId><artifactId>seata-all</artifactId><version>1.1.0</version>
</dependency>

2．Yml配置seata

spring:cloud:alibaba:seata:tx-service-group: fsp_tx_group #这里和file.conf中事务组名一样

3．拷贝配置

resources/file.conf

transport {# tcp udt unix-domain-sockettype = "TCP"#NIO NATIVEserver = "NIO"#enable heartbeatheartbeat = true# the client batch send request enableenableClientBatchSendRequest = true#thread factory for nettythreadFactory {bossThreadPrefix = "NettyBoss"workerThreadPrefix = "NettyServerNIOWorker"serverExecutorThread-prefix = "NettyServerBizHandler"shareBossWorker = falseclientSelectorThreadPrefix = "NettyClientSelector"clientSelectorThreadSize = 1clientWorkerThreadPrefix = "NettyClientWorkerThread"# netty boss thread size,will not be used for UDTbossThreadSize = 1#auto default pin or 8workerThreadSize = "default"}shutdown {# when destroy server, wait secondswait = 3}serialization = "seata"compressor = "none"
}
service {#transaction service group mappingvgroupMapping.fsp_tx_group = "default"#only support when registry.type=file, please don't set multiple addressesdefault.grouplist = "127.0.0.1:8091"#degrade, current not supportenableDegrade = false#disable seatadisableGlobalTransaction = false
}client {rm {asyncCommitBufferLimit = 10000lock {retryInterval = 10retryTimes = 30retryPolicyBranchRollbackOnConflict = true}reportRetryCount = 5tableMetaCheckEnable = falsereportSuccessEnable = false}tm {commitRetryCount = 5rollbackRetryCount = 5}undo {dataValidation = truelogSerialization = "jackson"logTable = "undo_log"}log {exceptionRate = 100}
}

resources/registry.conf

registry {# file 、nacos 、eureka、redis、zk、consul、etcd3、sofatype = "file"nacos {serverAddr = "localhost"namespace = ""cluster = "default"}eureka {serviceUrl = "http://localhost:8761/eureka"application = "default"weight = "1"}redis {serverAddr = "localhost:6379"db = "0"password = ""cluster = "default"timeout = "0"}zk {cluster = "default"serverAddr = "127.0.0.1:2181"session.timeout = 6000connect.timeout = 2000username = ""password = ""}consul {cluster = "default"serverAddr = "127.0.0.1:8500"}etcd3 {cluster = "default"serverAddr = "http://localhost:2379"}sofa {serverAddr = "127.0.0.1:9603"application = "default"region = "DEFAULT_ZONE"datacenter = "DefaultDataCenter"cluster = "default"group = "SEATA_GROUP"addressWaitTime = "3000"}file {name = "file.conf"}
}
config {# file、nacos 、apollo、zk、consul、etcd3、springCloudConfigtype = "file"nacos {serverAddr = "localhost"namespace = ""group = "SEATA_GROUP"}consul {serverAddr = "127.0.0.1:8500"}apollo {app.id = "seata-server"apollo.meta = "http://192.168.1.204:8801"namespace = "application"}zk {serverAddr = "127.0.0.1:2181"session.timeout = 6000connect.timeout = 2000username = ""password = ""}etcd3 {serverAddr = "http://localhost:2379"}file {name = "file.conf"}
}

4．DataSource代理配置
Mybatis版本

import com.alibaba.druid.pool.DruidDataSource;
import io.seata.rm.datasource.DataSourceProxy;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.transaction.SpringManagedTransactionFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;import javax.sql.DataSource;//使用seata对DataSource进行代理
@Configuration
public class DataSourceProxyConfig {//mapper.xml路径@Value("${mybatis.mapper-locations}")private String mapperLocations;//手动配置bean@Bean@ConfigurationProperties(prefix = "spring.datasource")public DataSource druidDataSource(){return new DruidDataSource();}@Beanpublic SqlSessionFactory sessionFactory(DataSourceProxy dataSourceProxy) throws Exception {SqlSessionFactoryBean sessionFactoryBean = new SqlSessionFactoryBean();sessionFactoryBean.setDataSource(dataSourceProxy);sessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(mapperLocations));//事务管理工厂sessionFactoryBean.setTransactionFactory(new SpringManagedTransactionFactory());return sessionFactoryBean.getObject();}@Beanpublic DataSourceProxy dataSource() {return new DataSourceProxy(druidDataSource());}
}

MybatisPlus版本

mybatis-plus:
type-aliases-package: cn.ronghuanet.gift.domain,cn.ronghuanet.gift.query
mapper-locations: cn/ronghuanet/gift/mapper/*Mapper.xml

/*** 数据源代理*/
@Configuration
public class DataSourceConfiguration {//mapper.xml路径@Value("${mybatis-plus.mapper-locations}")private String mapperLocations;@Value("${mybatis-plus.type-aliases-package}")private String typeAliasesPackage;//手动配置bean@Bean@ConfigurationProperties("spring.datasource")@Primarypublic DataSource druidDataSource(){return new DruidDataSource();}@Beanpublic MybatisSqlSessionFactoryBean sqlSessionFactoryBean(DataSourceProxy dataSourceProxy) throws Exception {//处理MybatisPlusMybatisSqlSessionFactoryBean factory = new MybatisSqlSessionFactoryBean();factory.setDataSource(dataSourceProxy);factory.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(mapperLocations));factory.setTypeAliasesPackage(typeAliasesPackage);//事务管理工厂factory.setTransactionFactory(new SpringManagedTransactionFactory());return factory;}@Beanpublic DataSourceProxy dataSource() {return new DataSourceProxy(druidDataSource());}
}

5．开启全局事务

业务方法贴@GlobalTransactional(rollbackFor = Exception.class)

@GlobalTransactional(rollbackFor = Exception.class)
@Override
public void register(RegisterDto dto) {
//...省略...vipBaseMapper.insert(vipBase);//...省略...
AjaxResult save = authFeignClient.save(login);if(!save.isSuccess())throw new RuntimeException("异常了");if(true)throw new RuntimeException("异常了");
}

6．undolog日志

-- 注意此处0.3.0+ 增加唯一索引 ux_undo_log
CREATE TABLE `undo_log` (`id` bigint(20) NOT NULL AUTO_INCREMENT,`branch_id` bigint(20) NOT NULL,`xid` varchar(100) NOT NULL,`context` varchar(128) NOT NULL,`rollback_info` longblob NOT NULL,`log_status` int(11) NOT NULL,`log_created` datetime NOT NULL,`log_modified` datetime NOT NULL,`ext` varchar(100) DEFAULT NULL,PRIMARY KEY (`id`),UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;