dtm

Anglais | 简体中文

Gestionnaire de transactions distribuées

Qu'est-ce que le DTM

DTM est un cadre de transaction distribué qui assure la cohérence éventuelle des données entre services. Il fournit des modèles de flux de travail Saga, TCC, XA, message en 2 phases, boîte d'envoi pour une variété de scénarios d'application. Il prend également en charge plusieurs langues et plusieurs moteurs de magasin pour former une transaction comme suit :

Qui utilise DTM (partiel)

Tencent

Byté danse

Ivydad

Plus

Caractéristiques

• Prise en charge de plusieurs modes de transaction : SAGA, TCC, XA, Workflow, Outbox
• Prise en charge de plusieurs langues : SDK pour Go, Java, PHP, C#, Python, Nodejs
• Meilleure boîte d'envoi : messages en 2 phases, une solution plus élégante que la boîte d'envoi, prend en charge plusieurs bases de données
• Prise en charge de plusieurs transactions de bases de données : MySQL/MariaDB, Redis, MongoDB, Postgres, TDSQL, etc.
• Prise en charge de plusieurs moteurs de stockage : MySQL/MariaDB (commun), Redis (hautes performances), BoltDB (dév&test), MongoDB (en cours de planification)
• Prise en charge de plusieurs architectures de microservices : go-zero, go-kratos/kratos, polarismesh/polaris
• Prise en charge de la haute disponibilité et d’une mise à l’échelle horizontale facile

Scénarios d'application.

Le DTM peut être appliqué aux problèmes de cohérence des données dans un grand nombre de scénarios, en voici quelques-uns courants

• gestion du cache : garantir minutieusement la cohérence finale du cache et une cohérence forte
• des ventes flash pour déduire l'inventaire : dans les cas extrêmes, il est également possible de s'assurer que l'inventaire précis dans Redis est exactement le même que la commande finale créée, sans avoir besoin d'ajustement manuel
• Système de commande non monolithique : simplifie considérablement l'architecture
• Publication/abonnement à des événements : meilleur modèle de boîte d'envoi

Livre de cuisine

Démarrage rapide

exécuter DTM

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

Commencer un exemple

Supposons que nous souhaitions effectuer un virement interbancaire. Les opérations de transfert sortant (TransOut) et de transfert entrant (TransIn) sont codées dans des micro-services distincts.

Voici un exemple pour illustrer une solution de dtm à ce problème :

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

Code

Usage

 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 )

Lorsque le code ci-dessus s'exécute, nous pouvons voir dans la console que les services TransOut , TransIn ont été appelés.

Restauration en cas d'échec

Si une opération de transfert échoue, DTM appelle l'opération de compensation correspondante de chaque sous-transaction pour annuler, après quoi la transaction est annulée avec succès.

Déclenchons volontairement l'échec de la deuxième sous-transaction et observons ce qui se passe

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

on peut voir dans la console que les services TransOut , TransIn , TransOutRevert ont été appelés

Plus d'exemples

Si vous souhaitez plus d'exemples de démarrage rapide, veuillez vous référer à dtm-labs/quick-start-sample

L'exemple ci-dessus démontre principalement le flux d'une transaction distribuée. Pour en savoir plus à ce sujet, y compris des exemples pratiques sur la façon d'interagir avec une base de données réelle, comment effectuer une compensation, comment effectuer une restauration, etc. veuillez vous référer à dtm-examples pour plus d'exemples.

Donnez une étoile !

Si vous pensez que ce projet est intéressant ou utile pour vous, donnez une étoile !