当前位置: 首页 > news >正文

RV1126+FFMPEG推流项目(9)AI和AENC模块绑定,并且开启线程采集

        前面两篇已经交代AI和AENC模块的配置,这篇就让这两个模块绑定起来,绑定的原因是,Aenc从Ai模块拿到采集的原始数据进行编码。

        使用 RK_MPI_SYS_Bind 把 AI 节点和 AENC 进行绑定,其中 enModId 是模块 ID 号选择的是 RK_ID_AI、s32ChnId 是通道号,通道号则从容器 AENC 容器获取。开启 AENC 线程采集每一帧视频编码数据并存储到音频队列。

        绑定的函数是有rv1126通过的, RK_MPI_SYS_Bind,先来认识一下这个数据结构。

         看到RK_MPI_SYS_Bind的参数是两个需要绑定模块,这两个数据结构,在之前说视频模块绑定的时候,已经说过了这两个参数。这里我偷懒一下,不说了。

   
{//1.VI和VENC绑定//1.1定义出AI和AENC模块MPP_CHN_S ai_channel;MPP_CHN_S aenc_channel;//1.2先把容器里面的id获取出来RV1126_AI_CONTAINER ai_container;get_ai_container(0, &ai_container);RV1126_AENC_CONTAINER aenc_container;get_aenc_container(0, &aenc_container);ai_channel.s32ChnId = ai_container.ai_id;ai_channel.enModId = RK_ID_AI; //这里用的AI模块,选AIaenc_channel.s32ChnId = aenc_container.aenc_id;aenc_channel.enModId =  RK_ID_AENC;//这里用的AENC模块,选AENC//AI和VENC绑定ret = RK_MPI_SYS_Bind(&ai_channel, &aenc_channel);if(ret != 0){printf("AI和VENC绑定失败\n");}else{printf("AI和VENC绑定成功\n");}
}

        绑定之后就开启线程,开始获取一帧一帧数据包。

 //线程参数AENC_PROC_PARAM * aenc_proc_param = (AENC_PROC_PARAM*)malloc(sizeof(AENC_PROC_PARAM));aenc_proc_param->aenc_id = aenc_channel.s32ChnId;//2.创建AENC线程,获取音频编码数据pthread_t a_pid;ret = pthread_create(&a_pid, NULL,audio_aenc_thread,  (void*)aenc_proc_param);

线程处理流程:

//获取编码数据的线程
void* audio_aenc_thread(void* args)
{int ret;//线程分离,自己回收资源pthread_detach(pthread_self());MEDIA_BUFFER mb = NULL;定义一个媒体缓存区,用于接受编码器的输出数据AENC_PROC_PARAM* aenc_arg = static_cast<AENC_PROC_PARAM*> (args);free(args);//一直循环在这里拿数据while(1){//获取音频编码器的数据mb = RK_MPI_SYS_GetMediaBuffer(RK_ID_ADEC, aenc_arg->aenc_id, -1);if(!mb){printf("获取编码器数据失败\n");break; //推出循环}//获取成功printf("获取编码器数据成功\n");//为音频包分配一个内存audio_data_packet_t *audio_packet =(audio_data_packet_t*) malloc(sizeof(audio_data_packet_t));if(!audio_packet){perror("音频包分配内存失败\n");}memset(&audio_packet, 0, sizeof(audio_packet)); //清空内存//把拿到的音频编码数据拷贝packet包里面去memcpy(audio_packet, RK_MPI_MB_GetPtr(mb), RK_MPI_MB_GetSize(mb));//把包的长度拷贝进去audio_packet->audio_frame_size = RK_MPI_MB_GetSize(mb);//把packet放到队列里面去 audio_queue->putAudioPacketQueue(audio_packet);//释放缓存区,方便下一个包使用RK_MPI_MB_ReleaseBuffer(mb);}//到这里就是获取缓存区失败,或者编码器里面没有内容了//释放绑定的接口,和释放AI和AENC模块MPP_CHN_S ai_channel;MPP_CHN_S aenc_channel;ai_channel.enModId = RK_ID_AI;ai_channel.s32ChnId = 0 ;  //我只有一个是通道,如果有多个通道可以把ai的通道号一起传进来aenc_channel.enModId = RK_ID_AENC; aenc_channel.s32ChnId = aenc_arg->aenc_id; //AI的通道号已经被传了进来,所以不用在容器里面拿ret = RK_MPI_SYS_UnBind(&ai_channel, &aenc_channel);if(ret != 0 ){printf("解绑失败\n");}printf("解绑成功\n");ret = RK_MPI_AENC_DestroyChn(aenc_arg->aenc_id);if(ret != 0 ){printf("AENC销毁失败\n");}printf("AENC销毁成功\n");ret = RK_MPI_AI_DisableChn( 0 );if(ret != 0){printf("关闭AI模块势能失败\n");}printf("关闭AI模块势能成功\n");return nullptr;}

 

 

http://www.lryc.cn/news/522956.html

相关文章:

  • excel实用工具
  • 基于.Net Core+Vue的文件加密系统
  • 工业网口相机:如何通过调整网口参数设置,优化图像传输和网络性能,达到最大帧率
  • 深入理解 Windows Server 的核心功能:现代 IT 架构的基石
  • WEB渗透技术研究与安全防御
  • 智能学习平台系统设计与实现(代码+数据库+LW)
  • Java学习,List移动元素
  • Linux-----线程同步(资源竞争和同步锁)
  • 当当网书籍信息爬虫
  • React实现拖拽特效
  • 【竞技宝】LOL:ning直播再次锐评
  • ThreeJS能力演示——界面点选交互能力
  • flutter的web页面
  • 2025.1.17——三、SQLi regexp正则表达式|
  • 虚幻基础2:gameplay框架
  • 使用 Go 语言生成样式美观的 PDF 文件
  • 鸿蒙-点击Notification通知并打开App的具体页面
  • 非科班转码第5年零241天
  • 数据库:MongoDB命令行帮助解释
  • MongoDB单机版安装
  • Azure面试
  • 在.NET用C#将Word文档转换为HTML格式
  • macOS 安装JDK17
  • Django SimpleUI 自定义功能实战
  • C语言/C++自然序列重排列——相邻序号不相邻问题⭐
  • Spring boot面试题---- Spring boot项目运行原理
  • Qt/C++ 基于 QGraphicsView 的绘图软件 (附源码下载链接)
  • 如何使用 useMemo 和 memo 优化 React 应用性能?
  • 数据结构(链表 哈希表)
  • 人工智能之深度学习_[4]-神经网络入门