架构实践：如何打造极致流畅的短剧 APP 连续播放与交易鉴权体验

// 首页 Feed 流获取逻辑示例 (Go)
func GetHomeFeed(ctx context.Context, lang string) (*HomeFeedResponse, error) {
    cacheKey := fmt.Sprintf("home_feed:v1:%s", lang)
    
    // 1. 尝试从 Redis 获取
    if cachedData, err := redisClient.Get(ctx, cacheKey).Result(); err == nil {
        var resp HomeFeedResponse
        json.Unmarshal([]byte(cachedData), &resp)
        return &resp, nil
    }

    // 2. 缓存未命中，查库并组装动态页面组件 (如 Banner, HotList, GuessYouLike)
    feed := buildFeedFromDB(lang)
    
    // 3. 异步写入缓存，设置较短的过期时间 (如 5 分钟) + 随机防击穿时间
    go func() {
        data, _ := json.Marshal(feed)
        ttl := time.Minute*5 + time.Duration(rand.Intn(60))*time.Second
        redisClient.Set(context.Background(), cacheKey, data, ttl)
    }()

    return feed, nil
}

// 服务端接收播放进度，利用 Redis Hash 结构高效存储
func SyncPlayProgress(ctx context.Context, userID, episodeID, progress int) error {
    hashKey := fmt.Sprintf("user_progress:%d", userID)
    
    // 使用 HSet 记录该用户各个剧集的进度
    err := redisClient.HSet(ctx, hashKey, fmt.Sprintf("%d", episodeID), progress).Err()
    
    // 异步投递 MQ，由消费者批量刷入 MySQL 持久化，削峰填谷
    publishToMQ("progress_sync_topic", SyncMsg{userID, episodeID, progress})
    
    return err
}

// 获取鉴权播放地址
func GetSecurePlayURL(userID, episodeID uint) (string, error) {
    ep := queryEpisodeInfo(episodeID)
    
    // 1. 如果是免费集，直接返回防盗链 URL
    if ep.UnlockType == 0 {
        return generateCDNSignedURL(ep.VideoPath, 2*time.Hour), nil
    }
    
    // 2. 检查是否是 VIP 且该剧支持 VIP 免费观看
    if ep.UnlockType == 1 && checkUserVIP(userID) {
        return generateCDNSignedURL(ep.VideoPath, 2*time.Hour), nil
    }
    
    // 3. 检查单集代币/钻石解锁记录
    if hasUnlocked(userID, episodeID) {
        return generateCDNSignedURL(ep.VideoPath, 2*time.Hour), nil
    }
    
    // 权限不足，返回特定的错误码，触发前端弹出充值/激励广告面板
    return "", errors.New("ERR_PAYMENT_REQUIRED")
}

// 广告平台服务端回调接口 (以通用签名为例)
func AdRewardCallback(c *gin.Context) {
    // 1. 获取回调参数与签名
    transID := c.Query("trans_id")
    sign := c.Query("sign")
    userID := c.Query("user_id") // 透传参数
    
    // 2. 校验签名防止伪造请求
    if !verifyAdSignature(transID, sign) {
        c.JSON(403, gin.H{"msg": "invalid signature"})
        return
    }
    
    // 3. 幂等性处理：检查 transID 是否已处理
    if !isTransProcessed(transID) {
        // 在数据库事务中：增加代币余额 + 记录资产流水
        executeRewardTransaction(userID, 100) 
        markTransProcessed(transID)
        
        // 4. (可选) 通过 WebSocket 通知客户端刷新余额/解除播放锁定，实现无缝续播
        notifyClientViaWS(userID, "REWARD_SUCCESS")
    }
    
    c.JSON(200, gin.H{"msg": "success"})
}