dtm

الإنجليزية | 简体中文

مدير المعاملات الموزعة

ما هو دي تي ام

DTM هو إطار عمل موزع للمعاملات يوفر تناسقًا نهائيًا للبيانات عبر الخدمات. فهو يوفر الملحمة، وtcc، وxa، والرسائل ثنائية الطور، وصندوق الصادر، وأنماط سير العمل لمجموعة متنوعة من سيناريوهات التطبيق. كما أنه يدعم لغات متعددة ومحرك متجر متعدد لتكوين معاملة على النحو التالي:

من يستخدم DTM (جزئي)

تينسنت

بايت دانس

ايفيداد

أكثر

سمات

• دعم أوضاع المعاملات المتعددة: SAGA، TCC، XA، Workflow، Outbox
• دعم لغات متعددة: SDK for Go وJava وPHP وC# وPython وNodejs
• Outbox أفضل: رسائل ثنائية الطور، وهي حل أكثر أناقة من Outbox، وتدعم قواعد بيانات متعددة
• دعم معاملات قاعدة البيانات المتعددة: MySQL/MariaDB، وRedis، وMongoDB، وPostgres، وTDSQL، وما إلى ذلك.
• دعم محركات تخزين متعددة: MySQL/MariaDB (مشترك)، Redis (عالي الأداء)، BoltDB (dev&test)، MongoDB (قيد التخطيط)
• دعم بنيات الخدمات الصغيرة المتعددة: go-zero، وgo-kratos/kratos، وpolarismesh/polaris
• دعم التوفر العالي والقياس الأفقي السهل

سيناريوهات التطبيق

يمكن تطبيق DTM على مشكلات تناسق البيانات في عدد كبير من السيناريوهات، فيما يلي بعض السيناريوهات الشائعة

• إدارة ذاكرة التخزين المؤقت: ضمان الاتساق النهائي لذاكرة التخزين المؤقت والاتساق القوي
• مبيعات سريعة لخصم المخزون: في الحالات القصوى، من الممكن أيضًا التأكد من أن المخزون الدقيق في Redis هو تمامًا نفس الطلب النهائي الذي تم إنشاؤه، دون الحاجة إلى التعديل اليدوي
• نظام ترتيب غير متآلف: يبسط البنية بشكل كبير
• نشر/اشتراك الحدث: نمط أفضل للبريد الصادر

كتاب الطبخ

بداية سريعة

تشغيل dtm

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

ابدأ بمثال

لنفترض أننا نريد إجراء تحويل بين البنوك. يتم ترميز عمليات النقل للخارج (TransOut) والتحويل للداخل (TransIn) في خدمات صغيرة منفصلة.

فيما يلي مثال لتوضيح حل dtm لهذه المشكلة:

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

شفرة

الاستخدام

 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 )

عند تشغيل الكود أعلاه، يمكننا أن نرى في وحدة التحكم أن خدمات TransOut ، قد تم استدعاء TransIn .

التراجع عند الفشل

في حالة فشل أي عملية إعادة توجيه، تستدعي DTM عملية التعويض المقابلة لكل معاملة فرعية للتراجع، وبعد ذلك يتم إرجاع المعاملة بنجاح.

دعونا نتسبب عمدا في فشل المعاملة الفرعية الثانية ونشاهد ما يحدث

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

يمكننا أن نرى في وحدة التحكم أنه تم استدعاء الخدمات TransOut و TransIn و TransOutRevert

المزيد من الأمثلة

إذا كنت تريد المزيد من أمثلة البدء السريع، فيرجى الرجوع إلى dtm-labs/quick-start-sample

يوضح المثال أعلاه بشكل أساسي تدفق المعاملة الموزعة. المزيد عن هذا، بما في ذلك الأمثلة العملية لكيفية التفاعل مع قاعدة البيانات الفعلية، وكيفية التعويض، وكيفية التراجع، وما إلى ذلك. يرجى الرجوع إلى أمثلة dtm لمزيد من الأمثلة.

إعطاء نجمة!

إذا كنت تعتقد أن هذا المشروع مثير للاهتمام أو مفيد لك، فيرجى إعطاء نجمة!