# metaIPC2_jz

**Repository Path**: metartc/metaIPC2_jz

## Basic Information

- **Project Name**: metaIPC2_jz
- **Description**: 君正Ingenic metaIPC2.0基于mqtt通信，基于libyangpeerconnection7开发，支持基于IPC的AI二次开发，支持多路并发，支持浏览器/微信等视频直播远程控制等功能。
- **Primary Language**: C
- **License**: Not specified
- **Default Branch**: main
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 1
- **Created**: 2025-06-03
- **Last Updated**: 2025-08-14

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# libyangpeerconnection7

**FILE:libyangpeerconnection7_jz_720.7z**

libyangpeerconnection7是一个实现P2P媒体传输/数据通道的一个轻量级的webRTC库，基于metaRTC7.0的传输模块构建，支持H264/H265视频编码，通过 P2P 连接为用户提供高效、低延迟的音视频和数据通信。

君正版libyangpeerconnection7可适用于t31/x2000等多个君正SOC系列，助力基于君正webRTC P2P应用快速开发。

# 君正Ingenic metaIPC2 SDK

**FILE:metaIPC2_jz_720.7z**

君正Ingenic metaIPC2.0 sdk基于mqtt通信，基于libyangpeerconnection7开发，支持基于IPC的AI二次开发，支持多路并发，支持浏览器/微信等视频直播远程控制等功能

# **libyangpeerconnection7编程指南**

## 依赖文件

### 头文件

YangPeerConnection7.h

### 库文件

libyangpeerconnection7.so

## 示例代码

### 对象分配与释放

YangPeerConnection7* peer = (YangPeerConnection7*)calloc(1, sizeof(YangPeerConnection7));

YangPeerInfo* peerInfo=&peer->peer.peerInfo;

yang_init_peerParam(peerInfo);

peerInfo->uid = uid;

peerInfo->userId=userId;//查看配置文件sys/userId

peerInfo->direction = YangSendonly;

peerInfo->rtc.rtcLocalPort = 16000;

peerInfo->rtc.isControlled = yangtrue;

peerInfo->rtc.iceCandidateType = 2;

peerInfo->pushAudio.sample = 8000;

peerInfo->pushAudio.channel = 1;

peerInfo->pushAudio.audioEncoderType = Yang_AED_PCMA;

peerInfo->pushVideo.width = 1280;

peerInfo->pushVideo.height = 720;

peerInfo->pushVideo.fps = 30;

peerInfo->pushVideo.videoEncoderType = Yang_VED_H264;

peerInfo->rtc.iceServerPort=3478;

strcpy(peerInfo->rtc.iceServerIP, "192.168.0.104");

strcpy(peerInfo->rtc.iceUserName, "metartc");

strcpy(peerInfo->rtc.icePassword, "metartc");

peer->peer.peerCallback.sslCallback.context = session;

peer->peer.peerCallback.sslCallback.sslAlert = ipc_rtcrecv_sslAlert;

peer->peer.peerCallback.recvCallback.context = session;

peer->peer.peerCallback.recvCallback.receiveAudio = ipc_rtcrecv_receiveAudio;

peer->peer.peerCallback.recvCallback.receiveVideo = ipc_rtcrecv_receiveVideo;

peer->peer.peerCallback.recvCallback.receiveMsg = ipc_rtcrecv_receiveMsg;

peer->peer.peerCallback.iceCallback.context = session;

peer->peer.peerCallback.iceCallback.onConnectionStateChange=ipc_onConnectionStateChange;

peer->peer.peerCallback.iceCallback.onIceStateChange=ipc_onIceStateChange;

peer->peer.peerCallback.iceCallback.onIceCandidate=ipc_onIceCandidate;

yang_create_peerConnection7(peer);

peer->addAudioTrack(&peer->peer,Yang_AED_PCMA);

peer->addVideoTrack(&peer->peer,Yang_VED_H264);

peer->addTransceiver(&peer->peer,YangMediaAudio,peer->peer.peerInfo.direction);

peer->addTransceiver(&peer->peer,YangMediaVideo,peer->peer.peerInfo.direction);

//通过信令取得对端sdp

if((ret = peer->setRemoteDescription(&peer->peer, sdp))!=Yang_Ok){

goto cleanup;

}

//取得answer通过信令传回对端

if((ret = peer->createAnswer(&peer->peer, answer))!=Yang_Ok){

goto cleanup;

}

//free peer

if(peer){

    yang_destroy_peerConnection7(peer);

    free(peer);

}

### 交换Candidate

//通过信令取得对端candidate

rtc->addIceCandidate(&rtc->peer,candidate);

//回调函数
static void ipc_onIceCandidate(void* context, int32_t uid,char* sdp){
    if (context == NULL) return;
    //取得candidate 通过信令传到对端
}

### 回调函数

static void ipc_onConnectionStateChange(void* context, int32_t uid,YangRtcConnectionState connectionState){

if (context == NULL) return;

switch(connectionState){

case Yang_Conn_State_Connecting:{

break;

}

case Yang_Conn_State_Connected:{

break;

}

case Yang_Conn_State_Disconnected:{

break;

}

case Yang_Conn_State_Failed:{

//yang_trace("\nYang_Conn_State_Failed remove uid==%d",uid);

//removePeer(uid);

break;

}

case Yang_Conn_State_Closed:{

break;

}

default:break;

}

}

static void ipc_onIceStateChange(void* context,int32_t uid,YangIceCandidateState iceState){

if (context == NULL) return;

switch(iceState){

case YangIceSuccess:{

break;

}

case YangIceFail:{

//yang_trace("\nYangIceFail remove uid==%d",uid);

break;

}

default:break;

}

}

static void ipc_onIceCandidate(void* context, int32_t uid,char* sdp){

    if (context == NULL) return;

    //取得candidate 传到对端

}

static void ipc_rtcrecv_sslAlert(void *context, int32_t uid, char *type, char *desc) {

    if (context == NULL || type == NULL || desc == NULL)

        return;

    if (yang_strcmp(type, "warning") == 0 && yang_strcmp(desc, "CN") == 0) {

        removePeer( uid);

    }

}

static void ipc_rtcrecv_receiveAudio(void *user, YangFrame *audioFrame) {

    if (user == NULL || audioFrame == NULL)

    return;

}

static void ipc_rtcrecv_receiveVideo(void *user, YangFrame *videoFrame) {

    if (user == NULL || videoFrame == NULL)

    return;

}

static void ipc_rtcrecv_receiveMsg(void *user, YangFrame *msgFrame) {

    if (user == NULL) return;

  //  receiveMsg(msgFrame->uid,msgFrame->payload,msgFrame->nb);

}

### 推流

//YangFrame payload 数据 nb:数据长度 

//frametype:YANG_Frametype_I I帧  四字节sps长度+sps+四字节pps长度+pps+四字节I帧//长度+I帧 如：00,00,00,0e,67,42,c0,1f,8c,8d,40,50,1e,d0,0f,08,84,6a,00,00,00,04,68,ce,3c,80,00,00,00,01,65,b8,00,04,00,00,13,88,c5

//YANG_Frametype_P非I帧 如：00,00,00,01,61,e0,00,40,00,be,41,38,22,93,df

//去掉start code 00,00,00,01,取61,e0,00,40,00,be,41,38,22,93,df

rtc->on_video(&rtc->peer, frame)://推视频

rtc->on_audio(&rtc->peer, frame);//推音频