七叶笔记 » golang编程 » 开源的DTM-分布式事务管理,真的很牛逼

开源的DTM-分布式事务管理,真的很牛逼

还在纠结项目中如何选取最适合的 分布式事务 解决方案?还在绞尽脑汁地考虑技术方案中还有哪些盲点?如何避免分布式事务中始终跳不过的坑?如果你有上述的问题,那么今天就带你了解下一个很牛逼的分布式事务管理器- DTM;

DTM是什么

DTM是一款跨语言的开源分布式事务管理器,优雅的解决了幂等、空补偿、悬挂等分布式事务难题。提供了简单易用、高性能、易扩展的分布式事务解决方案。

亮点

  • 极易接入
    • 支持HTTP,提供非常简单的接口,极大降低上手分布式事务的难度,新手也能快速接入
  • 使用简单
    • 开发者不再担心悬挂、空补偿、幂等各类问题,框架层代为处理
  • 跨语言
    • 可适合多语言栈的公司使用。方便go、 python 、php、 nodejs ruby 各类语言使用。
  • 易部署、易扩展
    • 仅依赖 mysql ,部署简单,易集群化,易水平扩展
  • 多种分布式事务协议支持
    • TCC、SAGA、 XA 、事务消息

与其它框架对比

目前开源的分布式事务框架,暂未看到非 Java 语言有成熟的框架。而Java语言的较多,有 阿里 的SEATA、 华为 的ServiceComb-Pack,以及himly,tcc- transaction Byte TCC等等,其中以seata应用最为广泛。

下面是dtm和seata的主要特性对比:

特性

DTM

SEATA

备注

支持语言

Golang、python、php及其他

Java

dtm可轻松接入一门新语言

异常处理

子事务屏障自动处理

手动处理

dtm解决了幂等、悬挂、空补偿

TCC事务

XA事务

AT事务

AT与XA类似,性能更好,但有脏回滚

SAGA事务

简单模式

状态机复杂模式

dtm的状态机模式在规划中

事务消息

dtm提供类似rocketmq的事务消息

通信协议

HTTP

dubbo 等协议,无HTTP

dtm后续将支持grpc类协议

star数量

dtm从20210604发布0.1,发展快

从上面对比的特性来看,如果您的语言栈包含了Java之外的语言,那么dtm是您的首选。如果您的语言栈是Java,您也可以选择接入dtm,使用子事务屏障技术,简化您的业务编写。

使用方式

步骤一:JitPack 存储库添加到您的构建文件

Maven

 <repositories>
  <repository>
    <id>jitpack.io</id>
    <url>
  </repository>
</repositories>  

Gradle :

 allprojects {
    repositories {
      ...
      maven { url '#39; }
    }
  }  

步骤二:添加依赖项

Maven:

 <dependency>
  <groupId>com.github.yedf</groupId>
  <artifactId>dtmcli-java</artifactId>
  <version>Tag</version>
</dependency>  

Gradle:

 dependencies {
          implementation 'com.github.yedf:dtmcli-java:Tag'
  }  

示例:

Java示例

 @ Request Mapping("testTcc")
    public String testTcc() {
        //创建dtm clinet
        DtmClient dtmClient = new DtmClient(ipPort);
        //创建tcc事务
        try {
            dtmClient.tccGlobalTransaction(dtmClient.genGid(), TccTestController::tccTrans);
        } catch ( Exception  e) {
            log.error("tccGlobalTransaction error", e);
            return "fail";
        }
        return "success";
    }


/**
     * 定义tcc事务函数,内部需要通过callBranch注册事务子分支
     *
     * @param tcc
     * @return
     * @see TransController
     */    public  static   void  tccTrans(Tcc tcc) throws Exception {
        Response outResponse = tcc
                .callBranch("",  svc  + "/TransOutTry", svc + "/TransOutConfirm", svc + "/TransOutCancel");
        log.info("outResponse:{}", outResponse);
        Response inResponse = tcc.callBranch("", svc + "/TransInTry", svc + "/TransInConfirm", svc + "/TransInCancel");
        log.info("inResponse:{}", inResponse);
    }  

DTM开源地址

相关文章