2. 程式人生 > 實用技巧 >SpringCloud系列之整合分散式事務Seata應用篇

SpringCloud系列之整合分散式事務Seata應用篇

阿新 • • 發佈：2020-07-06

目錄

前言

單體應用被拆分成各個獨立的業務模組後，就不得不要去面對分散式事務，好在阿里已經開源分散式事務元件Seata，雖還在迭代中，難免會有bug產生，但隨著社群發展及反饋，相信終究會越來越穩定，話不多說讓我們開始吧。

專案版本

spring-boot.version：2.2.5.RELEASE

spring-cloud.version：Hoxton.SR3

seata.version：1.2.0

專案說明

專案模組說明如下：



前端請求介面經由閘道器服務進行路由轉發後進入cloud-web模組，經cloud-web模組呼叫相應業務微服務模組，執行業務邏輯後響應前端請求。

Seata服務端部署

1.下載Seata服務端部署檔案

https://github.com/seata/seata/releases/download/v1.2.0/seata-server-1.2.0.zip

如嫌下載慢，可關注本文下方微信公眾號二維碼，關注後回覆“666”即可獲取開發常用工具包

2.解壓至本地目錄後，執行seata-server.bat指令碼，過程中無報錯則說明部署正常，Linux環境下操作類似不做展開說明

Seata客戶端整合
cloud-web

部分pom.xml，後續模組引入seata依賴一樣，後續模組不再單獨說明

<dependency>

    <groupId>com.alibaba.cloud</groupId>

    <artifactId>spring-cloud-alibaba-seata</artifactId>

    <version>2.2.0.RELEASE</version>

    <exclusions>

        <exclusion>

            <groupId>io.seata</groupId>
 

            <artifactId>seata-spring-boot-starter</artifactId>

        </exclusion>

    </exclusions>

</dependency>

<dependency>

    <groupId>io.seata</groupId>

    <artifactId>seata-spring-boot-starter</artifactId>

    <version>1.2.0</version>

</dependency>

application.properties ，後續模組引入seata配置項大致一樣，根據業務模組調整3個配置項即可，後續模組不再單獨說明

# seata配置

seata.enabled=true

#seata.excludes-for-auto-proxying=firstClassNameForExclude,secondClassNameForExclude

seata.application-id=cloud-web

seata.tx-service-group=cloud-web_tx_group

seata.enable-auto-data-source-proxy=true

seata.use-jdk-proxy=false

seata.client.rm.async-commit-buffer-limit=1000

seata.client.rm.report-retry-count=5

seata.client.rm.table-meta-check-enable=false

seata.client.rm.report-success-enable=false

seata.client.rm.saga-branch-register-enable=false

seata.client.rm.lock.retry-interval=10

seata.client.rm.lock.retry-times=30

seata.client.rm.lock.retry-policy-branch-rollback-on-conflict=true

seata.client.tm.commit-retry-count=5

seata.client.tm.rollback-retry-count=5

seata.client.tm.degrade-check=false

seata.client.tm.degrade-check-allow-times=10

seata.client.tm.degrade-check-period=2000

seata.client.undo.data-validation=true

seata.client.undo.log-serialization=jackson

seata.client.undo.only-care-update-columns=true

seata.client.undo.log-table=undo_log

seata.client.log.exceptionRate=100

seata.service.vgroup-mapping.cloud-web_tx_group=default

seata.service.grouplist.default=${cloud-web.seata.service.grouplist.default}

seata.service.enable-degrade=false

seata.service.disable-global-transaction=false

seata.transport.shutdown.wait=3

seata.transport.thread-factory.boss-thread-prefix=NettyBoss

seata.transport.thread-factory.worker-thread-prefix=NettyServerNIOWorker

seata.transport.thread-factory.server-executor-thread-prefix=NettyServerBizHandler

seata.transport.thread-factory.share-boss-worker=false

seata.transport.thread-factory.client-selector-thread-prefix=NettyClientSelector

seata.transport.thread-factory.client-selector-thread-size=1

seata.transport.thread-factory.client-worker-thread-prefix=NettyClientWorkerThread

seata.transport.thread-factory.worker-thread-size=default

seata.transport.thread-factory.boss-thread-size=1

seata.transport.type=TCP

seata.transport.server=NIO

seata.transport.heartbeat=true

seata.transport.serialization=seata

seata.transport.compressor=none

seata.transport.enable-client-batch-send-request=true

seata.config.type=file

seata.registry.type=file

重點3個配置項需要調整下，其餘保持預設

seata.application-id=cloud-web

seata.tx-service-group=cloud-web_tx_group

seata.service.vgroup-mapping.cloud-web_tx_group=default

OrderController.java

@RestController

@RequestMapping(value = "/order")

public class OrderController {

    @Autowired

    OrderFacade orderFacade;

    @GlobalTransactional

    @GetMapping("/add")

    public String add(@RequestParam("cartId") Long cartId){

        orderFacade.addOrder(cartId);

        return "OK";

    }

}

在需要開啟分散式事務的方法上新增@GlobalTransactional註解即可

module-order

專案結構圖如下



OrderService.java

@RestController

public class OrderService implements OrderFacade {

    @Autowired

    private TbOrderMapper tbOrderMapper;

    @Autowired

    private CartFacade cartFacade;

    @Autowired

    private GoodsFacade goodsFacade;

    @Autowired

    private WalletFacade walletFacade;

    /**

     * <p >

     * 功能：新增訂單

     * </p>

     * @param cartId 購物車ID

     * @author wuyubin

     * @date  2020年05月22日

     * @return

     */

    @Override

    public void addOrder(Long cartId) {

        CartDTO cart = cartFacade.getCartById(cartId);

        TbOrder order = new TbOrder();

        order.setUserId(cart.getUserId());

        order.setGoodsId(cart.getGoodsId());

        order.setOrderNo(String.valueOf(System.currentTimeMillis()));

        order.setCreateTime(System.currentTimeMillis());

        order.setUpdateTime(order.getCreateTime());

        order.setIsDeleted(Byte.valueOf("0"));

        // 新增訂單

        tbOrderMapper.insert(order);

        // 刪除購物車

        cartFacade.deleteCartById(cartId);

        GoodsDTO goods = goodsFacade.getByGoodsId(cart.getGoodsId());

        // 扣減庫存

        goodsFacade.substractStock(goods.getId());

        // 扣減金額

        walletFacade.substractMoney(cart.getUserId(),goods.getMoney());

        throw new RuntimeException();

    }
module-cart

專案結構圖如下



CartService.java

@RestController

public class CartService implements CartFacade {

    Logger LOGGER = LoggerFactory.getLogger(CartService.class);

    @Autowired

    private TbCartMapper tbCartMapper;

    /**

     * <p >

     * 功能：增加商品至購物車

     * </p>

     * @param userId 使用者ID

     * @param goodsId 商品ID

     * @author wuyubin

     * @date  2020年05月22日

     * @return

     */

    @Override

    public String addCart(Long userId,Long goodsId) {

        TbCart cart = new TbCart();

        cart.setUserId(userId);

        cart.setGoodsId(goodsId);

        cart.setCreateTime(System.currentTimeMillis());

        cart.setUpdateTime(cart.getCreateTime());

        cart.setIsDeleted(Byte.valueOf("0"));

        tbCartMapper.insert(cart);

        return null;

    }

    /**

     * <p >

     * 功能：獲取購物車資訊

     * </p>

     * @param cartId 購物車ID

     * @author wuyubin

     * @date  2020年05月22日

     * @return

     */

    @Override

    public CartDTO getCartById(Long cartId) {

        CartDTO cartDTO = null;

        TbCart cart = tbCartMapper.selectById(cartId);

        if (null != cart) {

            cartDTO = new CartDTO();

            cartDTO.setUserId(cart.getUserId());

            cartDTO.setGoodsId(cart.getGoodsId());

        }

        return cartDTO;

    }

    /**

     * <p >

     * 功能：刪除購物車資訊

     * </p>

     * @param cartId 購物車ID

     * @author wuyubin

     * @date  2020年05月22日

     * @return

     */

    @Override

    public void deleteCartById(Long cartId) {

        tbCartMapper.deleteById(cartId);

    }

}
module-goods

專案結構圖如下



GoodsService.java

@RestController

public class GoodsService implements GoodsFacade {

    @Autowired

    private TbGoodsMapper tbGoodsMapper;

    /**

     * <p >

     * 功能：獲取商品資訊

     * </p>

     * @param goodsId 商品ID

     * @author wuyubin

     * @date  2020年05月22日

     * @return

     */

    @Override

    public GoodsDTO getByGoodsId(Long goodsId) {

        GoodsDTO goodsDTO = null;

        TbGoods goods = tbGoodsMapper.selectById(goodsId);

        if (null != goods) {

            goodsDTO = new GoodsDTO();

            BeanUtils.copyProperties(goods,goodsDTO);

        }

        return goodsDTO;

    }

    /**

     * <p >

     * 功能：扣減商品庫存

     * </p>

     * @param goodsId 商品ID

     * @author wuyubin

     * @date  2020年05月22日

     * @return

     */

    @Override

    public void substractStock(@RequestParam("goodsId") Long goodsId) {

        if (tbGoodsMapper.updateSubstractStockNumById(goodsId) != 1) {

            throw new RuntimeException("扣減庫存異常");

        }

    }

}
module-wallet

專案結構圖如下



WalletService.java

@RestController

public class WalletService implements WalletFacade {

    @Autowired

    private TbWalletMapper tbWalletMapper;

    /**

     * <p >

     * 功能：扣減使用者錢包金額

     * </p>

     * @param userId 使用者ID

     * @param money 金額

     * @author wuyubin

     * @date  2020年05月22日

     * @return

     */

    @Override

    public void substractMoney(Long userId, BigDecimal money) {

        if (tbWalletMapper.updateSubstractMoney(userId,money) != 1) {

            throw new RuntimeException("使用者金額異常");

        }

    }

}
表結構說明

undo_log 表：seata依賴表

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 DEFAULT CHARSET=utf8;

tb_cart 表：購物車表

CREATE TABLE `tb_cart`  (

  `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主鍵',

  `user_id` bigint(20) NULL DEFAULT NULL COMMENT '使用者ID',

  `goods_id` bigint(20) NULL DEFAULT NULL COMMENT '商品ID',

  `create_time` bigint(20) NULL DEFAULT NULL COMMENT '建立時間戳',

  `update_time` bigint(20) NULL DEFAULT NULL COMMENT '更新時間戳',

  `is_deleted` tinyint(4) NULL DEFAULT 0 COMMENT '刪除標誌 0：未刪除；1：已刪除',

  PRIMARY KEY (`id`) USING BTREE

) ENGINE = InnoDB AUTO_INCREMENT = 2 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = '購物車表' ROW_FORMAT = Dynamic;

-- 初始化資料

INSERT INTO `tb_cart` VALUES (1, 1, 1, 1590114829756, 1590114829756, 0);

tb_goods 表：商品表

CREATE TABLE `tb_goods`  (

  `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主鍵',

  `name` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '商品名稱',

  `stock_num` bigint(20) NULL DEFAULT NULL COMMENT '商品庫存數量',

  `money` decimal(10, 2) NULL DEFAULT NULL COMMENT '商品金額',

  `create_time` bigint(20) NULL DEFAULT NULL COMMENT '建立時間戳',

  `update_time` bigint(20) NULL DEFAULT NULL COMMENT '更新時間戳',

  `is_deleted` tinyint(4) NULL DEFAULT NULL COMMENT '刪除標誌 0：未刪除；1：已刪除',

  PRIMARY KEY (`id`) USING BTREE

) ENGINE = InnoDB AUTO_INCREMENT = 2 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = '商品表' ROW_FORMAT = Dynamic;

-- 初始化資料

INSERT INTO `tb_goods` VALUES (1, '鍵盤', 100, 100.00, 1590132270000, 1590377130, 0);

tb_wallet 表：錢包表

CREATE TABLE `tb_wallet`  (

  `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主鍵',

  `user_id` bigint(20) NULL DEFAULT NULL COMMENT '使用者ID',

  `money` decimal(10, 2) NULL DEFAULT NULL COMMENT '金額',

  `create_time` bigint(20) NULL DEFAULT NULL COMMENT '建立時間戳',

  `update_time` bigint(20) NULL DEFAULT NULL COMMENT '更新時間戳',

  `is_deleted` tinyint(4) NULL DEFAULT NULL COMMENT '刪除標誌 0：未刪除；1：已刪除',

  PRIMARY KEY (`id`) USING BTREE

) ENGINE = InnoDB AUTO_INCREMENT = 2 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = '錢包表' ROW_FORMAT = Dynamic;

-- 初始化資料

INSERT INTO `tb_wallet` VALUES (1, 1, 500.00, 1590132270000, 1590377130, 0);

tb_order 表：訂單表

CREATE TABLE `tb_order`  (

  `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主鍵',

  `order_no` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '訂單編號',

  `user_id` bigint(20) NULL DEFAULT NULL COMMENT '使用者ID',

  `goods_id` bigint(20) NULL DEFAULT NULL COMMENT '商品ID',

  `create_time` bigint(20) NULL DEFAULT NULL COMMENT '建立時間',

  `update_time` bigint(20) NULL DEFAULT NULL COMMENT '更新時間',

  `is_deleted` tinyint(4) NULL DEFAULT 0 COMMENT '是否刪除 0：未刪除；1：已刪除',

  PRIMARY KEY (`id`) USING BTREE

) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = '訂單表' ROW_FORMAT = Dynamic;

所有服務啟動後，請求以下介面

http://localhost:9005/cloud-web/order/add?cartId=1



檢視各服務模組日誌，你會發現均有如下資訊輸出，提示已回滾



因為在order模組中addOrder方法下，我這邊人為丟擲一個執行時異常，看樣子事務已經生效了



我們看下資料庫中資料是否已回滾正常，核實後發現資料均以回滾









接下來我們把order模組中addOrder方法下將“throw new RuntimeException();”程式碼塊註釋掉，重啟訂單模組服務後再次訪問上述介面地址，發現訪問正常



檢視各服務模組日誌，你會發現均有如下資訊輸出，提示已提交成功



我們再一次核實下資料表中的資料

購物車表已將原先記錄邏輯刪除



訂單表新增一條訂單記錄



商品表庫存數量已扣減1



錢包表金額已扣減100



最後我們測試其中一個服務出現異常，驗證下事務是否回滾正常，我們將購物車表邏輯刪除恢復正常，將商品表庫存改成0，這時我們再請求上述介面地址，發現返回異常了，我們再核實下資料，發現資料表中的資料均以回滾。好啦，SpringCloud整合分散式事務Seata的示例就到這裡啦，後續有深入的研究再分享出來。

參考資料

https://github.com/seata/seata

https://seata.io/zh-cn/docs/overview/what-is-seata.html

系列文章

SpringCloud系列之配置中心（Config）使用說明

SpringCloud系列之服務註冊發現（Eureka）應用篇

SpringCloud系列之閘道器（Gateway）應用篇

SpringCloud系列之整合Dubbo應用篇

專案原始碼

相關推薦

SpringCloud系列之整合分散式事務Seata應用篇

目錄 前言 專案版本 專案說明 Seata服務端部署 Seata客戶端整合 cloud-web module-order module-cart

CI/CD系列之阿里云云效2020應用篇

目錄 前言 實戰 製品倉庫 maven配置 專案pom配置 程式碼管理 流水線 參考資料 前言 前不久登入阿里雲後臺，看到雲效的介紹，出於好奇便點進去看了看，剛開始以為雲效是類似Jenkins的一套自動化部署方案，瞭解之後發

「整合系列」分散式事務seata

本篇文章主要內容是使用Seata解決分散式事務問題。 場景說明 訂單服務order-service需要對外提供建立訂單的介面，建立訂單的業務邏輯如下：

SpringCloud系列之Nacos應用篇

前言 原先專案是以SpringConfig作為專案配置中心元件，Eureka作為服務註冊發現元件，基本上就是SpringCloud全家桶，Eureka已經停更，所以前期調研可替換方案，主流替換方案有Consul/ZooKeeper/Nacos/Etcd等，網上資料

SpringCloud系列之分散式配置中心極速入門與實踐

SpringCloud系列之分散式配置中心極速入門與實踐 @目錄1、分散式配置中心簡介2、什麼是SpringCloud Config？3、例子實驗環境準備4、Config Server程式碼實現5、Config Client程式碼實現6、客戶端pull重新整理實現7、

SpringCloud Alibaba微服務實戰七 - 分散式事務Seata

http://javadaily.cn/articles/2019/12/19/1576731515587.html Seata解決方案 在Springcloud Alibaba體系中使用Seata作為分散式事務解決方案，大家可以訪問seata官網去了解詳情。這次我們先使用Seata的file配置解決

老生常談系列之Aop--Aop的經典應用之Spring的事務實現分析（三）

老生常談系列之Aop--Aop的經典應用之Spring的事務實現分析（三） 前言 上一篇文章老生常談系列之Aop--Aop的經典應用之Spring的事務實現分析（二）從三個問題匯入，分析了Spring是如何開啟事務的、Spring是如何為需要

SpringCloud系列之使用Feign進行服務呼叫

在上一章的學習中，我們知道了微服務的基本概念，知道怎麼基於Ribbon+restTemplate的方式實現服務呼叫，接著上篇部落格，我們學習怎麼基於Feign實現服務呼叫，請先學習上篇部落格，然後再學習本篇部落格

SpringBoot學習之整合Druid的簡單應用

一、Druid介紹 Druid簡介 Druid是目前Java語言中最好的資料庫連線池之一。結合了 C3P0、DBCP 等 DB 池的優點，同時加入了日誌監控。Druid 是一個分散式的、支援實時多維 OLAP 分析的資料處理系統。它既支援高速的資料

SpringCloud系列之客戶端負載均衡Netflix Ribbon

1. 什麼是負載均衡？ 負載均衡是一種基礎的網路服務，它的核心原理是按照指定的負載均衡演算法，將請求分配到後端服務叢集上，從而為系統提供並行處理和高可用的能力。提到負載均衡，你可能想到nginx。對於負載均衡，

spring boot:使用分散式事務seata(druid 1.1.23 / seata 1.3.0 / mybatis / spring boot 2.3.2)

一，什麼是seata? Seata:Simpe Extensible Autonomous Transcaction Architecture， 是阿里中介軟體開源的分散式事務解決方案。

SpringCloud系列之： Eureka註冊中心原理及其搭建

一、Eureka簡介 　　Eureka是Netflix開發的服務發現框架，本身是一個基於REST的服務，主要用於定位執行在AWS域中的中間層服務，以達到負載均衡和中間層服務故障轉移的目的。SpringCloud將它整合在其子專案spring-cl

開源的分散式事務-Seata的設計原理

前言 在微服務架構體系下，我們可以按照業務模組分層設計，單獨部署，減輕了服務部署壓力，也解耦了業務的耦合，避免了應用逐漸變成一個龐然怪物，從而可以輕鬆擴充套件，在某些服務出現故障時也不會影響其它服務的正

微服務開發的最大痛點-分散式事務SEATA入門簡介

前言 在微服務開發中，存在諸多的開發痛點，例如分散式事務、全鏈路跟蹤、限流降級和服務平滑上下線等。而在這其中，分散式事務是最讓開發者頭痛的。那分散式事務是什麼呢？

SpringCloud 系列之 eureka

簡介 關於 eureka 首先我們去官網去看一下相關的描述：https://github.com/Netflix/eureka/wiki/Eureka-at-a-glance

SpringCloud 系列之 zookeeper

簡介 ZooKeeper 是一種分散式協調服務，用於管理大型主機。ZooKeeper 的設計目標是將那些複雜且容易出錯的分散式一致性服務封裝起來，構成一個高效可靠的原語集，並以一系列簡單易用的介面提供給使用者使用。

SpringCloud 系列之 nacos

簡介 nacos簡單來說就是一個服務註冊和配置中心，我們可以像使用其它註冊中心一樣使用它，它也可以當作配置中心，可以實現SpringCloud Config和SpringCloud Bus 一樣的功能，可以實現線上的專案資訊配置。本文主要講

PHP 微服務之【分散式事務】

分散式事務一直是微服務的一個難點。相關的解決方案和框架大部分是 java 的，那麼 php 該如何解決呢？下面一步一步講解如何用 php 解決分散式事務。

mysql 分散式鎖_死磕 java同步系列之mysql分散式鎖

技術標籤：mysql 分散式鎖 歡迎關注我的公眾號“彤哥讀原始碼”，檢視更多原始碼系列文章, 與彤哥一起暢遊原始碼的海洋。

分散式事務seata

https://blog.csdn.net/tianyaleixiaowu/article/details/95208906 seata分散式事務原理解釋，AT模式簡介