2. Go语言并发基础回顾：goroutine、channel、sync包在事务协调中的角色

分布式事务的本质是跨多个独立资源（数据库、消息队列、服务）的状态协调。在Go语言中，这种协调能力直接依赖于语言内置的并发原语。本章回顾goroutine、channel和sync包的核心机制，并揭示它们在事务边界划分、协调者通信和资源锁管理中的具体角色。

2.1 goroutine：事务协调的轻量执行单元

goroutine是Go运行时管理的轻量级线程，初始栈仅几KB，创建和销毁成本极低。在分布式事务中，每个参与方（Participant）或协调者（Coordinator）都可以由一个独立的goroutine驱动，从而实现高效的并行协调。

2.2 channel：事务消息的管道与同步

channel是Go中goroutine之间通信的一等公民。在事务协调中，channel承担了三个核心职能：消息传递、结果聚合和信号同步。

• 消息传递： 协调者通过channel向参与者goroutine发送事务指令（prepare、commit、rollback）。
• 结果聚合： 参与者将本地事务结果（成功/失败）写入channel，协调者通过range或select收集所有结果。
• 信号同步： 使用无缓冲channel实现goroutine之间的“等待-通知”模式，确保事务阶段的有序推进。

// 示例：使用channel聚合2PC准备阶段结果
func preparePhase(participants []string) bool {
    resultCh := make(chan bool, len(participants))
    for _, p := range participants {
        go func(pid string) {
            // 模拟向参与者发送prepare请求
            ok := sendPrepare(pid)
            resultCh <- ok
        }(p)
    }
    // 聚合所有结果
    for i := 0; i < len(participants); i++ {
        if !<-resultCh {
            return false // 任一参与者失败，整体准备失败
        }
    }
    return true
}

2.3 sync包：事务资源的锁与协调

sync包提供了Mutex、RWMutex、WaitGroup、Once、Cond等同步原语。在分布式事务中，它们主要用于保护共享状态和控制并发访问。

// 示例：使用sync.Mutex保护事务状态表
type TransactionState struct {
    mu     sync.Mutex
    states map[string]string // txID -> "preparing"|"prepared"|"committed"|"aborted"
}

func (ts *TransactionState) SetState(txID, state string) {
    ts.mu.Lock()
    defer ts.mu.Unlock()
    ts.states[txID] = state
}

func (ts *TransactionState) GetState(txID string) string {
    ts.mu.Lock()
    defer ts.mu.Unlock()
    return ts.states[txID]
}

2.4 并发原语在事务协调中的协作模式

在实际的分布式事务框架中，goroutine、channel和sync包通常组合使用，形成稳定的协调模式。以下是最常见的三种模式：

• 扇出-聚合模式（Fan-Out/Fan-In）： 协调者goroutine扇出多个参与者goroutine，每个参与者执行本地操作后通过channel返回结果，协调者聚合所有结果后做出决策。这是2PC和TCC的核心模式。
• 流水线模式（Pipeline）： 事务的多个阶段（如验证→预留→提交）由不同的goroutine通过channel串联，每个阶段独立处理，适合Saga的编排模式。
• 超时控制模式： 使用select+time.After实现goroutine级别的超时控制，防止事务协调因网络故障而永久阻塞。

2.5 事务协调中的并发安全原则

在构建分布式事务框架时，以下并发安全原则必须贯穿始终：

1. 共享状态最小化： 事务协调中的共享状态（如事务表、锁记录）应集中管理，通过channel传递所有权，而非通过共享内存通信。
2. 锁粒度控制： 使用sync.Mutex保护关键状态时，锁定范围应仅限于内存操作，不包含网络I/O。
3. goroutine生命周期管理： 每个事务相关的goroutine必须有明确的退出路径（正常完成、超时、取消），避免goroutine泄漏。
4. 幂等性保障： 使用sync.Once确保提交/回滚操作只执行一次，防止网络重试导致的状态不一致。
5. 超时兜底： 所有channel操作都应配合select+time.After，防止goroutine永久阻塞。