语音交友陪玩系统架构实战：多人语音房的麦位同步与底层治理

// 房间元数据结构示例 (Go)
type Room struct {
    RoomID      string    `json:"room_id" gorm:"primaryKey;type:varchar(32)"`
    OwnerID     string    `json:"owner_id" gorm:"index"`
    Title       string    `json:"title" gorm:"type:varchar(128)"`
    Category    int       `json:"category"` // 房间分类：兴趣、游戏、点唱等
    Tags        []string  `json:"tags" gorm:"serializer:json"` // JSON序列化存储标签
    Status      int       `json:"status"`   // 0: 待审核, 1: 活跃, 2: 封禁
    MaxMembers  int       `json:"max_members"`
    CreatedAt   time.Time `json:"created_at"`
}

// WebSocket 麦位状态同步信令 payload 示例
{
  "event": "MIC_STATE_CHANGE",
  "data": {
    "room_id": "room_1024",
    "mic_index": 2,          // 麦位序号
    "action": "LOCK_MIC",    // 操作动作: ON_MIC, OFF_MIC, MUTE, LOCK_MIC
    "user_id": "user_6789",
    "operator_id": "admin_01", // 房管ID，用于权限溯源
    "timestamp": 1693120000
  }
}

// 检查黑名单关系的通用函数
func CheckBlacklist(ctx context.Context, fromUserID, toUserID string) (bool, error) {
    redisKey := fmt.Sprintf("user:blacklist:%s", toUserID)
    // 利用 Redis SET O(1) 复杂度快速校验拦截
    isBlacklisted, err := redisClient.SIsMember(ctx, redisKey, fromUserID).Result()
    if err != nil {
        return false, err
    }
    return isBlacklisted, nil
}

// 技能服务订单状态机定义 (Go)
type OrderState int

const (
    OrderCreated    OrderState = iota // 0: 已创建 (等待接单)
    OrderAccepted                     // 1: 已接单 (服务中)
    OrderCompleted                    // 2: 已完成 (待评价)
    OrderCancelled                    // 3: 已取消 
    OrderDisputed                     // 4: 平台客服介入中
)

// 状态流转时，系统自动记录操作日志与时间戳，保障交易安全

// Gin 框架下的 RBAC 权限校验中间件
func RoleAuthMiddleware(requiredRoles ...string) gin.HandlerFunc {
    return func(c *gin.Context) {
        // 解析上下文中的 JWT Claims (已在上一层解析验证)
        userRole := c.GetString("userRole") 
        
        hasPermission := false
        for _, role := range requiredRoles {
            if userRole == role {
                hasPermission = true
                break
            }
        }
        
        if !hasPermission {
            c.JSON(http.StatusForbidden, gin.H{
                "code": 403,
                "msg":  "权限不足，无法执行当前管理操作",
            })
            c.Abort()
            return
        }
        c.Next()
    }
}