dtm

Bahasa Inggris | 简体中文

Manajer Transaksi Terdistribusi

Apa itu DTM

DTM adalah kerangka transaksi terdistribusi yang menyediakan konsistensi data lintas layanan. Ini menyediakan saga, tcc, xa, pesan 2 fase, kotak keluar, pola alur kerja untuk berbagai skenario aplikasi. Ini juga mendukung berbagai bahasa dan beberapa mesin toko untuk membentuk transaksi sebagai berikut:

Siapa yang menggunakan DTM (sebagian)

Tencent

Bytedansi

Ivydad

Lagi

Fitur

• Dukungan untuk berbagai mode transaksi: SAGA, TCC, XA, Alur Kerja, Kotak Keluar
• Dukungan berbagai bahasa: SDK untuk Go, Java, PHP, C#, Python, Nodejs
• Kotak Keluar Lebih Baik: pesan 2 fase, solusi yang lebih elegan daripada Kotak Keluar, mendukung multi-database
• Dukungan beberapa transaksi database: MySQL/MariaDB, Redis, MongoDB, Postgres, TDSQL, dll.
• Dukungan untuk beberapa mesin penyimpanan: MySQL/MariaDB (umum), Redis (kinerja tinggi), BoltDB (dev&test), MongoDB (dalam perencanaan)
• Dukungan untuk beberapa arsitektur layanan mikro: go-zero, go-kratos/kratos, polarismash/polaris
• Dukungan untuk ketersediaan tinggi dan penskalaan horizontal yang mudah

Skenario aplikasi.

DTM dapat diterapkan pada masalah konsistensi data dalam banyak skenario, berikut beberapa skenario umum

• manajemen cache: menjamin konsistensi akhir cache dan konsistensi yang kuat
• penjualan kilat untuk mengurangi inventaris: dalam kasus ekstrim, dimungkinkan juga untuk memastikan bahwa inventaris yang tepat di Redis sama persis dengan pesanan akhir yang dibuat, tanpa perlu penyesuaian manual
• Sistem tatanan non-monolitik: Menyederhanakan arsitektur secara dramatis
• Penerbitan/langganan acara: pola kotak keluar yang lebih baik

Buku Masak

Mulai cepat

jalankan dtm

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

Mulailah sebuah contoh

Misalkan kita ingin melakukan transfer antar bank. Operasi transfer keluar (TransOut) dan transfer masuk (TransIn) dikodekan dalam layanan mikro terpisah.

Berikut adalah contoh untuk menggambarkan solusi dtm untuk masalah ini:

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

Kode

Penggunaan

 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 )

Ketika kode di atas dijalankan, kita dapat melihat di konsol bahwa layanan TransOut , TransIn telah dipanggil.

Kembalikan jika gagal

Jika ada operasi penerusan yang gagal, DTM akan memanggil operasi kompensasi yang sesuai dari setiap sub-transaksi untuk melakukan rollback, setelah itu transaksi berhasil dibatalkan.

Mari kita dengan sengaja memicu kegagalan sub-transaksi kedua dan melihat apa yang terjadi

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

kita dapat melihat di konsol bahwa layanan TransOut , TransIn , TransOutRevert telah dipanggil

Lebih banyak contoh

Jika Anda ingin contoh memulai cepat lainnya, lihat dtm-labs/quick-start-sample

Contoh di atas terutama menunjukkan aliran transaksi terdistribusi. Lebih lanjut mengenai hal ini, termasuk contoh praktis bagaimana berinteraksi dengan database sebenarnya, bagaimana melakukan kompensasi, bagaimana melakukan rollback, dll. silakan merujuk ke dtm-examples untuk contoh lebih lanjut.

Berikan bintang!

Jika menurut Anda proyek ini menarik, atau bermanfaat bagi Anda, silakan beri bintang!