如何用Golang处理分布式事务 Saga模式实现-Golang-PHP中文网

如何用Golang处理分布式事务 Saga模式实现

P粉602998670

发布： 2025-08-18 16:18:02

原创

317人浏览过

Saga模式通过将长事务拆分为多个带补偿操作的本地事务来解决分布式事务问题，Golang结合协调式Saga与消息队列可实现高可靠、易维护的分布式事务系统。

如何用golang处理分布式事务 saga模式实现

在分布式系统中，事务的处理比单体应用复杂得多。当一个业务操作需要跨多个微服务完成时，传统的两阶段提交（2PC）往往不适用，因为会带来性能瓶颈和系统耦合。Saga 模式是一种解决分布式事务的常用方案，Golang 凭借其高并发和简洁的语法，非常适合实现这一模式。

什么是 Saga 模式

Saga 模式将一个长事务拆分为多个本地事务，每个本地事务都有对应的补偿操作。如果某个步骤失败，就通过执行前面已成功步骤的逆向操作来回滚整个流程。

它有两种实现方式：

编排式（Choreography）：各个服务通过事件驱动通信，没有中心控制器。
协调式（Orchestration）：由一个中心协调器控制事务的流程和补偿逻辑。

在实际项目中，协调式更常见，也更容易维护和调试。

立即学习“go语言免费学习笔记（深入）”；

使用 Golang 实现协调式 Saga

我们以一个简单的电商下单场景为例：创建订单 → 扣减库存 → 扣减账户余额。任意一步失败，都要触发补偿操作。

定义事务步骤和补偿函数：

Getfloorplan

创建 2D、3D 平面图和 360° 虚拟游览，普通房间变成梦想之家

148

查看详情

type Step struct {
    Action   func() error
    Compensate func() error
}
<p>type Saga struct {
Steps []Step
}</p>

登录后复制

添加执行逻辑：

func (s *Saga) Execute() error {
    var executed []int
    for i, step := range s.Steps {
        if err := step.Action(); err != nil {
            // 触发补偿，逆序执行
            for j := len(executed) - 1; j >= 0; j-- {
                s.Steps[executed[j]].Compensate()
            }
            return err
        }
        executed = append(executed, i)
    }
    return nil
}

登录后复制

使用示例：

saga := &Saga{
    Steps: []Step{
        {
            Action: func() error { return createOrder() },
            Compensate: func() error { return cancelOrder() },
        },
        {
            Action: func() error { return deductStock() },
            Compensate: func() error { return restoreStock() },
        },
        {
            Action: func() error { return deductBalance() },
            Compensate: func() error { return refundBalance() },
        },
    },
}
<p>if err := saga.Execute(); err != nil {
log.Printf("Saga 执行失败: %v", err)
}</p>

登录后复制