2. Go 接口契约基础：接口定义、实现、空接口与类型断言

在分布式事务画布中，每个参与者节点（如 TM、RM、资源锁）都需要对外暴露一组可调用的操作。Go 语言的接口（interface）正是定义这种调用契约的最佳工具。本章从接口的声明、隐式实现、空接口的泛型能力到类型断言的运行时安全检测，建立你在分布式事务代码中编写接口契约的基础。

2.1 接口定义：声明一组方法签名

Go 的接口是一组方法签名的集合。任何类型只要实现了接口中声明的所有方法，就自动满足该接口——无需显式声明 implements 关键字。这种“鸭子类型”风格让分布式事务中的组件替换变得极其灵活。

type 接口名 interface {
    方法名1(参数列表) (返回值列表)
    方法名2(参数列表) (返回值列表)
    // ...
}

以下是一个分布式事务中“资源管理器”的接口定义示例：

// ResourceManager 定义资源管理器必须实现的契约
type ResourceManager interface {
    // Prepare 准备阶段：锁定资源并记录 undo/redo 日志
    Prepare(txID string) (bool, error)
    // Commit 提交阶段：持久化变更并释放锁
    Commit(txID string) error
    // Rollback 回滚阶段：根据 undo 日志恢复数据
    Rollback(txID string) error
    // Status 查询事务状态
    Status(txID string) (TxStatus, error)
}

2.2 接口实现：隐式满足契约

任何类型只要拥有接口中所有方法，就自动实现了该接口。这种隐式实现让分布式事务中的 mock 测试、组件替换变得极其自然。

// MySQLResource 实现了 ResourceManager 接口
type MySQLResource struct {
    db *sql.DB
}

func (m *MySQLResource) Prepare(txID string) (bool, error) {
    // 实际实现：开启本地事务、锁定行、写 undo 日志
    return true, nil
}

func (m *MySQLResource) Commit(txID string) error {
    // 实际实现：提交本地事务、释放锁
    return nil
}

func (m *MySQLResource) Rollback(txID string) error {
    // 实际实现：根据 undo 日志回滚、释放锁
    return nil
}

func (m *MySQLResource) Status(txID string) (TxStatus, error) {
    // 实际实现：查询事务状态表
    return Prepared, nil
}

// 编译时检查：确保 MySQLResource 满足 ResourceManager
var _ ResourceManager = (*MySQLResource)(nil)

2.3 空接口：任意类型的容器

interface{}（Go 1.18 起也可写作 any）是没有任何方法签名的接口，因此所有类型都隐式实现了它。在分布式事务画布中，空接口常用于以下场景：

• 事务上下文传递：携带任意类型的业务载荷
• 异构数据存储：资源管理器返回的未定型状态
• 回调函数参数：允许用户传入任意类型的参数

// TransactionContext 事务上下文，携带任意类型的业务数据
type TransactionContext struct {
    TxID    string
    Payload interface{} // 可以是订单结构体、JSON 字节流、或自定义类型
}

// 使用示例
ctx := TransactionContext{
    TxID:    "tx-20250321-001",
    Payload: map[string]string{"account": "alice", "amount": "100"},
}

2.4 类型断言：从接口中提取具体类型

当从空接口或更宽泛的接口中获取具体类型时，需要使用类型断言。类型断言有两种形式：

// 从空接口中提取具体类型
func HandlePayload(payload interface{}) {
    // 安全断言：推荐使用双返回值形式
    if m, ok := payload.(map[string]string); ok {
        fmt.Printf("账户: %s, 金额: %s\n", m["account"], m["amount"])
        return
    }

    // 也可以使用 type switch
    switch v := payload.(type) {
    case string:
        fmt.Println("字符串载荷:", v)
    case []byte:
        fmt.Println("字节载荷, 长度:", len(v))
    default:
        fmt.Println("未知载荷类型")
    }
}

2.5 接口契约在分布式事务中的角色

下面的 SVG 展示了接口契约如何将分布式事务的参与者解耦：

2.6 接口组合：构建复杂契约

Go 支持接口嵌套组合，这在分布式事务中非常有用。例如，一个“可恢复的资源管理器”可以组合基础接口和恢复接口：

// Recoverable 定义恢复能力
type Recoverable interface {
    Recover(txID string) error
}

// RecoverableResourceManager 组合了基础契约和恢复契约
type RecoverableResourceManager interface {
    ResourceManager
    Recoverable
}

// 实现组合接口
type PostgresResource struct{ /* ... */ }

func (p *PostgresResource) Prepare(txID string) (bool, error) { return true, nil }
func (p *PostgresResource) Commit(txID string) error          { return nil }
func (p *PostgresResource) Rollback(txID string) error        { return nil }
func (p *PostgresResource) Status(txID string) (TxStatus, error) { return Prepared, nil }
func (p *PostgresResource) Recover(txID string) error         { return nil }

// 编译时检查组合接口
var _ RecoverableResourceManager = (*PostgresResource)(nil)

2.7 常见陷阱与避坑指南

• nil 接口 vs nil 具体值：一个接口变量在具体值为 nil 但类型不为 nil 时，接口本身不等于 nil。这是分布式事务中常见的 bug 来源。
• 接口太大：一个接口包含超过 5 个方法时，应考虑拆分为更小的接口（接口隔离原则）。
• 类型断言 panic：在分布式事务的恢复路径中，务必使用双返回值形式，避免 panic 导致整个节点崩溃。

func GetResource() ResourceManager {
    var m *MySQLResource = nil
    return m  // 返回的接口不是 nil！类型信息 (*MySQLResource, nil) 存在
}

func main() {
    rm := GetResource()
    if rm == nil {  // 永远为 false！
        fmt.Println("资源未初始化")
    }
}

2.8 本章小结