通过AVAPIs的方式实作云存推流

一、核心说明

二、云存储模块初始化

// 读取云存储配置文件（gVsaasInfoFilePath：本地配置文件路径）
char *vsaas_info = NULL;
FILE *vsaas_info_file_ptr = fopen(gVsaasInfoFilePath, "r");
int ret = 0;

if (vsaas_info_file_ptr == NULL) {
    // 未配置：从APP端获取（通过VsaasConfigChangedHandle回调保存）
    printf("Enable VSaaS without preload data!\n");
    ret = avEnableVSaaS(
        device_ctx,                  // 设备上下文（提前初始化）
        NULL,                        // 无预加载配置
        VsaasConfigChangedHandle,    // 配置变更回调
        VSaaSUpdateContractInfoHandle// 合约信息更新回调
    );
} else {
    // 已配置：读取本地文件初始化
    long file_size = 0;
    fseek(vsaas_info_file_ptr, 0, SEEK_END);
    file_size = ftell(vsaas_info_file_ptr);
    rewind(vsaas_info_file_ptr);

    vsaas_info = (char*)malloc(sizeof(char)*file_size);
    if (vsaas_info == NULL) {
        printf("memory alloc fail!\n");
        fclose(vsaas_info_file_ptr);
        return -1;
    }
    
    fread(vsaas_info, 1, file_size, vsaas_info_file_ptr);
    ret = avEnableVSaaS(device_ctx, vsaas_info, VsaasConfigChangedHandle, VSaaSUpdateContractInfoHandle);
    
    fclose(vsaas_info_file_ptr);
    free(vsaas_info);
    gVsaasConfigExist = true;
}

if (ret != AV_ER_NoERROR) {
    printf("avEnableVSaaS error [%d]\n", ret);
    return -1;
}

三、通知云服务器取流

/* 参数说明：
 * starttime：实时流填"live"，回放流填时间戳（秒）
 * event_id：固定为 VSAAS_EVENT_GENERAL
 * event_file：回放流必填，指定本地录像文件路径
 * media_type：0=H264，1=H265，2=JPEG
 * channel：回放流必填，传入回放专用IOTC通道ID（避免avServStartEx超时）
 */
char att_json_str[256] = {0};
bool isLiveView = true;  // true=实时流，false=回放流
bool h264 = true;        // true=H264，false=H265
unsigned long current_time_sec = 1699999999;  // 回放起始时间戳
char *gRecordFile = "/mnt/record/20231114_100000.h264";  // 本地录像文件
int iotc_channel_id_for_playback = 1;  // 回放IOTC通道ID

if (isLiveView) {
    // 实时流模式
    sprintf(att_json_str, 
        "{\"starttime\":\"live\",\"protocol\":\"tutk\",\"event_id\":\"%d\",\"media_type\":\"%d\"}",
        VSAAS_EVENT_GENERAL,
        h264 ? 0 : 1
    );
} else {
    // 回放流模式
    sprintf(att_json_str, 
        "{\"starttime\":\"%lu\",\"protocol\":\"tutk\",\"event_id\":\"%d\",\"event_file\":\"%s\",\"media_type\":\"%d\",\"channel\":\"%d\"}",
        current_time_sec,
        VSAAS_EVENT_GENERAL,
        gRecordFile,
        h264 ? 0 : 1,
        iotc_channel_id_for_playback
    );
}

// 通知云服务器取流（超时3000ms）
Nebula_Json_Obj attr_obj = NULL;
Nebula_Json_Obj_Create_From_String(att_json_str, &attr_obj);
ret = avServNotifyCloudRecordStream(attr_obj, 3000, NULL);
printf("avServNotifyCloudRecordStream ret[%d]\n", ret);

if (ret != AV_ER_NoERROR) {
    // 错误处理（例：-20043=用户未购买云存储方案）
    printf("通知取流失败，错误码：%d\n", ret);
}

四、关键回调函数实现

static void VsaasConfigChangedHandle(const char *vsaas_config)
{
    printf("Enter %s\n", __func__);
    printf("收到云存储配置：\n%s\n", vsaas_config);

    // 保存配置到本地文件
    FILE *vsaas_info_file_ptr = fopen(gVsaasInfoFilePath, "w+");
    if (vsaas_info_file_ptr == NULL) {
        printf("%s：打开配置文件失败！路径：%s\n", __func__, gVsaasInfoFilePath);
        return;
    }

    fwrite(vsaas_config, 1, strlen(vsaas_config), vsaas_info_file_ptr);
    fclose(vsaas_info_file_ptr);
    gVsaasConfigExist = true;  // 标记已配置
}

// 全局变量：存储云存储合约信息
VSaaSContractInfo gVsaasContractInfo = {0};

static void VSaaSUpdateContractInfoHandle(const VSaaSContractInfo *contract_info)
{
    printf("Enter %s\n", __func__);
    // 打印合约信息
    printf("合约类型：%u\n", contract_info->contract_type);
    printf("最大录制时长：%d秒\n", contract_info->event_recording_max_sec);
    printf("最大帧率：%d fps\n", contract_info->video_max_fps);
    printf("最大码率：%d kbps\n", contract_info->recording_max_kbps);
    printf("最大分辨率：%dx%d\n", contract_info->video_max_width, contract_info->video_max_high);

    // 保存合约信息（设备端需按此调整录像参数）
    memcpy(&gVsaasContractInfo, contract_info, sizeof(VSaaSContractInfo));
}

五、注意事项

int ExPasswordAuthCallBackFn(const char *account, char *pwd, unsigned int pwd_buf_size)
{
    // 允许设备默认账号和 "vsaas" 账号认证
    if (strcmp(account, gAvAccount) != 0 && strcmp(account, "vsaas") != 0) {
        return -1;  // 账号不匹配
    }

    // 密码缓冲区长度校验
    if (pwd_buf_size <= strlen(gAvPassword)) {
        return -1;  // 缓冲区不足
    }

    // 填充密码
    strcpy(pwd, gAvPassword);
    return 0;  // 认证成功
}

六、优化策略（实时流模式）

1. 识别连接来源：判断 IOTC 连线是否为云服务器发起（通过账号 "vsaas" 区分）；
2. 标记 avIndex：记录该连接对应的音视频流索引（avIndex）；
3. 动态停止存储：检测到无需继续存储时，停止向该 avIndex 推送音视频数据；
4. 安全关闭连接：等待 avIndex 中缓存的流全部发送完成后，关闭连接。

七、参考资源

• TUTK AV SDK 3.3+ 官方文档 - AVAPIs 协议详细说明
• SDK Sample Code - 参考 AV_VSaaS_Server.c 完整实现
• TUTK 公版实时音视频协议对接指南 - 设备端基础协议适配
• TUTK 云存储错误码手册 - 常见错误码（如-20043）排查方案