seata(3)：api实例源码

golangLeetcode

发布于 2023-09-20 16:57:55

1440

发布于 2023-09-20 16:57:55

文章被收录于专栏：golang算法架构leetcode技术phpgolang算法架构leetcode技术php

TM的代码位于src/main/java/io/seata/samples/api/Bussiness.java，TM开始执行前，先初始化各个RM

        AccountService accountService = new AccountServiceImpl();
        StockService stockService = new StockServiceImpl();
        OrderService orderService = new OrderServiceImpl();
        orderService.setAccountService(accountService);

并且把数据设置成原始值

        accountService.reset(userId, String.valueOf(money));
        stockService.reset(commodityCode, String.valueOf(commodityCount));
        orderService.reset(null, null);

注册TC 和RM的client

        TMClient.init(applicationId, txServiceGroup);
        RMClient.init(applicationId, txServiceGroup);

然后就生成全局事务id，开启事务

        GlobalTransaction tx = GlobalTransactionContext.getCurrentOrCreate();
        try {
            tx.begin(6000, "testBiz");

紧接着就执行我们的事务，包括扣库存，生成订单，扣余额

            stockService.deduct(commodityCode, opCount);
            orderService.create(userId, commodityCode, opCount);

            //check data if negative
            boolean needCommit = ((StockServiceImpl)stockService).validNegativeCheck("count", commodityCode)
                && ((AccountServiceImpl)accountService).validNegativeCheck("money", userId);

最后检查结果，根据执行结果决定提交还是回滚

if (needCommit) {
    tx.commit();
} else {
    System.out.println("rollback trx, cause: data negative, xid is " + tx.getXid());
    tx.rollback();
}

具体到每一个RM的实现的时候，只需要实现对应的crud即可

src/main/java/io/seata/samples/api/service/impl/StockServiceImpl.java


    @Override
    public void deduct(String commodityCode, int count) throws SQLException {
        String sql = "update stock_tbl set count = count - " + count + " where commodity_code = '" + commodityCode
            + "'";
        DataSourceUtil.executeUpdate(DB_KEY, sql);
    }

src/main/java/io/seata/samples/api/service/impl/AccountServiceImpl.java

    @Override
    public void reduce(String userId, int money) throws SQLException {
        String sql = "update account_tbl set money = money - " + money + " where user_id = '" + userId + "'";
        DataSourceUtil.executeUpdate(DB_KEY, sql);
    }

src/main/java/io/seata/samples/api/service/impl/OrderServiceImpl.java

    @Override
    public void create(String userId, String commodityCode, Integer count) throws SQLException {
        int money = count * 200;
        String sql = "insert into order_tbl (user_id, commodity_code, count, money) values ('" + userId + "','"
            + commodityCode + "'," + count + "," + money + ")";
        DataSourceUtil.executeUpdate(DB_KEY, sql);
        accountService.reduce(userId, money);

    }

整体来说，让分布式事务和本地事务使用起来一样方便，把事务管理的模式交给了TC，降低了系统复杂性的同时也抽象出了共性，让分布式事务处理中复杂的逻辑不再暴露给业务开发人员。

另一方面，TC作为一个中间件，对开发来说完全是黑盒，提升了运维成本，提高了稳定性风险。

本文参与腾讯云自媒体同步曝光计划，分享自微信公众号。

原始发表：2023-09-20 00:00，如有侵权请联系 cloudcommunity@tencent.com 删除

api