# Fescar Example ## 项目说明 本项目演示如何使用 Fescar Starter 完成 Spring Cloud 应用的分布式事务接入。 [Fescar](https://github.com/alibaba/fescar) 是 阿里巴巴 开源的 分布式事务中间件,以 高效 并且对业务 0 侵入 的方式,解决 微服务 场景下面临的分布式事务问题。 ## 准备工作 在运行此示例之前,你需要先完成如下几步准备工作: 1. 配置数据库 1. 创建 UNDO_LOG 表 1. 创建 示例中 业务所需要的数据库表 1. 启动 Fescar Server ### 配置数据库 首先,你需要有一个支持 InnoDB 引擎的 MySQL 数据库。 **注意**: 实际上,Fescar 支持不同的应用使用完全不相干的数据库,但是这里为了简单地演示一个原理,所以我们选择了只使用一个数据库。 将 `account-server`、`order-service`、`storage-service` 这三个应用中的 resources 目录下的 `application.properties` 文件中的如下配置修改成你运行环境中的实际配置。 ``` mysql.server.ip=your mysql server ip address mysql.server.port=your mysql server listening port mysql.db.name=your database name for test mysql.user.name=your mysql server username mysql.user.password=your mysql server password ``` ### 创建 UNDO_LOG 表 [Fescar AT 模式]() 需要使用到 UNDO_LOG 表。 ``` $sql CREATE TABLE `undo_log` ( `id` bigint(20) NOT NULL AUTO_INCREMENT, `branch_id` bigint(20) NOT NULL, `xid` varchar(100) 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`), KEY `idx_unionkey` (`xid`,`branch_id`) ) ENGINE=InnoDB AUTO_INCREMENT=159 DEFAULT CHARSET=utf8 ``` ### 创建 示例中 业务所需要的数据库表 ```$sql DROP TABLE IF EXISTS `storage_tbl`; CREATE TABLE `storage_tbl` ( `id` int(11) NOT NULL AUTO_INCREMENT, `commodity_code` varchar(255) DEFAULT NULL, `count` int(11) DEFAULT 0, PRIMARY KEY (`id`), UNIQUE KEY (`commodity_code`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8; DROP TABLE IF EXISTS `order_tbl`; CREATE TABLE `order_tbl` ( `id` int(11) NOT NULL AUTO_INCREMENT, `user_id` varchar(255) DEFAULT NULL, `commodity_code` varchar(255) DEFAULT NULL, `count` int(11) DEFAULT 0, `money` int(11) DEFAULT 0, PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8; DROP TABLE IF EXISTS `account_tbl`; CREATE TABLE `account_tbl` ( `id` int(11) NOT NULL AUTO_INCREMENT, `user_id` varchar(255) DEFAULT NULL, `money` int(11) DEFAULT 0, PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8; ``` ### 启动 Fescar Server 点击这个页面 [https://github.com/alibaba/fescar/releases](https://github.com/alibaba/fescar/releases),下载最新版本的 Fescar Server 端. 进入解压之后的 bin 目录,执行如下命令来启动 ```$shell sh fescar-server.sh $LISTEN_PORT $PATH_FOR_PERSISTENT_DATA ``` 在这个示例中,采用如下命令来启动 Fescar Server ```$shell sh fescar-server.sh 8091 ~/fescar/data/ ``` **注意** 如果你修改了端口号,那么记得需要在各个示例工程中的 `application.conf` 文件中,修改 grouplist 的值。 ## 运行示例 分别运行 `account-server`、`order-service`、`storage-service` 和 `business-service` 这三个应用的 Main 函数,启动示例。 启动示例后,通过 HTTP 的 GET 方法访问如下两个 URL,可以分别验证在 `business-service` 中 通过 RestTemplate 和 FeignClient 调用其他服务的场景。 ```$xslt http://127.0.0.1:18081/fescar/feign http://127.0.0.1:18081/fescar/rest ``` ## 如何验证分布式事务成功? ### Xid 信息是否成功传递 在 `account-server`、`order-service` 和 `storage-service` 三个 服务的 Controller 中,第一个执行的逻辑都是输出 RootContext 中的 Xid 信息,如果看到都输出了正确的 Xid 信息,即每次都发生变化,且同一次调用中所有服务的 Xid 都一致。则表明 Fescar 的 Xid 的传递和还原是正常的。 ### 数据库中数据是否一致 在本示例中,我们模拟了一个用户购买货物的场景,StorageService 负责扣减库存数量,OrderService 负责保存订单,AccountService 负责扣减用户账户余额。 为了演示样例,我们在 OrderService 和 AccountService 中 使用 Random.nextBoolean() 的方式来随机抛出异常,模拟了在服务调用时随机发生异常的场景。 如果分布式事务生效的话, 那么以下等式应该成立 - 用户原始金额(1000) = 用户现存的金额 + 货物单价 (2) * 订单数量 * 每单的货物数量(2) - 货物的初始数量(100) = 货物的现存数量 + 订单数量 * 每单的货物数量(2) ## 对 Spring Cloud 支持点 - 通过 Spring MVC 提供服务的服务提供者,在收到 header 中含有 Fescar 信息的 HTTP 请求时,可以自动还原 Fescar 上下文。 - 支持服务调用者通过 RestTemplate 调用时,自动传递 Fescar 上下文。 - 支持服务调用者通过 FeignClient 调用时,自动传递 Fescar 上下文。 - 支持 FeignClient 和 Hystrix 同时使用的场景。 - 支持 FeignClient 和 Sentinel 同时使用的场景。