1.場景還原

     筆者在公司最近的一個專案採用springcloud框架搭建微服務架構，這勢必會引發分散式事務處理的思考，目前處理分散式主流方案tcc及訊息的最終一致性；今天筆者整合github上較為流行的tx-lcn分散式處理框架，它是基於redis的一種補償型處理方案

2.實現方案

①先截圖，下載該框架

從github上的starts數量來看，目前還是較多開發者採用了這種方案的，而且作者維護迭代也很及時

②將tx-manager微服務單獨拎出來，整合在自己的專案中

將tx-manager中application.properties中的配置改成自己的專案配置

③然後涉及分散式的微服務中新增如下依賴

<!--分散式事物-->
<dependency>
   <groupId>com.codingapi</groupId>
   <artifactId>transaction-springcloud</artifactId>
   <version>${lcn.last.version}</version>
   <exclusions>
      <exclusion>
         <groupId>org.slf4j</groupId>
         <artifactId>*</artifactId>
      </exclusion>
   </exclusions>
</dependency>

<dependency>
   <groupId>com.codingapi</groupId>
   <artifactId>tx-plugins-db</artifactId>
   <version>${lcn.last.version}</version>
   <exclusions>
      <exclusion>
         <groupId>org.slf4j</groupId>
         <artifactId>*</artifactId>
      </exclusion>
   </exclusions>
</dependency>
 

將其中的兩個實現類複製到自己工程的service中

⑤開啟tx-manager，在各個微服務application.yml配置tx-manager地址

# 分散式事物
tm:
  manager:
    url: http://localhost:8899/tx/manager/

3.應用步驟

①分散式事務起始服務方

@Transactional
@TxTransaction(isStart = true)
public int addAcount(String logId){
   int i = yiViUserAccountMapper.increaseAccount("100","71d8beff-9e70-11e7-9a60-00163e0a3457");

   int n =  paymentDispatchFeignClient.test(logId); //呼叫失敗

   if(n == 0){
       throw new RuntimeException("服務呼叫失敗");
   }
    return i + n;
}
 

②被呼叫服務方

@Override
@Transactional
@TxTransaction
public int test(String logId) throws YiViException {
    int i = yiViDispatchOrderStatusLogMapper.deleteByPrimaryKey(logId);
    return i;
}

如此便可，好了我是張星，歡迎加入博主技術交流群，群號：526601468