dtm

Inglês | 简体中文

Gerenciador de transações distribuídas

O que é DTM

DTM é uma estrutura de transação distribuída que fornece consistência de dados eventual entre serviços. Ele fornece padrões de fluxo de trabalho saga, tcc, xa, mensagem bifásica, caixa de saída para uma variedade de cenários de aplicativos. Ele também oferece suporte a vários idiomas e vários mecanismos de armazenamento para formar uma transação da seguinte forma:

Quem está usando DTM (parcial)

Tencent

Bytedância

Ivydad

Mais

Características

• Suporte para vários modos de transação: SAGA, TCC, XA, Workflow, Outbox
• Suporte a vários idiomas: SDK para Go, Java, PHP, C#, Python, Nodejs
• Melhor caixa de saída: mensagens em duas fases, uma solução mais elegante que a caixa de saída, suporta vários bancos de dados
• Suporte a múltiplas transações de banco de dados: MySQL/MariaDB, Redis, MongoDB, Postgres, TDSQL, etc.
• Suporte para vários mecanismos de armazenamento: MySQL/MariaDB (comum), Redis (alto desempenho), BoltDB (desenvolvimento e teste), MongoDB (em planejamento)
• Suporte para múltiplas arquiteturas de microsserviços: go-zero, go-kratos/kratos, polarismesh/polaris
• Suporte para alta disponibilidade e fácil escalonamento horizontal

Cenários de aplicação.

O DTM pode ser aplicado a problemas de consistência de dados em um grande número de cenários. Aqui estão alguns dos mais comuns

• gerenciamento de cache: garanta completamente a consistência final do cache e a consistência forte
• flash-sales para deduzir estoque: em casos extremos, também é possível garantir que o estoque preciso no Redis seja exatamente igual ao pedido final criado, sem a necessidade de ajuste manual
• Sistema de pedidos não monolítico: simplifica drasticamente a arquitetura
• Publicação/assinatura de eventos: melhor padrão de caixa de saída

Livro de receitas

Início rápido

execute dtm

git clone https://github.com/dtm-labs/dtm && cd dtm
go run main.go

Comece um exemplo

Suponha que queiramos realizar uma transferência interbancária. As operações de transferência de saída (TransOut) e transferência de entrada (TransIn) são codificadas em microsserviços separados.

Aqui está um exemplo para ilustrar uma solução de dtm para este problema:

git clone https://github.com/dtm-labs/quick-start-sample.git && cd quick-start-sample/workflow-grpc
go run main.go

Código

Uso

 wfName := "workflow-grpc"
err = workflow . Register ( wfName , func ( wf * workflow. Workflow , data [] byte ) error {
  // ...
  // Define a transaction branch for TransOut
  wf . NewBranch (). OnRollback ( func ( bb * dtmcli. BranchBarrier ) error {
    // compensation for TransOut
    _ , err := busiCli . TransOutRevert ( wf . Context , & req )
    return err
  })
  _ , err = busiCli . TransOut ( wf . Context , & req )
  // check error

  // Define another transaction branch for TransIn
  wf . NewBranch (). OnRollback ( func ( bb * dtmcli. BranchBarrier ) error {
    _ , err := busiCli . TransInRevert ( wf . Context , & req )
    return err
  })
  _ , err = busiCli . TransIn ( wf . Context , & req )
  return err
}

// ...
req := busi . BusiReq { Amount : 30 , TransInResult : "" }
data , err := proto. Marshal ( & req )

// Execute workflow
_ , err = workflow . ExecuteCtx ( wfName , shortuuid . New (), data )
logger . Infof ( "result of workflow.Execute is: %v" , err )

Quando o código acima é executado, podemos ver no console que o serviço TransOut , TransIn foi chamado.

Reverter em caso de falha

Se alguma operação de encaminhamento falhar, o DTM invoca a operação de compensação correspondente de cada subtransação para reverter, após o que a transação é revertida com sucesso.

Vamos acionar propositalmente a falha da segunda subtransação e observar o que acontece

 // req := busi.BusiReq{Amount: 30, TransInResult: ""}
req := busi. BusiReq { Amount : 30 , TransInResult : "FAILURE" }
})

podemos ver no console que os serviços TransOut , TransIn , TransOutRevert foram chamados

Mais exemplos

Se você quiser mais exemplos de início rápido, consulte dtm-labs/quick-start-sample

O exemplo acima demonstra principalmente o fluxo de uma transação distribuída. Mais sobre isso, incluindo exemplos práticos de como interagir com um banco de dados real, como fazer compensação, como fazer rollback, etc. consulte exemplos de dtm para mais exemplos.

Dê uma estrela!

Se você acha que este projeto é interessante ou útil para você, dê uma estrela!