Go标准库和Echo框架不支持分布式事务，仅支持单库本地事务；跨服务需依赖DTM或Dapr等外部组件实现Saga模式，强调幂等性、事务上下文透传与补偿可靠性。
Go 标准库和 Echo 框架本身都不支持分布式事务 —— 它们只管 HTTP 生命周期和单库本地事务，跨服务协调必须靠外部组件。
为什么不能在 Echo 里用 db.BeginTx 实现分布式事务
Echo 的中间件或 handler 里调用 db.BeginTx 只会开启一个数据库连接上的本地事务，作用域严格限定在当前服务、当前 DB 实例内。哪怕你在多个 Echo 服务里都写了一套 BeginTx + Commit，只要网络中断、某个服务崩溃或超时，就会出现部分提交：订单创建成功但库存没扣减，或反过来。
常见错误现象：
-
context deadline exceeded后只 rollback 了本服务 DB，其他服务已 commit - 日志里反复出现
GlobalTransaction is not active—— 实际是事务上下文没透传，或 DTM/Dapr 的 sidecar 未响应 - 手动拼接多个
http.Post调用后统一判断结果，但无法回滚已成功的请求
在 Echo 服务中接入 Saga 模式（推荐 DTM 或 Dapr）
Echo 作为 HTTP 入口，最适合做 Saga 的参与者（Participant），而非协调器（Orchestrator）。你只需暴露幂等接口，由 DTM 或 Dapr 统一编排。
立即学习“go语言免费学习笔记（深入）”；
实操建议：
在 Go 中使用 google/wire 实现编译时依赖注入——wire.NewSet、wire.Build、wire.Bind（接口→实现）、wire.Struct、wire.Value、wire.Interface
- 每个 handler 必须校验
idempotency_key请求头或 body 字段，并在 DB 插入前加唯一索引：UNIQUE (idempotency_key) - 正向操作（如
CreateOrder）完成后，立即返回 HTTP 202 Accepted，不等待下游；补偿接口（如CancelOrder）必须独立可重试 - 用 Echo 中间件自动注入
trace_id和saga_id到 context，便于日志串联和问题定位 - 避免在 handler 内直接调用其他服务的 HTTP 接口 —— 改为发消息（如 Kafka）或交由 DTM 的
TransOut调度
DTM 客户端集成到 Echo 的关键步骤
DTM 是目前 Go 生态最成熟的 Saga 协调器，与 Echo 集成轻量且稳定（截至 2026 年 7 月，v1.12+ 已支持 gRPC 流式回调和自动死信投递）。
你需要做的不是“在 Echo 里写事务逻辑”，而是让 Echo 接口符合 DTM 的协议约定：
- 正向接口路径必须是
/api/your-service/try、/api/your-service/confirm、/api/your-service/cancel - 所有接口接收 JSON body，且必须返回标准结构：
{"result": "SUCCESS"}或{"result": "FAILURE", "message": "..."} - 在 Echo 的
POST /tryhandler 中，先执行本地事务（如插入 pending 状态订单），再调用dtmcli.MustGenGid获取全局事务 ID，最后写入saga_step_log表记录状态 - 确认/取消接口必须幂等：用
UPDATE ... WHERE id = ? AND status = 'pending'这类带条件的更新，防止重复执行
别碰 XA、2PC 和自研协调器
Go 社区没有生产级 XA 驱动支持 —— go-sql-driver/mysql 不暴露 xa_start 接口；所有号称“纯 Go 2PC 库”的实现，都缺乏 prepare 日志持久化和原子广播保障，线上极易出现悬挂事务（dangling transaction）。
典型翻车点：
- 用
gorilla/sessions存 transaction id：节点重启后丢失，无法恢复 - 自己用 Redis 实现协调器：网络分区时无法判断某 participant 是宕机还是延迟，只能盲目 abort
- 把 DTM 当作普通 HTTP client 封装进 Echo middleware：漏掉超时控制和重试策略，导致 saga 步骤卡死
真正要花精力的地方，从来不是“怎么写 Commit 函数”，而是补偿是否幂等、idempotency_key 是否贯穿全链路、失败后是否进了死信队列 —— 这些细节一旦漏掉，Saga 就退化成一堆不可靠的 HTTP 调用。
