云计算、AI、云原生、大数据等一站式技术学习平台

网站首页 > 教程文章 正文

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

jxf315 2025-02-07 17:55:37 教程文章 30 ℃

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


如何选择最适合的分布式事务方案

CodingBug,公众号:CodingCode如何选择适合分布式事务的方案


DTM是什么

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


亮点

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


与其它框架对比

目前开源的分布式事务框架,暂未看到非Java语言有成熟的框架。而Java语言的较多,有阿里的SEATA、华为的ServiceComb-Pack,以及himly,tcc-transaction,ByteTCC等等,其中以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:


  
    jitpack.io
    https://jitpack.io
  

Gradle:

allprojects {
    repositories {
      ...
      maven { url 'https://jitpack.io' }
    }
  }

步骤二:添加依赖项

Maven:


  com.github.yedf
  dtmcli-java
  Tag

Gradle:

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


示例:

Java示例

https://github.com/dtm-labs/dtmcli-java-sample

@RequestMapping("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开源地址

https://dtm.pub/

最近发表
标签列表