GB28181设备对接视频流的流程

news2024/11/18 21:43:11

搭建CG28181 服务端，也即 SIP Server，这正是我们要实现的。实现CG28181服务端可以借助于现有的开源库 PJSIP，具体的实现步骤如下：

1、启动GB28181服务端，接收客户端消息请求

bool Init(std::string concat, int logLevel)
{
    this->concat = concat;
    pj_log_set_level(logLevel);
    auto status = pj_init();
    status = pjlib_util_init();
    pj_caching_pool_init(&cachingPool, &pj_pool_factory_default_policy, 0);
    status = pjsip_endpt_create(&cachingPool.factory, nullptr, &endPoint);
    status = pjsip_tsx_layer_init_module(endPoint);
    status = pjsip_ua_init_module(endPoint, nullptr);
    pool = pj_pool_create(&cachingPool.factory, "proxyapp", 4000, 4000, nullptr);
    auto pjStr =StrToPjstr(GetAddr());
    pj_sockaddr_in pjAddr;
    pjAddr.sin_family = pj_AF_INET();
    pj_inet_aton(&pjStr, &pjAddr.sin_addr);
    auto port = GetPort();
 
    pjAddr.sin_port = pj_htons(static_cast<pj_uint16_t>(GetPort()));
　　　　status = pjsip_udp_transport_start(endPoint, &pjAddr, nullptr, 1, nullptr);
      if (status != PJ_SUCCESS) return status;
      auto realm = StrToPjstr(GetLocalDomain());
      return pjsip_auth_srv_init(pool, &authentication, &realm, lookup, 0) == PJ_SUCCESS ? true : false;
}

以上是PJSip初始化的代码，需要将服务将要监听的端口传给PJSIP,这样服务就在监听的端口接收SIP 消息了。

2、应答注册消息

        摄像机端发送来Register消息后，如果服务端不应答，摄像机端会一直发送直到收到服务端应答为止。如果服务器端重新运行，需要手动再次开启设备。

服务端应答注册消息代码如下：

bool OnReceive(pjsip_rx_data* rdata) override
{
    if(rdata->msg_info.cseq->method.id == PJSIP_REGISTER_METHOD)
    {
    　　auto expires = static_cast<pjsip_expires_hdr*>(pjsip_msg_find_hdr(rdata->msg_info.msg, PJSIP_H_EXPIRES, nullptr));
    　　auto authHdr = static_cast<pjsip_authorization_hdr*>(pjsip_msg_find_hdr(rdata->msg_info.msg, PJSIP_H_AUTHORIZATION, nullptr));
    　　if(expires && expires->ivalue > 0 )
    　　{
               if(authHdr)
               { 
        　　cout <<"receive register info"<<endl;
        　　response(rdata, PJSIP_SC_OK, DateHead);
        　　QureryDeviceInfo(rdata);
               }
            else
             {
        　　response(rdata, PJSIP_SC_UNAUTHORIZED, AuthenHead);
              }
              return true;  
    　　}
    }
     return false;
}

 OnReceive 是服务端接收注册消息以后的响应方法，也就是说要将OnReceive作为入参传给PJSIP，完成此项功能在初始化<br>PJSIP Moudle时。至于PJSIP moudle，细节的话，可以查看PJSIP文档，代码如下：

bool  Init(std::string concat, int loglevel)
{
　　bool ret = false;
 
  if(!mainModule)
　{
    ret = context.Init(concat,loglevel);
    if(!ret) return ret;
    static struct pjsip_module moudle =
    {
    　　nullptr, 
    nullptr,
      { "MainModule", 10 },
      -1,
     PJSIP_MOD_PRIORITY_APPLICATION,
     nullptr,
     nullptr,
     nullptr,
     nullptr,
     nullptr,
    &CGSipMedia::OnReceive,
    nullptr,
    nullptr,
    nullptr,
 
    };
    mainModule = &moudle;
    pjsip_inv_callback callback;
    pj_bzero(&callback, sizeof(callback));
    callback.on_state_changed = &onStateChanged;
    callback.on_new_session = &onNewSession;
    callback.on_tsx_state_changed = &onTsxStateChanged;
    callback.on_rx_offer = &onRxOffer;
    callback.on_rx_reinvite = &onRxReinvite;
    callback.on_create_offer = &onCreateOffer;
    callback.on_send_ack = &onSendAck;
    ret = context.RegisterCallback(&callback);
    if(!ret ) return ret;
    context.InitModule();
    ret  = context.RegisterModule(mainModule);
    if(!ret ) return ret;
    CGSipModule::GetInstance().Init();
    ret = context.CreateWorkThread(&proc,workthread,nullptr,"proxy");
    }
    return ret;
    }

 OnReceive方法内Resonse方法实现了发送响应数据到客户端(设备):

  接到PJSIP发送一些字符串给客户端:

void  Response(pjsip_rc_data* rdata, int st_code, int headType)
{
std::lock_guard<mutex> lk(lock);
pjsip_tx_data* tdata;
pjsip_endpt_create_response(endPoint, rdata, st_code, nullptr, &tdata);
auto date = DateTimeFormatter::format(LocalDateTime(), "Y-%m-%dT%H:%M:%s");
pj_str_t c;
pj_str_t key;
pjsip_hdr * hdr;
switch(headType)
{
case  DateHead:
key = pj_str("Date");
hdr = reinterpret_cast<pjsip_hdr*>(pjsip_date_hdr_create(poll, &key, pj_cstr(&c, date.c_str())));
pjsip_msg_add_hdr(tdata->msg, hdr);
break;
case AuthenHead:
       pjsip_auth_srv_challenge(&authentication, nullptr, nullptr, nullptr, PJ_FALSE, tdata);
break;
default:
break;
}
          pjsip_response_addr addr;
          pjsip_get_response_addr(pool, rdata, &addr);
   pjsip_endpt_send_response(endPoint, &addr, tdata, nullptr, nullptr);
 
}

SIP服务端响应注册命令后，发送Invite请求，请求catalog信息，也就是设备基本信息，具体的方法上面已

给出，具体的内容是：

bool OnReceive(pjsip_rx_data* rdata) override
{
　　if (rdata->msg_info.cseq->method.id == PJSIP_OTHER_METHOD)
　　{
  	      CGXmlParser xmlParser(context.GetMessageBody(rdata));
CGDynamicStruct dynamicStruct;
               dynamicStruct.Set(xmlParser.GetXml());
               auto cmd = xmlParser.GetXml()->firstChild()->nodeName();
               auto cmdType = dynamicStruct.Get<std::string>("CmdType");
               if (cmdType != "Catalog") return false;
              auto DeviceID = dynamicStruct.Get<std::string>("DeviceID");
             Vector deviceList = dynamicStruct.Get<Vector>("DeviceList");
    for (auto& x : deviceList)
    {
    　　CGCatalogInfo devinfo;
    try
    {
    　　devinfo.PlatformAddr = rdata->pkt_info.src_name;
    　　devinfo.PlatformPort = rdata->pkt_info.src_port;
    　　devinfo.Address = x["Address"].convert<string>();
    　　devinfo.Name = WstringToString(x["Name"].convert<wstring>());
    　　devinfo.Manufacturer = x["Manufacturer"].convert<string>();
    　　devinfo.Model = x["Model"].convert<string>();
    　　devinfo.Owner = x["Owner"].convert<string>();
    　　devinfo.Civilcode = x["CivilCode"].convert<string>();
    　　devinfo.Registerway = x["RegisterWay"].convert<int>();
    　　devinfo.Secrecy = x["Secrecy"].convert<int>();
    　　//devinfo.IPAddress = x["IPAddress"].convert<string>();
    　　devinfo.DeviceID = x["DeviceID"].convert<string>();
    　　devinfo.Status= x["Status"].convert<string>();
    }
    catch (...)
    {
        //continue;
    }
    if(callback)
    {
        callback(user, &devinfo);
    }
  	  //SipControlModule::GetInstance().CatalogCallBack(devinfo);
  }
    response(rdata, PJSIP_SC_OK,NoHead);
    return true;
}

SIP服务端获取设备端的信息后就可以发送请求视频信息了，请求视频最为关键的是SDP，下面看下SDP信息如何填写：

static string createSDP(MediaContext& mediaContext)
{
    char str[500] = { 0 };
    pj_ansi_snprintf(str, 500,
    "v=0\n"
    "o=%s 0 0 IN IP4 %s\n"
    "s=Play\n"
    "c=IN IP4 %s\n"
    "t=0 0\n"
    "m=video %d RTP/AVP 96 98 97\n"
    "a=recvonly\n"
    "a=rtpmap:96 PS/90000\n"
    "a=rtpmap:98 H264/90000\n"
    "a=rtpmap:97 MPEG4/90000\n"
    "y=0100000001\n",
    mediaContext.GetDeviceId().c_str(),
    mediaContext.GetRecvAddress().c_str(),
    mediaContext.GetRecvAddress().c_str(),
    mediaContext.GetRecvPort()
    );
    return str;
}

发送请求视频命令到设备端也是通过PJSIP API实现，实现代码如下：

bool Invite(pjsip_dialog *dlg, MediaContext mediaContext, string sdp)

{

pjsip_inv_session *inv;

if (PJ_SUCCESS != pjsip_inv_create_uac(dlg, nullptr, 0, &inv)) return false;

pjsip_tx_data *tdata;

if (PJ_SUCCESS != pjsip_inv_invite(inv, &tdata)) return false;

pjsip_media_type type;

type.type = pj_str("application");

type.subtype = pj_str("sdp");

auto text = pj_str(const_cast<char *>(sdp.c_str()));

try

{

tdata->msg->body = pjsip_msg_body_create(pool, &type.type, &type.subtype, &text);

auto hName = pj_str("Subject");

auto subjectUrl = mediaContext.GetDeviceId() + ":" + SiralNum + "," + GetInstance().GetCode() + ":" + SiralNum;

auto hValue = pj_str(const_cast<char*>(subjectUrl.c_str()));

auto hdr = pjsip_generic_string_hdr_create(pool, &hName, &hValue);

pjsip_msg_add_hdr(tdata->msg, reinterpret_cast<pjsip_hdr*>(hdr));

pjsip_inv_send_msg(inv, tdata);

}

catch (...)

{

}

return true;

}

 设备端收到Invite请求后，会将视频数据以rtp的方式推送到指定的端口，端口在invite消息指定。这样在指定的地址（ip + port）就可以拿到数据了。

交流联系：

微信：

LiveMedia视频汇聚平台www.houhangkeji.com

QQ技术交流群：698793654

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1210805.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

Unity中使用VS常用技巧

Unity中使用VS常用技巧

文章目录 1、Unity预览代码中文显示乱码解决方案2、VS中格式化代码快捷键 1、Unity预览代码中文显示乱码解决方案 ①打开VS&#xff0c;在 扩展 中找到 管理扩展 打开 ②在 管理扩展面板 联机 中搜索 Force UTF-8(No BOM) &#xff0c;点击下载即可 ③重启VS 如果以前编写的脚…
阅读更多...
本地顺风车小程序源码系统 源码开源可二次开发 出行无忧：一键预约顺风车 带完整搭建教程

本地顺风车小程序源码系统 源码开源可二次开发 出行无忧：一键预约顺风车 带完整搭建教程

共享经济和互联网技术的发展。随着人们出行需求的不断增加&#xff0c;顺风车作为一种绿色、共享的出行方式&#xff0c;越来越受到广大用户的青睐。为了满足这种需求&#xff0c;本地顺风车小程序应运而生&#xff0c;为用户提供了一种方便、快捷、可靠的顺风车出行服务。 以…
阅读更多...
HelloWorld - 从Houdini导出HDA到UE5

HelloWorld - 从Houdini导出HDA到UE5

1.配置插件 在Houdini安装目录下找到对应版本引擎的插件&#xff0c;例如这里是Houdini19对应UE5.2的版本&#xff0c;我们就要保证先下载好UE5.2&#xff1a; 将Houdini插件粘贴到UE安装目录的Plugins文件夹下&#xff1a; 目前插件配置完成&#xff0c;打开UE会自动启用插…
阅读更多...
兼容最新 urllib3 版本及相关库

兼容最新 urllib3 版本及相关库

解决方案 对于这个问题&#xff0c;我们可以通过修改setup.py文件来解决。在setup.py文件中&#xff0c;我们将urllib3的版本范围从1.21.1到1.26改为1.21.1到最新版本。这是因为在patch中&#xff0c;我们已经检查了urllib3的版本&#xff0c;并确保其大于1…
阅读更多...
ceph 14.2.10 aarch64 非集群内 客户端 挂载块设备

ceph 14.2.10 aarch64 非集群内 客户端 挂载块设备

集群上的机器测试 706 ceph pool create block-pool 64 64 707 ceph osd pool create block-pool 64 64 708 ceph osd pool application enable block-pool rbd 709 rbd create vdisk1 --size 4G --pool block-pool --image-format 2 --image-feature layering 7…
阅读更多...
资讯 | 图扑应邀出席“数字孪生•筑梦末来”数字工程论坛

资讯 | 图扑应邀出席“数字孪生•筑梦末来”数字工程论坛

2023"数字孪生 筑梦未来"数字工程论坛于 11 月 8 日在杭州拉开帷幕。该论坛是由中国电建集团华东勘测设计研究院有限公司发起创办全国性“工程IT”高端交流平台活动。 图扑软件作为受邀参展企业之一&#xff0c;有幸与诸位专家学者、参展客户共同领略数字化发展的成…
阅读更多...
在Python中使用sqlite3进行数据持久化操作

在Python中使用sqlite3进行数据持久化操作

目录 引言 一、安装sqlite3模块 二、创建数据库连接 三、创建游标对象 四、执行SQL命令 五、提交更改 六、关闭连接 七、使用参数化查询 八、使用ORM进行数据操作 九、备份和恢复数据库 十、处理大量数据 十一、优化查询性能 十二、处理并发访问 十三、处理数据持…
阅读更多...
C/C++ stm32基础知识超详细讲解（系统性学习day14）

C/C++ stm32基础知识超详细讲解（系统性学习day14）

目录 前言 一、ARM和STM32是什么&#xff1f; 二、STM32的开发方式 三、GPIO----寄存器开发方式 1.八种输入输出模式分析 2.寄存器 四、stm32芯片图片 五、怎么学好stm32 总结 前言 stm32的广泛含义及背景&#xff1a; STM32是一款由意法半导体&#xff08;ST&…
阅读更多...
基于flask和fomantic-ui的简易p2p文件分享平台的手动实现

基于flask和fomantic-ui的简易p2p文件分享平台的手动实现

背景 开学一个多月了&#xff0c;由于繁重的学业和懒惰&#xff0c;都没怎么更新有意思的博客。 前几天突然想到了一个想法。同学之间平常用网络分享一个文件&#xff0c;大部分都是用的qq。但是qq看起来把文件拖到聊天框点击发送就发给对面同学了。但是实际上是先上传到了腾…
阅读更多...
Spark通过三种方式创建DataFrame

Spark通过三种方式创建DataFrame

通过toDF方法创建DataFrame 通过toDF的方法创建 集合rdd中元素类型是样例类的时候&#xff0c;转成DataFrame之后列名默认是属性名集合rdd中元素类型是元组的时候&#xff0c;转成DataFrame之后列名默认就是_N集合rdd中元素类型是元组/样例类的时候&#xff0c;转成DataFrame…
阅读更多...
LLM prompt提示工程调试方法经验技巧汇总

LLM prompt提示工程调试方法经验技巧汇总

现在接到一个LLM模型任务&#xff0c;第一反应就是能不能通过精调prompt来实现&#xff0c;因为使用prompt不需要训练模型&#xff0c;只需输入指令就可以实现和LLM的交互。按照以往经验&#xff0c;不同的prompt对模型输出影响非常大&#xff0c;如果能构造一个好的prompt&…
阅读更多...
工业品电商，新的隐形冠军藏不住了？

工业品电商，新的隐形冠军藏不住了？

【潮汐商业评论/原创】 “时代真的变了。”自打从淘宝买了一批配件后&#xff0c;工厂老板李瓦就经常感慨。 李瓦经营着一家专门生产机器零部件的工厂&#xff0c;日常经常要采购传送带、螺丝、螺母等材料&#xff0c;过去他主要通过线下的方式进货。但最近朋友圈里一段淘宝工…
阅读更多...
2023.11.15 hive sql之函数标准,字符串,日期,数学函数

2023.11.15 hive sql之函数标准,字符串,日期,数学函数

目录 一.函数分类标准 二.查看官方函数,与简单演示 三.3种类型函数演示 四.字符串函数 1.常见字符串函数 2.索引函数 解析函数 五.日期函数 1.获取当前时间 2.获取日期相关 3.周,季度等计算 4.时间戳 六.数学函数 一.函数分类标准 目前hive三大标准 UDF:&#xff08…
阅读更多...
社区论坛小程序源码系统，功能齐全，页面简洁，前端+后端+完整部署教程

社区论坛小程序源码系统，功能齐全，页面简洁，前端+后端+完整部署教程

现如今&#xff0c;社区论坛已经成为人们交流思想&#xff0c;分享经验&#xff0c;获取信息的重要平台。近年来&#xff0c;小程序的出现更是改变了传统的网站建设方式&#xff0c;让用户体验更加便捷&#xff0c;高效。今天源码小编来和大家分享一款社区论坛小程序源码系统&a…
阅读更多...
基于SSM的OA办公管理系统的设计与实现

基于SSM的OA办公管理系统的设计与实现

末尾获取源码 开发语言&#xff1a;Java Java开发工具&#xff1a;JDK1.8 后端框架&#xff1a;SSM 前端&#xff1a;Vue 数据库&#xff1a;MySQL5.7和Navicat管理工具结合 服务器&#xff1a;Tomcat8.5 开发软件&#xff1a;IDEA / Eclipse 是否Maven项目&#xff1a;是 目录…
阅读更多...
exce常用

exce常用

一、冻结 同时冻结行和列 打开一个Excel表格&#xff0c;点击选择需要冻结的行和列交接处对应的单元格&#xff08;例如&#xff1a;需要同时冻结1、2行和A、B列&#xff0c;则选中行列交接对应的C3单元格&#xff09;&#xff09;&#xff0c; 即下一行 和下一列的交接点。 …
阅读更多...
使用grad-cam对ViT的输出进行可视化

使用grad-cam对ViT的输出进行可视化

使用grad-cam对ViT的输出进行可视化 文章目录 使用grad-cam对ViT的输出进行可视化前言原理使用代码Pytorch-grad-cam库的更多方法在MMpretrain中使用示例总结 前言 Vision Transformer (ViT) 作为现在CV中的主流backbone&#xff0c;它可以在图像分类任务上达到与卷积神经网络…
阅读更多...
mysql数据库超过最大连接数

mysql数据库超过最大连接数

mysql 超过数据库最大连接数解决办法 1、报错信息 首先无论是navicat 执行sql还是 用idea启动多的服务都会有如下报错信息&#xff1a; 2、解决办法 2.1命令方式修改 这种方法是由其他资料提供的。这种修改方式是临时的&#xff0c;如果mysql服务重启设置就会还原&#xff…
阅读更多...
弱类型和强类型自定义UDAF函数

弱类型和强类型自定义UDAF函数

目录 使用自带的avg函数弱类型自定义UDAF函数(AVG)强类型自定义UDAF函数(AVG) 弱类型&#xff1a;3.x过期 2.x有 强类型&#xff1a;3.x 2.x没有 使用自带的avg函数 import org.apache.spark.rdd.RDD import org.apache.spark.sql.{DataFrame, SparkSession}object UserDefine…
阅读更多...
双极膜电渗析设备

双极膜电渗析设备

#双极膜电渗析设备 双极膜&#xff08;bipolar membrance&#xff0c;简称BPM&#xff09;是一种新型的离子交换复合膜&#xff0c;它通常由阳离子交换层&#xff08;N型膜&#xff09;、界面亲水层&#xff08;催化层&#xff09;和阴离子交换膜&#xff08;P型膜&#xff09;…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023