一、前言说明
搞完onvif设备模拟器,总想着把28181设备模拟也实现,因为之前已经花了大力气把28181平台软件端实现了,为了实现这个组件,头发掉了一大把,专门把国标文档看了好几遍,逐行阅读,针对需要实现的交互协议,逐一实现,然后在N多实际现场测试,给最终用户使用,不断反馈迭代修改,以满足更多的实际需求,比如有些厂家设备居然没有ssrc,有些严格要求设备IP地址认证,有些只支持tcp被动方式,林林种种N多实际的特殊需求,都不断调整以便适应,目前已经适配了市面上主流的设备,也有些非主流的也适配了,总之,能考虑到的都考虑了。
既然都已经熟悉了28181协议,那设备端的28181程序实现起来,轻车熟路,相对来说要简单一些,因为设备模拟要实现的功能不多,能够主动连接sip服务器,能够应答设备信息和状态,心跳保活,视频点播,主要就这几个,只不过sip通信链路可以是udp或者tcp,视频点播可以支持udp、tcp主动、tcp被动三种方式。整个实现过程还是没有碰到太多的难题,毕竟之前就已经把所有可能的坑都趟过去了。
二、效果图
三、相关地址
- 国内站点:https://gitee.com/feiyangqingyun
- 国际站点:https://github.com/feiyangqingyun
- 个人作品:https://blog.csdn.net/feiyangqingyun/article/details/97565652
- 文件地址:https://pan.baidu.com/s/1d7TH_GEYl5nOecuNlWJJ7g 提取码:01jf 文件名:bin_video_simulate。
四、功能特点
- 标准onvif协议,支持设备搜索、获取参数、快照抓图等。
- 支持264/265/aac等标准视音频协议传输。
- 支持多路批量onvif设备模拟,每一路都独立的端口。
- 支持本地摄像头采集转成onvif,可选择不同的设备、分辨率、帧率等参数。
- 支持本地桌面采集转成onvif,可选择不同的屏幕、分辨率、帧率等参数。
- 支持各种视频文件和视频流转成onvif,可重新设置编码转换以及分辨率转换。
- 支持4K、8K等高清分辨率,不限制分辨率,非264/265会自动转码推流。
- 每一路都可以设置统一或者独立的用户验证信息,为空则表示不验证。
- 可以把任意内容接入到NVR以及视频监控系统,方便保存录像文件,以便回放可查。
- 也可作为压力测试工具,比如模拟几千路onvif设备,让集成平台软件做接入压力测试。
- 推出去的流不仅有rtsp格式,还支持rtmp、http、flv、ws-flv、webrtc等方式访问,可以直接网页查看。
- 在管理工具上可以看到每一路的推流状况以及分辨率信息,非常直观。
- 支持自动重连拉流,重连推流,保证7乘以24小时稳定运行。
- 可设置开机自启动运行和后台运行,不显示在任务栏,作为后台服务运行。
- 可批量添加文件、添加目录,自动将目录下的所有文件添加到模拟器。
- 多功能添加地址面板,可以选择本地设备和监控设备,本地设备会自动识别摄像头设备和桌面设备,监控设备可以选择不同厂家,自动填充对应rtsp格式,填入用户信息即可,可以批量递增添加监控设备。
- 可无缝上传到市面上所有的onvif协议设备,包括海康、大华、宇视、华为、天地伟业等,也支持ONVIF Device Manager国际onvif工具。
- 支持gb28181设备模拟,具备设备注册、设备注销、设备心跳、设备信息、设备配置、设备状态应答等。
- 支持模拟报警和位置上报等,方便平台侧显示对应设备的实时位置。
- 支持一键添加批量模拟28181设备,实时显示已注册和已注销状态。
- 支持将本地桌面、本地摄像头、任意视频文件、视频流文件、手机摄像头等转换成28181设备,添加到NVR或者国标软件平台。
- sip协议同时支持udp和tcp两种通信方式,视频点播同时支持udp/tcp主动/tcp被动三种方式,涵盖所有可能的场景需求。
- 无论是onvif设备模拟组件还是28181设备模拟组件,全部原创底层协议解析,纯Qt实现,跨任意平台。
- 代码结构框架非常清晰,注释详细,代码精简不繁琐,非常易于学习和移植,可以很容易拓展其他接口需求。
- 支持Qt4/Qt5/Qt6以及后续所有版本、所有编译器、所有开发环境。
- 支持windows、linux、mac、国产OS、嵌入式linux、RK3588、树莓派、香橙派等系统。
五、相关代码
#include "gb28181devicebody.h"int GB28181DeviceBody::idlen = 5;
QString GB28181DeviceBody::getXml(const QString &type, const QStringList &body)
{QStringList list;list << QString("<?xml version=\"1.0\" encoding=\"GB2312\"?>");list << QString("<%1>").arg(type);list << body;list << QString("</%1>").arg(type);return list.join("\r\n");
}QStringList GB28181DeviceBody::getCommonXml(const QString &cmdType, const QString &deviceId, quint64 xmlSN)
{QStringList list;list << QString(" <CmdType>%1</CmdType>").arg(cmdType);list << QString(" <SN>%1</SN>").arg(xmlSN);list << QString(" <DeviceID>%1</DeviceID>").arg(deviceId);return list;
}QString GB28181DeviceBody::getResponseXml(const QString &cmdType, const QString &deviceId, quint64 xmlSN, const QStringList &body)
{QStringList list = GB28181DeviceBody::getCommonXml(cmdType, deviceId, xmlSN);list << " <Result>OK</Result>";list << body;return GB28181DeviceBody::getXml("Response", list);
}QString GB28181DeviceBody::getNotifyXml(const QString &cmdType, const QString &deviceId, quint64 xmlSN, const QStringList &body)
{QStringList list = GB28181DeviceBody::getCommonXml(cmdType, deviceId, xmlSN);list << body;return GB28181DeviceBody::getXml("Notify", list);
}QString GB28181DeviceBody::getKeepalive(GB28181DevicePara device, quint64 &xmlSN)
{QStringList list;list << QString(" <Status>OK</Status>");return GB28181DeviceBody::getNotifyXml("Keepalive", device.deviceId, xmlSN++, list);
}QString GB28181DeviceBody::getAlarm(GB28181DevicePara device, quint64 &xmlSN, int alarmPriority, int alarmMethod, int alarmType)
{QStringList list;list << QString(" <AlarmPriority>%1</AlarmPriority>").arg(alarmPriority);list << QString(" <AlarmMethod>%1</AlarmMethod>").arg(alarmMethod);list << QString(" <AlarmTime>%1</AlarmTime>").arg(SIPTIME);list << QString(" <Info>");list << QString(" <AlarmType>%1</AlarmType>").arg(alarmType);list << QString(" <Info>");return GB28181DeviceBody::getNotifyXml("Alarm", device.channelId, xmlSN++, list);
}QString GB28181DeviceBody::getMobilePosition(GB28181DevicePara device, quint64 &xmlSN, double longitude, double latitude, double altitude)
{QStringList list;list << QString(" <Time>%1</Time>").arg(SIPTIME);list << QString(" <Longitude>%1</Longitude>").arg(longitude);list << QString(" <Latitude>%1</Latitude>").arg(latitude);list << QString(" <Altitude>%1</Altitude>").arg(altitude);list << QString(" <Speed>%1</Speed>").arg(100);list << QString(" <Direction>%1</Direction>").arg(180);return GB28181DeviceBody::getNotifyXml("MobilePosition", device.channelId, xmlSN++, list);
}QString GB28181DeviceBody::getDeviceInfo(GB28181DevicePara device, quint64 xmlSN)
{QStringList list;list << QString(" <DeviceName>%1-%2</DeviceName>").arg("TX-Camera").arg(device.deviceId.right(idlen));list << QString(" <Manufacturer>%1</Manufacturer>").arg("TaiXue");list << QString(" <Model>%1</Model>").arg("TX-Camera-001");list << QString(" <Firmware>%1</Firmware>").arg("V20250808");list << QString(" <Channel>%1</Channel>").arg(1);return GB28181DeviceBody::getResponseXml("DeviceInfo", device.deviceId, xmlSN, list);
}QString GB28181DeviceBody::getDeviceStatus(GB28181DevicePara device, quint64 xmlSN)
{QStringList list;list << QString(" <Online>%1</Online>").arg("ONLINE");list << QString(" <Status>%1</Status>").arg("OK");list << QString(" <DeviceTime>%1</DeviceTime>").arg(SIPTIME);list << QString(" <Alarmstatus Num=\"%1\"></Alarmstatus>").arg(0);list << QString(" <Encode>%1</Encode>").arg("ON");list << QString(" <Record>%1</Record>").arg("OFF");return GB28181DeviceBody::getResponseXml("DeviceStatus", device.deviceId, xmlSN, list);
}QString GB28181DeviceBody::getCatalog(GB28181DevicePara device, quint64 xmlSN)
{QStringList list;list << QString(" <SumNum>%1</SumNum>").arg(1);list << QString(" <DeviceList Num=\"%1\">").arg("1");list << QString(" <Item>");list << QString(" <DeviceID>%1</DeviceID>").arg(device.channelId);list << QString(" <Name>%1-%2</Name>").arg("TX-Channel").arg(device.channelId.right(idlen));list << QString(" <Manufacturer>%1</Manufacturer>").arg("TaiXue");list << QString(" <Model>%1</Model>").arg("TX-Camera-001");list << QString(" <Owner>%1</Owner>").arg("Owner");list << QString(" <CivilCode>%1</CivilCode>").arg(device.serverRealm);list << QString(" <Address>%1</Address>").arg("Address");list << QString(" <Parental>%1</Parental>").arg(0);list << QString(" <ParentID>%1</ParentID>").arg(device.deviceId);list << QString(" <SafetyWay>%1</SafetyWay>").arg("0");list << QString(" <RegisterWay>%1</RegisterWay>").arg("1");list << QString(" <Secrecy>%1</Secrecy>").arg("0");list << QString(" <Status>%1</Status>").arg("ON");list << QString(" </Item>");list << QString(" </DeviceList>");return GB28181DeviceBody::getResponseXml("Catalog", device.deviceId, xmlSN, list);
}QString GB28181DeviceBody::getConfigDownload(GB28181DevicePara device, quint64 xmlSN)
{QStringList list;list << QString(" <BasicParam>");list << QString(" <Name>%1-%2</Name>").arg("TX-Camera").arg(device.deviceId.right(idlen));list << QString(" <DeviceID>%1</DeviceID>").arg(device.deviceId);list << QString(" <SIPServerID>%1</SIPServerID>").arg(device.serverId);list << QString(" <SIPServerIP>%1</SIPServerIP>").arg(device.serverIp);list << QString(" <SIPServerPort>%1</SIPServerPort>").arg(device.serverPort);list << QString(" <DomainName>%1</DomainName>").arg(device.serverRealm);list << QString(" <Expiration>%1</Expiration>").arg(device.registInterval);list << QString(" <Password>%1</Password>").arg(device.serverPwd);list << QString(" <HeartBeatInterval>%1</HeartBeatInterval>").arg(device.heartInterval);list << QString(" <HeartBeatCount>%1</HeartBeatCount>").arg(device.heartTimeout);list << QString(" <PositionCapability>%1</PositionCapability>").arg(0);list << QString(" </BasicParam>");return GB28181DeviceBody::getResponseXml("ConfigDownload", device.deviceId, xmlSN, list);
}