分布式事务学习笔记(一)分布式事务问题、CAP定理、BASE理论、Seata

news2024/11/19 15:33:36

文章目录

1 分布式事务问题
- 1.1 本地事务
- 1.2 分布式事务
- 1.3 创建分布式事务演示案例
2 理论基础
- 2.1 CAP定理
- 2.2 BASE理论
- 2.3 解决分布式事务的思路
- 2.4 Seata

1 分布式事务问题

1.1 本地事务

本地事务，也就是传统的单机事务，它必须要满足以下四个原则：

1.2 分布式事务

分布式事务，就是指不是在单个服务或单个数据库架构下产生的事务。例如：

跨数据源的分布式事务
跨服务的分布式事务
跨数据源且跨服务的综合分布式事务

在数据库水平拆分、服务垂直拆分之后，一个业务操作通常要跨多个数据库、服务才能完成。

例如电商行业中比较常见的下单付款案例，就包括创建新订单、扣减商品库存、从用户账户余额扣除金额等几个行为，而这些行为需要访问三个不同的微服务和三个不同的数据库：

创建新订单、扣减商品库存、从用户账户余额扣除金额在每一个服务和数据库内都是一个本地事务，可以保证ACID原则。

把这三个行为看做一个"业务"，保证“业务”的原子性，要么所有操作全部成功，要么全部失败，不允许出现部分成功部分失败的现象，这就是分布式系统下的事务。

此时ACID难以满足，这是分布式事务要解决的问题。

1.3 创建分布式事务演示案例

1）创建数据库，名为jingd，然后分别创建用户表t_account、订单表t_order、库存表t_storage

-- 创建数据库
create database jingd;
use jingd;
-- 创建用户表
CREATE TABLE `t_account`  (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `user_id` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  `money` int(11) UNSIGNED NULL DEFAULT 0,
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 2 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = COMPACT;
-- 用户ID为 user202103032042012 的用户余额为 1000 
INSERT INTO `t_account` VALUES (1, 'user202103032042012', 1000);
-- 创建订单表
CREATE TABLE `t_order`  (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `user_id` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  `commodity_code` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  `count` int(11) NULL DEFAULT 0,
  `money` int(11) NULL DEFAULT 0,
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = COMPACT;
-- 创建库存表
CREATE TABLE `t_storage`  (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `commodity_code` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  `count` int(11) UNSIGNED NULL DEFAULT 0,
  PRIMARY KEY (`id`) USING BTREE,
  UNIQUE INDEX `commodity_code`(`commodity_code`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 2 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = COMPACT;
-- 商品编号为 100202003032041 的商品库存有 10 件
INSERT INTO `t_storage` VALUES (1, '100202003032041', 10);

2）创建微服务的结构如下

jingd-demo：父工程，负责管理项目依赖。
jd-account-service：账户服务，负责管理用户的资金，提供扣减余额的接口。
jd-storage-service：库存服务，负责管理商品库存，提供扣减库存的接口。
jd-order-service：订单服务，负责管理订单，提供创建订单的接口。

需要特别注意的是，jd-order-service订单服务创建订单时，需要通过Feign调用account-service和storage-service服务的接口：