2. Go语言基础回顾：Go模块管理、结构体与方法、接口与多态、错误处理机制

在构建《Go权限审计网关》之前，必须夯实Go语言的核心基础。本章聚焦于四个关键领域：模块管理、结构体与方法、接口与多态、错误处理机制。这些知识点是后续实现网关插件化架构、中间件链、审计日志收集与错误恢复的基石。

2.1 Go模块管理：从GOPATH到Go Modules

Go Modules（go mod）是Go 1.11引入的官方依赖管理方案，彻底取代了传统的GOPATH模式。在网关项目中，我们将使用模块来管理核心库、插件接口和第三方依赖。

# 初始化模块
go mod init github.com/your-org/go-auth-gateway

# 添加依赖
go get github.com/gin-gonic/gin@v1.9.1

# 整理依赖
go mod tidy

# 创建vendor目录
go mod vendor

2.2 结构体与方法：定义网关核心模型

结构体是Go语言组织数据的主要方式，方法则赋予结构体行为。在权限审计网关中，结构体用于定义请求上下文、审计日志、用户会话等核心模型。

2.2.1 结构体定义与标签

// AuditLog 审计日志结构体
type AuditLog struct {
    ID        string    `json:"id" bson:"_id"`
    UserID    string    `json:"user_id" bson:"user_id"`
    Action    string    `json:"action" bson:"action"`     // 如 "LOGIN", "API_CALL"
    Resource  string    `json:"resource" bson:"resource"` // 如 "/api/v1/data"
    Status    int       `json:"status" bson:"status"`     // HTTP状态码
    Timestamp time.Time `json:"timestamp" bson:"timestamp"`
    Metadata  map[string]interface{} `json:"metadata,omitempty" bson:"metadata,omitempty"`
}

2.2.2 值接收者与指针接收者

// 值接收者：只读方法
func (a AuditLog) String() string {
    return fmt.Sprintf("[%s] %s - %s", a.Timestamp.Format(time.RFC3339), a.UserID, a.Action)
}

// 指针接收者：修改状态
func (a *AuditLog) SetStatus(code int) {
    a.Status = code
}

2.3 接口与多态：构建插件化审计架构

接口是Go实现多态的核心机制。在网关中，接口用于定义审计存储、认证策略、权限校验等抽象行为，使得我们可以轻松替换实现（如从MySQL切换到MongoDB存储审计日志）。

2.3.1 接口定义与隐式实现

// AuditStore 审计日志存储接口
type AuditStore interface {
    Save(ctx context.Context, log *AuditLog) error
    Query(ctx context.Context, filter map[string]interface{}) ([]AuditLog, error)
    Close() error
}

// MySQLStore 实现了 AuditStore 接口
type MySQLStore struct {
    db *sql.DB
}

func (m *MySQLStore) Save(ctx context.Context, log *AuditLog) error {
    // 实现MySQL写入逻辑
    return nil
}

func (m *MySQLStore) Query(ctx context.Context, filter map[string]interface{}) ([]AuditLog, error) {
    // 实现MySQL查询逻辑
    return nil, nil
}

func (m *MySQLStore) Close() error {
    return m.db.Close()
}

2.3.2 空接口与类型断言

空接口interface{}可以承载任何类型。在网关中，它常用于处理不确定类型的配置或元数据。

// 使用空接口存储任意类型的元数据
type RequestContext struct {
    UserID   string
    Metadata map[string]interface{} // 可存储任意类型
}

// 类型断言示例
func extractUserID(ctx *RequestContext) (string, error) {
    if val, ok := ctx.Metadata["user_id"]; ok {
        if userID, ok := val.(string); ok {
            return userID, nil
        }
        return "", fmt.Errorf("user_id is not a string")
    }
    return "", fmt.Errorf("user_id not found")
}

2.4 错误处理机制：构建健壮的审计链路

Go的错误处理哲学是显式而非异常。在网关中，每个可能失败的调用都必须检查错误，确保审计日志不丢失、权限校验不绕过。

2.4.1 基本错误处理模式

// 标准错误返回模式
func (s *MySQLStore) Save(ctx context.Context, log *AuditLog) error {
    if log == nil {
        return fmt.Errorf("audit log cannot be nil")
    }
    // 执行数据库操作
    _, err := s.db.ExecContext(ctx, "INSERT INTO audit_logs (...) VALUES (...)", ...)
    if err != nil {
        return fmt.Errorf("save audit log failed: %w", err) // 使用 %w 包装错误
    }
    return nil
}

// 调用方必须检查错误
if err := store.Save(ctx, auditLog); err != nil {
    // 记录错误，但不应中断主流程
    log.Printf("failed to save audit log: %v", err)
    // 可考虑写入备用存储或本地文件
}

2.4.2 自定义错误类型与错误链

// 自定义错误类型
type AuditError struct {
    Code    int    // 错误码：1001=存储失败, 1002=序列化失败
    Message string
    Err     error  // 原始错误
}

func (e *AuditError) Error() string {
    return fmt.Sprintf("[%d] %s: %v", e.Code, e.Message, e.Err)
}

func (e *AuditError) Unwrap() error {
    return e.Err
}

// 使用 errors.Is 和 errors.As 进行错误链判断
func handleAuditError(err error) {
    var auditErr *AuditError
    if errors.As(err, &auditErr) {
        switch auditErr.Code {
        case 1001:
            // 存储失败，尝试重试或切换存储
        case 1002:
            // 序列化失败，记录并跳过
        }
    }
}

2.4.3 panic与recover：网关的防御性编程

在网关中，panic应仅限于不可恢复的错误（如初始化失败）。在HTTP处理链中，使用recover防止单个请求崩溃整个服务。

// 中间件中的recover示例
func RecoveryMiddleware() gin.HandlerFunc {
    return func(c *gin.Context) {
        defer func() {
            if err := recover(); err != nil {
                // 记录panic堆栈
                log.Printf("panic recovered: %v\n%s", err, debug.Stack())
                // 返回500错误，不暴露内部信息
                c.AbortWithStatusJSON(http.StatusInternalServerError, gin.H{
                    "error": "internal server error",
                })
            }
        }()
        c.Next()
    }
}

2.5 本章小结