Java詳細分析LCN框架分散式事務

2022-07-28 22:04:31

2PC兩階段提交協定

分散式事務通常採用2PC協定，全稱Two Phase Commitment Protocol。該協定主要為了解決在分散式資料庫場景下，所有節點間資料一致性的問題。分散式事務通過2PC協定將提交分成兩個階段：

階段一為準備（prepare）階段。即所有的參與者準備執行事務並鎖住需要的資源。參與者ready時，向transaction manager報告已準備就緒。
階段二為提交階段（commit）。當transaction manager確認所有參與者都ready後，向所有參與者傳送commit命令。

2PC和3PC的區別就是解決參與者超時的問題和多加了一層詢問，保證資料的傳輸可靠性。

LCN

LCN並不生產事務，LCN只是本地事務的協調工，TX-LCN定位於一款事務協調性框架，框架其本身並不操作事務，而是基於對事務的協調從而達到事務一致性的效果。

參考檔案：https://www.codingapi.com/docs/txlcn-preface/

LCN基本實現原理

發起方與參與方都與我們的 LCN 管理器一直保持長連線；
發起方在呼叫介面之前，先向 LCN 管理器申請一個全域性的事務分組id；
發起方呼叫介面的時候在請求頭中傳遞事務分組id；
參與方獲取到請求頭中有事務分組的id的，則當前業務邏輯執行完實現假關閉，不會提交或者回滾當前的事務。
發起方呼叫完介面後，如果出現異常的情況下，在通知給事務協調者回滾事務，這時候事務協調則告訴給參與方回滾當前的事務。

搭建全域性協調者

1、在github上面下載 Lcn 原始碼

倉庫地址：https://github.com/codingapi/tx-lcn，注意下載版本。

2、將專案匯入idea中，啟動對應的專案

修改對應的組態檔：

spring.application.name=TransactionManager
server.port=7970
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.url=jdbc:mysql://www.kaicostudy.com:3306/transaction_lcn?characterEncoding=UTF-8
spring.datasource.username=root
spring.datasource.password=123456

mybatis.configuration.map-underscore-to-camel-case=true
mybatis.configuration.use-generated-keys=true

# TxManager Host Ip
tx-lcn.manager.host=127.0.0.1
# TxClient連線請求埠
tx-lcn.manager.port=8070
# 心跳檢測時間(ms)
tx-lcn.manager.heart-time=15000
# 分散式事務執行總時間
tx-lcn.manager.dtx-time=30000
#引數延遲刪除時間單位ms
tx-lcn.message.netty.attr-delay-time=10000
tx-lcn.manager.concurrent-level=128
# 開啟紀錄檔
tx-lcn.logger.enabled=true
logging.level.com.codingapi=debug

#redis 連線資訊
spring.redis.host=www.kaicostudy.com
spring.redis.port=6379
redisu5BC6u7801
#spring.redis.password=

將專案中提供的SQL語句在資料庫中執行，建立對應的表。

請求路徑：http://127.0.0.1:7970/admin/index.html

預設登入密碼：codingapi

登入成功頁面

埠介紹：

8070：TM事務訊息埠

7970：後臺管理頁面登入頁面

使用LCN解決分散式事務問題

在分散式系統A系統呼叫B系統服務介面的時候時候，兩個服務的都需要使用 LCN 來控制分散式事務。

使用步驟：

1、引入lcn 相關的maven依賴

<dependency>
    <groupId>com.codingapi.txlcn</groupId>
    <artifactId>txlcn-tc</artifactId>
    <version>5.0.2.RELEASE</version>
</dependency>
<dependency>
    <groupId>com.codingapi.txlcn</groupId>
    <artifactId>txlcn-txmsg-netty</artifactId>
    <version>5.0.2.RELEASE</version>
</dependency>

2、yml 組態檔增加 lcn 的設定

tx-lcn:
  client:
    manager-address: www.kaicostudy.com:8070
  logger:
    enabled: true

3、使用

springboot專案主類上加上註解：@EnableDistributedTransaction

參與方與發起方都要加上該註解

@LcnTransaction

@Transactional

呼叫案例：

A服務的方法，需要去呼叫B服務方法

@Service
public class ServiceA {
    @Autowired
    private ValueDao valueDao; //本地db操作
    @Autowired
    private ServiceB serviceB;//遠端B模組業務
    @LcnTransaction //分散式事務註解
    @Transactional //本地事務註解
    public String execute(String value) throws BusinessException {
        // step1. call remote service B
        String result = serviceB.rpc(value);  // (1)
        // step2. local store operate. DTX commit if save success, rollback if not.
        valueDao.save(value);  // (2)
        valueDao.saveBackup(value);  // (3)
        return result + " > " + "ok-A";
    }
}

B服務的方法，被A服務的方法呼叫

@Service
public class ServiceB {
    @Autowired
    private ValueDao valueDao; //本地db操作
    @LcnTransaction //分散式事務註解
    @Transactional  //本地事務註解
    public String rpc(String value) throws BusinessException {
        valueDao.save(value);  // (4)
        valueDao.saveBackup(value);  // (5)
        return "ok-B";
    }
}