2. 程式人生 > 其它 >分散式事務解決方案-seata

分散式事務解決方案-seata

阿新 • • 發佈：2022-04-14

什麼是MySQL XA方案？

MySQL從5.7開始加入了分散式事務的支援。MySQL XA中擁有兩種角色：RM，TM。

RM(Resource Manager):用於直接執行本地事務的提交和回滾。在分散式叢集中，一臺MySQL伺服器就是一個RM。

TM(Transaction Manager):TM是分散式事務的核心管理者。事務管理器與每個RM進行通訊，協調並完成分散式事務的處理。

發起一個分散式事務的MySQL客戶端就是一個TM。

XA的兩階段提交分為Prepare階段和Commit階段，過程如下：

階段一為準備（prepare）階段:即所有的RM（Resource Manager）鎖住需要的資源，在本地執行這個事務（執行sql，寫redo/undo log等），但不提交，然後向TM（Transaction Manager）報告已準備就緒

階段二為提交階段（commit）:當TM（Transaction Manager）確認所有參與者都ready後，向所有參與者傳送commit命令。

什麼是seata?

Seata 是一款開源的分散式事務解決方案，致力於提供高效能和簡單易用的分散式事務服務。Seata 將為使用者提供了 AT、TCC、SAGA 和 XA 事務模式，為使用者打造一站式的分散式解決方案。

 

seata的分散式事務解決方案是業務層面的解決方案，只依賴於單臺數據庫的事務能力。Seata框架中一個分散式事務包含3中角色：TC，TM，RM。

事務協調器TC（Transaction Coordinator ）：維護全域性事務的執行狀態，負責協調並驅動全域性事務的提交或回滾。

TM（Transaction Manager）：控制全域性事務的邊界，負責開啟一個全域性事務，並最終發起全域性提交或全域性回滾的決議。

RM（Resource Manager）：控制分支事務，負責分支註冊、狀態彙報，並接收事務協調器的指令，驅動分支（本地）事務的提交和回滾。

TM是一個分散式事務的發起者和終結者，TC負責維護分散式事務的執行狀態，而RM則負責本地事務的運

MySQL XA與Seata（Fescar） AT的區別？

XA 方案的 RM 實際上是在資料庫層，RM 本質上就是資料庫自身（通過提供支援 XA 的驅動程式來供應用使用）。

Seata 的 RM 是以二方包的形式作為中介軟體層部署在應用程式這一側的，不依賴與資料庫本身對協議的支援。

使用Seata解決分散式異常

  1. 模擬分散式事務異常

  2. 使用Seata解決

1.模擬分散式事務異常

完成父工程：
1.新建springboot專案，刪除src資料夾

2.匯入pom依賴

<properties>
    <java.version>1.8</java.version>
    <!--spring cloud 版本-->
    <spring-cloud.version>Hoxton.SR3</spring-cloud.version>
    <spring-cloud-alibaba.version>2.2.1.RELEASE</spring-cloud-alibaba.version>
</properties>
<!--引入Spring Cloud 依賴-->
<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>${spring-cloud.version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-alibaba-dependencies</artifactId>
            <version>${spring-cloud-alibaba.version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>
<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <optional>true</optional>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
</dependencies>

完成子工程order(maven專案):

1.新建資料庫pay,表名pay

2.匯入maven依賴

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <scope>runtime</scope>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
        </dependency>
    </dependencies>

3.編寫application.yml

server:
  port: 8020
spring:
  application:
    name: pay
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    username: root
    password: root
    url: jdbc:mysql://localhost:3306/pay?serverTimezone=GMT%2B8

4.編寫啟動類

@SpringBootApplication
@EnableDiscoveryClient
public class OrderApplication {
    public static void main(String[] args) {
        SpringApplication.run(OrderApplication.class, args);
    }

    @Bean
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }

}

5.完成service

OrderService.java

public interface OrderService {
    void save();
}

OrderServiceImpl.java

@Service
public class OrderServiceImpl implements OrderService {

    @Autowired
    private JdbcTemplate jdbcTemplate;

    public void save(){
        this.jdbcTemplate.update(" INSERT INTO `order` (`username`) VALUES ('zhangsan') ");
    }
}

6.編寫OrderController.java

@RestController
public class OrderController {
    @Autowired
    private OrderService orderService;
    @Autowired
    private RestTemplate restTemplate;

    @GetMapping("/save")
    public String save(){
        //訂單
        this.orderService.save();
        int i = 10/0;
        //支付
        //控制器 Order 通過 RestTemplate 呼叫 Pay 的服務
        this.restTemplate.getForObject("http://localhost:8020/save",String.class);
        return "success";
    }
}

完成子工程pay(maven專案):

1.新建資料庫pay,表名pay

2.匯入maven依賴

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <scope>runtime</scope>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
        </dependency>
    </dependencies>

3.編寫application.yml

server:
  port: 8020
spring:
  application:
    name: pay
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    username: root
    password: root
    url: jdbc:mysql://localhost:3306/pay?serverTimezone=GMT%2B8

4.編寫啟動類

@SpringBootApplication
@EnableDiscoveryClient
public class PayApplication {
    public static void main(String[] args) {
        SpringApplication.run(PayApplication.class, args);
    }

}

5.完成service

PayService.java

public interface PayService {
     void save();
}

PayServiceImpl.java

@Service
public class PayServiceImpl implements PayService {
    @Autowired
    private JdbcTemplate jdbcTemplate;

    public void save(){
        this.jdbcTemplate.update(" INSERT INTO `pay` (`username`) VALUES ('張三') ");
    }
}

6.編寫PayController.java

@RestController
public class PayController {
    @Autowired
    private PayService payService;

    @GetMapping("/save")
    public String save(){
        this.payService.save();
        return "success";
    }
}

使用Seate解決分散式問題

1.下載Seate https://seata.io/zh-cn/blog/download.html

我用的版本0.9.0

 

2.解壓後分別修改nacos-config.txt和registry.conf

regisry.conf

注意serverAddr地址如果是linux中，不在本機，需要寫uri

registry {
  type = "nacos"
  nacos {
    serverAddr = "localhost"
    namespace = "public"
    cluster = "default"
  }
}

config {
  type = "nacos"
  nacos {
    serverAddr = "localhost"
    namespace = "public"
    cluster = "default"
  }
}

nacos-config.txt

名字與工程中application.yml中的name屬性對應

transport.type=TCP
transport.server=NIO
transport.heartbeat=true
transport.thread-factory.boss-thread-prefix=NettyBoss
transport.thread-factory.worker-thread-prefix=NettyServerNIOWorker
transport.thread-factory.server-executor-thread-prefix=NettyServerBizHandler
transport.thread-factory.share-boss-worker=false
transport.thread-factory.client-selector-thread-prefix=NettyClientSelector
transport.thread-factory.client-selector-thread-size=1
transport.thread-factory.client-worker-thread-prefix=NettyClientWorkerThread
transport.thread-factory.boss-thread-size=1
transport.thread-factory.worker-thread-size=8
transport.shutdown.wait=3
service.vgroup_mapping.pay=default
service.vgroup_mapping.order=default
service.enableDegrade=false
service.disable=false
service.max.commit.retry.timeout=-1
service.max.rollback.retry.timeout=-1
client.async.commit.buffer.limit=10000
client.lock.retry.internal=10
client.lock.retry.times=30
client.lock.retry.policy.branch-rollback-on-conflict=true
client.table.meta.check.enable=true
client.report.retry.count=5
client.tm.commit.retry.count=1
client.tm.rollback.retry.count=1
store.mode=file
store.file.dir=file_store/data
store.file.max-branch-session-size=16384
store.file.max-global-session-size=512
store.file.file-write-buffer-cache-size=16384
store.file.flush-disk-mode=async
store.file.session.reload.read_size=100
store.db.datasource=dbcp
store.db.db-type=mysql
store.db.driver-class-name=com.mysql.jdbc.Driver
store.db.url=jdbc:mysql://127.0.0.1:3306/seata?useUnicode=true
store.db.user=mysql
store.db.password=mysql
store.db.min-conn=1
store.db.max-conn=3
store.db.global.table=global_table
store.db.branch.table=branch_table
store.db.query-limit=100
store.db.lock-table=lock_table
recovery.committing-retry-period=1000
recovery.asyn-committing-retry-period=1000
recovery.rollbacking-retry-period=1000
recovery.timeout-retry-period=1000
transaction.undo.data.validation=true
transaction.undo.log.serialization=jackson
transaction.undo.log.save.days=7
transaction.undo.log.delete.period=86400000
transaction.undo.log.table=undo_log
transport.serialization=seata
transport.compressor=none
metrics.enabled=false
metrics.registry-type=compact
metrics.exporter-list=prometheus
metrics.exporter-prometheus-port=9898
support.spring.datasource.autoproxy=false

啟動Nacos

在路勁下的位址列輸入cmd,在cmd介面輸入startup/startup.cmd

執行 nacos-config.sh 將 Seata 配置匯入 Nacos

注意：windows中不能直接執行sh檔案，可用git啟動

# 進入conf目錄，git hash中執行：
sh nacos-config.sh 127.0.0.1

啟動 Seata Server ( JDK 8 以上環境無法啟動)

# 進入bin目錄 ，位址列輸入cmd
seata-server.bat -p 8090 -m file

初始化數據庫

兩個資料庫中執行此sql

兩個子工程的pom中新增seata依賴

<dependency>
     <groupId>com.alibaba.cloud</groupId>
     <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency>

給 JDBCTemplate 新增代理資料來源（我用的是JDBC，如果使用的是MyBatis 或 MP處理不一樣）

OrderApplication.java

@SpringBootApplication
public class OrderApplication {

    public static void main(String[] args) {
        SpringApplication.run(OrderApplication.class, args);
    }

    @Bean
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }

    @Bean
    public JdbcTemplate jdbcTemplate(DataSource dataSource){
        return new JdbcTemplate(new DataSourceProxy(dataSource));
    }
}

PayApplication.java

@SpringBootApplication
public class PayApplication {

    public static void main(String[] args) {
        SpringApplication.run(PayApplication.class, args);
    }

    @Bean
    public JdbcTemplate jdbcTemplate(DataSource dataSource){
        return new JdbcTemplate(new DataSourceProxy(dataSource));
    }

}

將registry.conf 複製到兩個工程的 resources 下

給兩個工程新增 bootstrap.yml 讀取 Nacos 配置

tx-service-group 需要和 Nacos 配置中的名稱一致

spring:
  application:
    name: order
  cloud:
    nacos:
      config:
        server-addr: localhost:8848
        namespace: public
        group: SEATA_GROUP
    alibaba:
      seata:
        tx-service-group: ${spring.application.name}
spring:
  application:
    name: order
  cloud:
    nacos:
      config:
        server-addr: localhost:8848
        namespace: public
        group: SEATA_GROUP
    alibaba:
      seata:
        tx-service-group: ${spring.application.name}

Order 呼叫 Pay 處添加註解 @GlobalTransactional

@RestController
public class OrderController {

    @Autowired
    private OrderService orderService;
    @Autowired
    private RestTemplate restTemplate;

    @GetMapping("/save")
    @GlobalTransactional
    public String save(){
        //訂單
        this.orderService.save();
        int i = 10/0;
        //支付
        this.restTemplate.getForObject("http://localhost:8020/save",String.class);
        return "success";
    }
}

執行

在OrderController.java打斷點

Debug執行Order

執行Pay

訪問http://localhost:8010/save

檢視order資料庫

order表

undo_log表

直接執行完

order表

 undo_log表

進行了資料的回滾，如果去掉模擬異常int i=10/0，兩個資料庫能夠存入資料

相關推薦

開源的分散式事務解決方案-Seata

Seata 是什麼? （1）Seata 是一款開源的分散式事務解決方案，致力於在微服務架構下提供高效能和簡單易用的分散式事務服務。

分散式事務解決方案-seata

什麼是MySQL XA方案？ MySQL從5.7開始加入了分散式事務的支援。MySQL XA中擁有兩種角色：RM，TM。

分散式事務解決方案之 Alibaba Seata

關於事務的幾點常識 本地事務 該類事務需要滿足四大特性：ACID（原子性、一致性、隔離性、永續性），僅限於對單一資料庫資源的訪問控制。

詳解SpringBoot基於Dubbo和Seata的分散式事務解決方案

1. 分散式事務初探 一般來說，目前市面上的資料庫都支援本地事務，也就是在你的應用程式中，在一個數據庫連線下的操作，可以很容易的實現事務的操作。

spring cloud alibaba 分散式事務解決方案之seata-1.3.0

1.github上下載seata-1.3.0.zip包 連結：https://github.com/seata/seata/releases/download/v1.3.0/seata-server-1.3.0.zip

Alibaba微服務元件 - Seata（一） 分散式事務解決方案

1.1 事務簡介 事務(Transaction)是訪問並可能更新資料庫中各種資料項的一個程式執行單元(unit)。在關係資料庫中，一個事務由一組SQL語句組成。

分散式事務解決方案

什麼是分散式事務 在大的操作集合中，所有的小操作都屬於不同的伺服器，不同的應用，分散式事務需要保證這些小操作要麼一起成功，要麼一起失敗。本質上，分散式事務為了保證資料的一致性

基於RocketMq的分散式事務解決方案

特邀作者：老顧 轉載請宣告出處！ 前言 在系統變的複雜後，分散式、微服務等架構技術，就要考慮到應用在系統中了。尤其資料量大了後，就需要對資料庫進行拆分。

.NET Core 事件匯流排,分散式事務解決方案：CAP（轉載）

背景 相信前面幾篇關於微服務的文章也介紹了那麼多了，在構建微服務的過程中確實需要這麼一個東西，即便不是在構建微服務，那麼在構建分散式應用的過程中也會遇到分散式事務的問題，那麼 CAP 就是在這樣的背

曹工雜談：分散式事務解決方案之基於本地訊息表實現最終一致性

曹工雜談：分散式事務解決方案之基於本地訊息表實現最終一致性 前言 為什麼寫這個？其實我這邊的業務場景，嚴格來說，不算是典型的分散式事務，需求是這樣說的：因為我這邊負責的一個服務消費者consumer，是使用者登

架構師必備的那些分散式事務解決方案！！

為了保證分散式環境下資料強一致性，需要引入分散式事務，而分散式事務由於網路環境的不確定性，天生就很難實現。具體可以見上一篇。

分散式事務解決方案2--TCC事務補償實踐

1、建立SpringBoot工程 工程名為my-tcc-demo 依賴如下 2、資料準備 134和129分別在user_134建立account_a表， user_129 建立account_b表

MSSQL server分散式事務解決方案

本篇文章由  www.234yp.com 整理髮布，  謝謝合作！mssql是什麼 　　適用環境 　　作業系統：windows 2003

最全分散式事務解決方案詳解

錄 一、分散式事務前奏 二、柔性事務解決方案架構 （一）、基於可靠訊息的最終一致性方案概述

.NET Core 事件匯流排,分散式事務解決方案：CAP

本文地址：http://www.cnblogs.com/savorboard/p/cap.html 作者部落格：Savorboard 背景 相信前面幾篇關於微服務的文章也介紹了那麼多了，在構建微服務的過程中確實需要這麼一個東西，即便不是在構建微服務，那麼在

分散式事務解決方案之2PC(兩階段提交)

概述 學習了分散式事務的基礎理論，以理論為基礎，針對不同的分散式場景業界常見的解決方案有2PC、TCC、可靠訊息最終一致性、最大努力通知這幾種。

分散式事務解決方案之可靠訊息最終一致性

什麼是可靠訊息最終一致性事務 可靠訊息最終一致性方案是指當事務發起方執行完成本地事務後併發出一條訊息，事務參與方(訊息消費者)一定能夠接收訊息並處理事務成功，此方案強調的是隻要訊息發給事務參與方最終事務要

分散式事務解決方案-2pc/3pc

什麼是2pc? 2PC 即兩階段提交協議，將整個事務流程分為兩個階段:準備階段、提交階段

分散式事務-解決方案

◆  兩階段提交/XA XA是由X/Open組織提出的分散式事務的規範，XA規範主要定義了(全域性)事務管理器(TM)和(區域性)資源管理器(RM)之間的介面。本地的資料庫如mysql在XA中扮演的是RM角色

簡單瞭解4種分散式session解決方案

cookie和session的區別和聯絡 cookie是本地客戶端用來儲存少量資料資訊的，儲存在客戶端，使用者能夠很容易的獲取，安全性不高，儲存的資料量小