dtm

영어 | 简体中文

분산 트랜잭션 관리자

DTM이란 무엇입니까?

DTM은 서비스 간 최종 데이터 일관성을 제공하는 분산 트랜잭션 프레임워크입니다. 다양한 애플리케이션 시나리오에 대한 saga, tcc, xa, 2단계 메시지, 아웃박스, 워크플로우 패턴을 제공합니다. 또한 다음과 같이 거래를 구성하기 위해 여러 언어와 여러 상점 엔진을 지원합니다.

DTM을 사용하는 사람(일부)

텐센트

바이트댄스

아이비다드

더

특징

• 다양한 거래 모드 지원: SAGA, TCC, XA, Workflow, Outbox
• 다국어 지원: Go, Java, PHP, C#, Python, Nodejs용 SDK
• 더 나은 Outbox: 2단계 메시지, Outbox보다 더 우아한 솔루션, 다중 데이터베이스 지원
• 다중 데이터베이스 트랜잭션 지원: MySQL/MariaDB, Redis, MongoDB, Postgres, TDSQL 등
• 다양한 스토리지 엔진 지원: MySQL/MariaDB(공통), Redis(고성능), BoltDB(개발 및 테스트), MongoDB(계획 중)
• 여러 마이크로서비스 아키텍처 지원: go-zero, go-kratos/kratos, polarismesh/폴라리스
• 고가용성 및 손쉬운 수평 확장 지원

응용 시나리오.

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-examples를 참조하세요.

별을 줘!

이 프로젝트가 흥미롭거나 도움이 된다고 생각하시면 별점을 주세요!