阿里开源分布式事务seata demo示例（原Fescar）

àì夳堔傛蜴生んèń 2022-04-23 00:54 452阅读 0赞

### 文章目录 ###

*  简介
 *  运行官方demo
 *  事务回滚原理简介

> 备注：阿里分布式事务中间件`seata`原名`fescar`。`seata`是后来改的名称。本文写的比较老，不做修改。  
> https://github.com/alibaba/fescar 是老的仓库地址  
> https://github.com/seata/seata是新的sea他的仓库地址

# 简介 #

阿里巴巴近日开源了分布式事务中间件 `seata`。GitHub地址是 https://github.com/seata/seata。  
官方中文文档：http://seata.io/zh-cn/

阿里巴巴现在内部使用的版本是GTS，fescar是其开源社区版本，fescar是`Fast & EaSy Commit And Rollback, FESCAR`的简称。更多简介请参考 http://seata.io/zh-cn/。

# 运行官方demo #

将https://github.com/alibaba/fescar克隆到本地IDEA，demo运行使用到的是examples和server。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70]  
我这里使用的是0.1.1版本：  
![在这里插入图片描述][20190122174437151.png]  
运行程序首先需要配置数据库并且初始化SQL。  
1、修改以下三个配置文件的MySQL地址  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70 1]  
test module中的MySQL配置也改一下：  
![在这里插入图片描述][20190122175336210.png]  
另外由于我本地的MySQL是8.X版本，所以驱动要升级。  
![在这里插入图片描述][20190122175129238.png]  
我使用的JDK11，`com.alibaba.fescar.tm.dubbo.impl.OrderServiceImpl`有个BUG，运行时会报错，需要修改一下：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70 2]  
最后执行以下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;
    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=1 DEFAULT CHARSET=utf8;

好了，准备工作做完。  
实例简述：  
该实例模拟一个下单功能，由businessService发起，首先扣减库存，然后创建订单。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70 3]  
启动server项目的`com.alibaba.fescar.server.Server`的main方法；  
启动example项目的`AccountServiceImpl、OrderServiceImpl、StorageServiceImpl`三个类的main方法，也就是dubbo服务提供者；  
以上4个服务启动完成后，查看DB中的记录，会初始化account\_tbl和storage\_tbl两张表，插入一条记录（左侧的表）  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70 4]  
执行`com.alibaba.fescar.tm.dubbo.impl.BusinessServiceImpl`main方法。会发现执行报错，DB表数据没有变更。  
是因为在`com.alibaba.fescar.tm.dubbo.impl.BusinessServiceImpl#purchase`方法中存在模拟的异常，我们将其注释掉，再次执行：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70 5]  
注释掉以后执行，可以发现没有报错，DB中的数据已经正确修改（参见上图的右侧三张表的数据）。

至此demo运行成功。

# 事务回滚原理简介 #

根据 [阿里巴巴开源分布式事务解决方案 Fescar][Fescar] 介绍的原理，简单看看其rollback的原理。后续专门分析一下fescar的源码。

> [阿里巴巴开源分布式事务解决方案 Fescar][Fescar] 讲到它是优化了两阶段提交，减少锁的时间，利用本地事务真正提交事务，并且记录可用于回滚的日志，然后出错时根据日志回滚。

`TransactionalTemplate`是核心入口类;

/* * Copyright 1999-2018 Alibaba Group Holding Ltd. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */
    
    package com.alibaba.fescar.tm.api;
    
    import com.alibaba.fescar.core.exception.TransactionException;
    
    /** * Template of executing business logic with a global transaction. */
    public class TransactionalTemplate { 
    
        /** * Execute object. * * @param business the business * @return the object * @throws TransactionalExecutor.ExecutionException the execution exception */
        public Object execute(TransactionalExecutor business) throws TransactionalExecutor.ExecutionException { 
    
            // 1. get or create a transaction
            //获取全局事务管理器
            GlobalTransaction tx = GlobalTransactionContext.getCurrentOrCreate();
    
            // 2. begin transaction 事务begin
            try { 
                tx.begin(business.timeout(), business.name());
    
            } catch (TransactionException txe) { 
                throw new TransactionalExecutor.ExecutionException(tx, txe,
                    TransactionalExecutor.Code.BeginFailure);
    
            }
    
            Object rs = null;
            try { 
    
                // Do Your Business 执行我们具体的业务逻辑
                rs = business.execute();
    
            } catch (Throwable ex) { 
    
                // 3. any business exception, rollback. 出错时回滚
                try { 
                    tx.rollback();
    
                    // 3.1 Successfully rolled back
                    throw new TransactionalExecutor.ExecutionException(tx, TransactionalExecutor.Code.RollbackDone, ex);
    
                } catch (TransactionException txe) { 
                    // 3.2 Failed to rollback
                    throw new TransactionalExecutor.ExecutionException(tx, txe,
                        TransactionalExecutor.Code.RollbackFailure, ex);
    
                }
    
            }
    
            // 4. everything is fine, commit. 事务提交
            try { 
                tx.commit();
    
            } catch (TransactionException txe) { 
                // 4.1 Failed to commit
                throw new TransactionalExecutor.ExecutionException(tx, txe,
                    TransactionalExecutor.Code.CommitFailure);
    
            }
            return rs;
        }
    
    }

事务提交有两种：

public enum GlobalTransactionRole { 
    
        /** * The Launcher. * 开启全局事务的发起者 */
        // The one begins the current global transaction.
        Launcher,
    
        /** * The Participant. * 分支事务，也就是分布在各个系统中的本地事务 */
        // The one just joins into a existing global transaction.
        Participant
    }

通过代码可以看到，分支事务什么都不做，也就是直接提交本地事务。Launcher事务会进行全局事务的提交。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70 6]  
记录回滚日志的关键代码`com.alibaba.fescar.rm.datasource.undo.UndoLogManager#flushUndoLogs`中的`undoLogContent`：

public static void flushUndoLogs(ConnectionProxy cp) throws SQLException { 
            assertDbSupport(cp.getDbType());
    
            ConnectionContext connectionContext = cp.getContext();
            String xid = connectionContext.getXid();
            long branchID = connectionContext.getBranchId();
    
            BranchUndoLog branchUndoLog = new BranchUndoLog();
            branchUndoLog.setXid(xid);
            branchUndoLog.setBranchId(branchID);
            branchUndoLog.setSqlUndoLogs(connectionContext.getUndoItems());
    
            String undoLogContent = UndoLogParserFactory.getInstance().encode(branchUndoLog);
    
            if (LOGGER.isDebugEnabled()) { 
                LOGGER.debug("Flushing UNDO LOG: " + undoLogContent);
            }
    
            PreparedStatement pst = null;
            try { 
                pst = cp.getTargetConnection().prepareStatement(INSERT_UNDO_LOG_SQL);
                pst.setLong(1, branchID);
                pst.setString(2, xid);
                pst.setBlob(3, BlobUtils.string2blob(undoLogContent));
                pst.executeUpdate();
            } catch (Exception e) { 
                if (e instanceof SQLException) { 
                    throw (SQLException) e;
                } else { 
                    throw new SQLException(e);
                }
            } finally { 
                if (pst != null) { 
                    pst.close();
                }
            }
    
        }

这里根据上面的实例，查看其中一条日志：

{
    	"branchId": 1890459,
    	"sqlUndoLogs": [{
    		"afterImage": {
    			"rows": [{
    				"fields": [{
    					"keyType": "PrimaryKey",
    					"name": "ID",
    					"type": 4,
    					"value": 8
    				}, {
    					"keyType": "NULL",
    					"name": "MONEY",
    					"type": 4,
    					"value": 199
    				}]
    			}],
    			"tableName": "account_tbl"
    		},
    		"beforeImage": {
    			"rows": [{
    				"fields": [{
    					"keyType": "PrimaryKey",
    					"name": "ID",
    					"type": 4,
    					"value": 8
    				}, {
    					"keyType": "NULL",
    					"name": "MONEY",
    					"type": 4,
    					"value": 599
    				}]
    			}],
    			"tableName": "account_tbl"
    		},
    		"sqlType": "UPDATE",
    		"tableName": "account_tbl"
    	}],
    	"xid": "10.240.130.105:8091:1890457"
    }

可以看到，日志中记录了修改之前和之后的数据变化情况，也就是数据镜像，回滚时就是根据这个进行回滚的。

由于现在fescar才刚刚开源，远没有达到商用，需要到1.0版本才可以线上使用。本文只是简单了解入门一下，后续在升级几个版本之后再详细的分析其源码。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70]: /images/20220323/1cc6a00fb85d469ebfc8a598c8203351.png
[20190122174437151.png]: /images/20220323/670018b8bfcf4834b28d0b988d91831d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70 1]: /images/20220323/c65ef576e9fb4a7d92b1acb08960e5fc.png
[20190122175336210.png]: /images/20220323/0e9370dfadab4e2fb22ea44f6cefcf4a.png
[20190122175129238.png]: /images/20220323/630c2afb795446b3b9279f783725dc3e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70 2]: /images/20220323/ebf09e0ea62f40ee92966e867603dc1a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70 3]: /images/20220323/ea752652e7954935b30de30c58aff29f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70 4]: /images/20220323/8cc11ad456e2441fac5626587637d445.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70 5]: /images/20220323/ed7471d936b94cb8a164635772cb48a8.png
[Fescar]: https://blog.csdn.net/liubenlong007/article/details/86601281
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZneWlidXBp_size_16_color_FFFFFF_t_70 6]: /images/20220323/b5f10c7a65814f008e75edb656886da7.png