一、前言说明

一个好的视频监控系统，设备掉线后能够自动重连，也是一个重要的功能指标，如果监控系统只是个rtsp流地址，那非常好办，只需要重新打开流地址即可，而gb28181中就变得复杂了很多，需要多个方便配合，主要涉及到sip交互指令，rtp解包，ffmpeg解码，三个方面缺一不可，其中sip这边负责让设备发流数据，而且有多个交互指令，rtp这边也需要先绑定地址监听端口成功后，再把端口号一起sdp应答给设备，sip和rtp都完成后再打开ffmpeg准备收数据解码，三个方面都要配合，只要有一个方面配合的不好就会失败，关键是取流还支持三种方式，udp，tcp被动，tcp主动，三种方式都要能支持自动重连。网上很多国标的工具，几乎都没有这种重连的功能。

在做这个重连功能中，有几个要点需要注意，一个是当用户主动关闭了流，是不需要加入重连检测的，不然永远都关不掉，这个可以加个标志位来解决，当用户打开流的时候标志位真，用户关闭流的时候标志位假，重连定时器判断标志位，为真才需要去检测。还一个是资源的释放，重连过程中必须先把之前的rtp解包线程的资源释放，还有ffmpeg解码这边的资源全部释放，不然一直累加会导致内存泄漏。

二、效果图

在这里插入图片描述
在这里插入图片描述

三、相关地址

  1. 国内站点：https://gitee.com/feiyangqingyun
  2. 国际站点：https://github.com/feiyangqingyun
  3. 个人作品：https://blog.csdn.net/feiyangqingyun/article/details/97565652
  4. 文件地址：https://pan.baidu.com/s/1d7TH_GEYl5nOecuNlWJJ7g 提取码：01jf 文件名：bin_video_gb28181。

四、功能特点

  1. 支持设备注册、注销、心跳、校时、注册认证、注销认证等。
  2. 设备上线后可以手动获取设备状态、设备信息、配置信息、预置位信息等。
  3. 设备上线后自动获取设备通道信息，包括中文通道名称。识别到通道上线离线变化，会重新获取该设备的所有通道信息。
  4. 支持视频点播，可以分别点播主码流和子码流，内置rtp解包线程，解包后发给视频播放组件解码播放。
  5. 每个设备每个通道支持点播多个视频，通过ssrc区分，支持共用端口和不同端口收流。
  6. 支持对某个设备下面所有通道、某个通道、某个通道对应的某个流分别关闭。
  7. 支持录像文件查询和回放，回放控制支持暂停播放、继续播放、倍速播放、切换播放进度。
  8. 支持录像文件下载，支持倍速比如8倍速下载，可同时多线程批量下载。
  9. 回放和下载同时支持IPC和NVR，比如摄像头自带的SD存储卡录像文件回放，NVR上的硬盘录像文件回放。
  10. 支持云台控制，向上、向下、向左、向右、左上、右上、左下、右下方位移动，镜头放大缩小，光圈放大缩小，镜头聚焦放焦。
  11. 支持预置位信息的查询、调用、添加、修改、删除等操作。
  12. 自动目录订阅功能，通道上线下线都有对应的信号通知。
  13. 内置定时读取通道信息机制，以保证通道信息是最新的，比如有些NVR是不断更新的通道信息。
  14. 内置订阅警情和位置移动功能，订阅后各种警情事件比如运动目标检测报警、入侵检测报警、徘徊检测报警等自动上报。
  15. 支持语音对讲功能，可以直接在视频窗体的悬浮条上单击语音对讲按钮，再次单击关闭对讲，对讲期间悬浮条常驻显示。
  16. 支持设备布防撤防，布防后警情信息会主动上报。
  17. 国标服务同时支持udp和tcp方式，可选只监听一种或者两种都监听，tcp方式自动处理粘包问题。
  18. 国标拉流同时支持udp、tcp被动、tcp主动三种方式，每个通道都可以自由选择何种拉流方式。
  19. 内置拉流端口池，每次拉流从中取出一个，关闭流自动回收端口号，重复利用。
  20. 收流端口自动纠错，自动跳过被占用的端口，不会出现端口占用导致收流失败的情况。
  21. 支持三种取流方式自动检测离线重连，检测到离线后，自动重启点播拉流整个流程。
  22. 录像文件回放，上一个完成后自动切换到下一个继续回放，直到所有回放完成。支持高达8倍速回放。
  23. 视频播放自适应硬解码，极低资源占用，实时性极好，带悬浮条显示视频流信息，可以直接在悬浮条单击按钮保存录像文件到本地。
  24. 支持几千路国标消息交互并发，实时视频流支持64路同时显示，可以拓展更多路数。
  25. 支持阿里云等云服务器，可以分别设置内网监听地址和外网访问地址，一般云服务器上是监听地址用内网，对外访问用外网地址。
  26. 支持视频分发，也就是推流，视频通道打开后可以自动推流到流媒体服务器，其他需要的地方拉流即可，支持rtsp、rtmp、hls、webrtc等方式拉流。
  27. 实时预览和录像回放都支持推流，推流支持叠加文字和图片水印以及各种ffmpeg支持的滤镜效果，支持多个水印同时叠加。
  28. 同时支持gb28181-2011、gb28181-2016、gb28181-2022以及后续可能的所有协议版本。
  29. SIP解析和交互采用纯Qt底层代码实现，udp/tcp通信交互，祖传原创代码解析，不依赖任何第三方。
  30. 代码量少，gb28181交互部分共几千行代码，注释详细，接口友好，使用极其简单，提供非常详细的使用示例。
  31. 支持海康、大华、宇视、华为、天地伟业等所有国标设备，包括一些没有ssrc的设备。
  32. 支持所有Qt版本和编译器以及操作系统，包括但不限于win、linux、mac、android、嵌入式linux、树莓派香橙派、国产os等。

五、相关代码

#include "rtphelper.h"
#include "rtpthreadreceive.h"
#include "rtpthreadsend.h"
#include "gb28181widget.h"
#include "gb28181widgetmanage.h"
#include "gb28181server.h"
#include "urlhelper.h"bool GB28181Widget::checkSsrc = true;
GB28181Widget::GB28181Widget(QWidget *parent) : VideoWidget(parent)
{server = NULL;this->speed = 1;this->profile = 1;this->mode = TransmitMode_UdpServer;//创建视频解码线程rtpVideo = new RtpThreadReceive;rtpVideo->setProperty("running", false);connect(rtpVideo, SIGNAL(openOk(int)), this, SLOT(openOk(int)));connect(rtpVideo, SIGNAL(receiveData(QByteArray, qint64)), this, SLOT(receiveData(QByteArray, qint64)));//创建音频发送线程rtpAudio = new RtpThreadSend;connect(rtpAudio, SIGNAL(openOk(int)), this, SLOT(openOk(int)));//关联视频窗体信号槽connect(this, SIGNAL(sig_receivePlayStart(int)), this, SLOT(receivePlayStartx(int)));connect(this, SIGNAL(sig_receivePlayFinsh()), this, SLOT(receivePlayFinshx()));
}void GB28181Widget::initPara(int scaleMode, int videoMode, int videoCore, int decodeType, const QString &hardware, int readTimeout, bool call, bool download)
{GB28181WidgetManage::initPara(this, scaleMode, videoMode, videoCore, decodeType, hardware, readTimeout, call, download);
}void GB28181Widget::clearPara()
{this->ssrcVideo = "";this->ssrcAudio = "";this->deviceId = "";this->channelId = "";this->startTime = "";this->endTime = "";
}qint64 GB28181Widget::getPts() const
{return rtpVideo->getPts();
}RtpThreadReceive *GB28181Widget::getThread() const
{return this->rtpVideo;
}QString GB28181Widget::getSsrcVideo() const
{return this->ssrcVideo;
}QString GB28181Widget::getSsrcAudio() const
{return this->ssrcAudio;
}QString GB28181Widget::getDeviceId() const
{return this->deviceId;
}QString GB28181Widget::getChannelId() const
{return this->channelId;
}void GB28181Widget::setServer(GB28181Server *server)
{this->server = server;connect(server, SIGNAL(startVideo(QString, int, QString, QString, QString, int, int)), this, SLOT(startVideo(QString, int, QString, QString, QString, int, int)), Qt::UniqueConnection);connect(server, SIGNAL(startAudio(QString, int, QString, QString, QString, int, int)), this, SLOT(startAudio(QString, int, QString, QString, QString, int, int)), Qt::UniqueConnection);
}void GB28181Widget::setPara(float speed, int profile, TransmitMode mode, const QString &serverIp, const QString &pushUrl, PlayType playType)
{this->speed = speed;this->profile = profile;this->mode = mode;this->serverIp = serverIp;this->pushUrl = pushUrl;this->playType = playType;this->setSpeed(speed);
}void GB28181Widget::setTime(const QString &startTime, const QString &endTime)
{this->startTime = startTime;this->endTime = endTime;
}void GB28181Widget::openVideo(const QString &deviceId, const QString &channelId)
{this->deviceId = deviceId;this->channelId = channelId;//启动阶段先要停止if (rtpVideo->isRunning()) {rtpVideo->stop();}//从端口池中取出一个端口lastPort = RtpHelper::takePort();rtpVideo->setProperty("running", true);rtpVideo->setPara(serverIp, lastPort, serverIp, lastPort, mode);rtpVideo->start();
}bool GB28181Widget::closeVideo(const QString &deviceId, const QString &channelId, const QString &ssrc)
{if (this->deviceId != deviceId) {return false;}if (!channelId.isEmpty() && this->channelId != channelId) {return false;}if (!ssrc.isEmpty() && this->ssrcVideo != ssrc) {return false;}this->stop();return true;
}void GB28181Widget::appendAudio(const QByteArray &data)
{rtpAudio->append(data);
}void GB28181Widget::openAudio(const QString &deviceId, const QString &channelId)
{//启动阶段先要停止if (rtpAudio->isRunning()) {rtpAudio->stop();}//从端口池中取出一个端口lastPort = RtpHelper::takePort();rtpAudio->setPara(serverIp, lastPort, serverIp, lastPort, mode);rtpAudio->start();
}bool GB28181Widget::closeAudio(const QString &deviceId, const QString &channelId, const QString &ssrc)
{if (this->deviceId != deviceId) {return false;}if (!channelId.isEmpty() && this->channelId != channelId) {return false;}if (!ssrc.isEmpty() && this->ssrcAudio != ssrc) {return false;}//停止语音对讲和发流线程server->bye(deviceId, channelId, ssrcAudio);rtpAudio->stop();return true;
}void GB28181Widget::closeEvent(QCloseEvent *)
{this->stop();
}void GB28181Widget::openOk(int port)
{//收流端口打开成功才能继续点播lastPort = port;if (sender() == rtpVideo) {bool playback = (playType == PlayType_Playback);ssrcVideo = server->invite(deviceId, channelId, port, startTime, endTime, speed, profile, mode, playback);} else {server->broadcast(deviceId, channelId, port);}
}void GB28181Widget::receiveData(const QByteArray &data, qint64 ssrc)
{if (videoThread) {
#if (QT_VERSION >= QT_VERSION_CHECK(5,0,0))videoThread->appendData(data);
#elseQMetaObject::invokeMethod(videoThread, "appendData", Q_ARG(QByteArray, data));
#endif}
}void GB28181Widget::startVideo(const QString &host, int port, const QString &deviceId, const QString &channelId, const QString &ssrc, int transmitMode, int transmitPort)
{//过滤下是不是当前窗体if (this->deviceId != deviceId || this->channelId != channelId || transmitMode != mode) {return;}//有些设备并没有按照下发的ssrc作为标识/而是自己定义的/这里就需要去掉这个判断if (checkSsrc && this->ssrcVideo != ssrc) {return;}//qDebug() << TIMEMS << "startVideo" << mode << host << port << deviceId << channelId << ssrc << transmitMode << transmitPort;if (mode == TransmitMode_TcpClient) {rtpVideo->setPara(serverIp, lastPort, host, transmitPort, mode);rtpVideo->setOk(true);}//打开视频接收流数据/设置是否禁用解码/仅推流不需要解码/极大减少资源占用if (!this->getIsRunning()) {this->open(QString("stream://%1_%2").arg(deviceId).arg(channelId));this->getVideoThread()->setDisableDecode(this->property("disableDecode").toBool());}
}void GB28181Widget::startAudio(const QString &host, int port, const QString &deviceId, const QString &channelId, const QString &ssrc, int transmitMode, int transmitPort)
{//过滤下是不是当前窗体if (this->deviceId != deviceId || this->channelId != channelId) {return;}ssrcAudio = ssrc;rtpAudio->setPara(serverIp, lastPort, host, transmitPort, transmitMode, ssrc);rtpAudio->setOk(true);
}void GB28181Widget::receivePlayStartx(int)
{//设置播放速度this->setSpeed(speed);//执行保存文件或推流if (playType == PlayType_Download) {QString date = startTime.left(10);QString start = startTime.mid(11).replace(":", "-");QString end = endTime.mid(11).replace(":", "-");QString name = QString("%1_%2_%3_%4_%5.mp4").arg(deviceId).arg(channelId).arg(date).arg(start).arg(end);this->getVideoThread()->recordStart(qApp->applicationDirPath() + "/video/" + name);} else if (!pushUrl.isEmpty()) {QString url = this->getVideoPara().mediaUrl.mid(9);url = pushUrl + "/" + url + "_" + ssrcVideo;this->getVideoThread()->recordStart(url);//要转成外网地址才能正常访问QString ip = UrlHelper::getUrlIP(url);GB28181ServerPara para = server->getServerPara();url.replace(ip, para.serverHost);emit pushStart(this, url);}
}void GB28181Widget::receivePlayFinshx()
{//判断唯一标识/一个通道可能打开了多个流/只需要关闭当前窗体对应的流if (!ssrcVideo.isEmpty()) {rtpVideo->setProperty("running", false);server->bye(deviceId, channelId, ssrcVideo);rtpVideo->stop();}if (!ssrcAudio.isEmpty()) {server->bye(deviceId, channelId, ssrcAudio);rtpAudio->stop();}if (!deviceId.isEmpty() && !channelId.isEmpty()) {emit pushStop(deviceId, channelId);}this->clearPara();
}

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

如若内容造成侵权/违法违规/事实不符，请联系英文站点网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

此芯p1开发板使用OpenHarmony时llama.cpp不同优化速度对比(GPU vs CPU)

此芯p1开发板使用OpenHarmony时llama.cpp不同优化速度对比(GPU vs CPU)

硬件环境 Cix P1 SoC 瑞莎星睿 O6 开发板 rx580显卡 产品介绍&#xff1a; https://docs.radxa.com/orion/o6/getting-started/introduction OpenHarmony 5.0.0 使用vulkan后端的llama.cpp &#xff08;GPU&#xff09; # ./llama-bench -m /data/qwen1_5-0_5b-chat-q2_k.…
阅读更多...
Android 四大布局：使用方式与性能优化原理

Android 四大布局：使用方式与性能优化原理

一、四大布局基本用法与特点1. LinearLayout&#xff08;线性布局&#xff09;使用方式&#xff1a;<LinearLayoutandroid:orientation"vertical" <!-- 排列方向&#xff1a;vertical/horizontal -->android:layout_width"match_parent"android:…
阅读更多...
Redis的BigKey问题

Redis的BigKey问题

Redis的BigKey问题 什么是大Key问题&#xff1f; 大key问题其实可以说是大value问题&#xff0c;就是某个key对应的value所占据的存储空间太大了&#xff0c;所以导致我们在操作这个key的时候花费的时间过长&#xff08;序列化\反序列化&#xff09;&#xff0c;从而降低了redi…
阅读更多...
TDengine IDMP 产品基本概念

TDengine IDMP 产品基本概念

基本概念 元素 (Element) IDMP 通过树状层次结构来组织数据&#xff0c;树状结构里的每个节点被称之为元素 (Element)。元素是一个物理的或逻辑的实体。它可以是具体的物理设备&#xff08;比如一台汽车&#xff09;&#xff0c;物理设备的一个子系统&#xff08;比如一台汽车的…
阅读更多...
专题二_滑动窗口_将x减到0的最小操作数

专题二_滑动窗口_将x减到0的最小操作数

一&#xff1a;题目解释&#xff1a;每次只能移除数组的边界&#xff0c;移除的边界的总和为x&#xff0c;要求返回你移除边界的最小操作数&#xff01;也就是说你最少花几次移除边界&#xff0c;就能够让这些移除的边界的和为x&#xff0c;则返回这个次数&#xff01;所以这个…
阅读更多...
CentOS 7 下通过 Anaconda3 运行llm大模型、deepseek大模型的完整指南

CentOS 7 下通过 Anaconda3 运行llm大模型、deepseek大模型的完整指南

CentOS 7 下通过 Anaconda3 运行llm大模型、deepseek大模型的完整指南A1 CentOS 7 下通过 Anaconda3 运行大模型的完整指南一、环境准备二、创建专用环境三、模型部署与运行四、优化配置常见问题解决B1 CentOS 7 下通过 Anaconda3 使用 CPU 运行 DeepSeek 大模型的完整方案一、…
阅读更多...
Flutter应用在Windows 8上正常运行

Flutter应用在Windows 8上正常运行

要让Flutter应用在Windows 8上正常运行，需满足以下前提条件，涵盖系统环境、依赖配置、编译设置等关键环节： 一、系统环境基础要求 Windows 8版本 必须是 Windows 8.1（核心支持），不支持早期Windows 8（需升级到8.1，微软已停止对原版Windows 8的支持）。 确认系统版本：右…
阅读更多...
Redis实现消息队列三种方式

Redis实现消息队列三种方式

参考 Redis队列详解&#xff08;springboot实战&#xff09;_redis 队列-CSDN博客 前言 MQ消息队列有很多种&#xff0c;比如RabbitMQ,RocketMQ,Kafka等&#xff0c;但是也可以基于redis来实现&#xff0c;可以降低系统的维护成本和实现复杂度&#xff0c;本篇介绍redis中实现…
阅读更多...
【C++动态版本号生成方案：实现类似C# 1.0.* 的自动构建号】

【C++动态版本号生成方案：实现类似C# 1.0.* 的自动构建号】

C动态版本号生成方案&#xff1a;实现类似C# 1.0.* 的自动构建号 在C#中&#xff0c;1.0.*版本号格式会在编译时自动生成构建号和修订号。本文将介绍如何在C项目中实现类似功能&#xff0c;通过MSBuild自动化生成基于编译时间的版本号。 实现原理 版本号构成&#xff1a;主版本…
阅读更多...
【算法题】：斐波那契数列

【算法题】：斐波那契数列

用 JavaScript 实现一个 fibonacci 函数&#xff0c;满足&#xff1a; 输入 n&#xff08;从0开始计数&#xff09;输出第 n 个斐波那契数&#xff08;斐波那契数列从 1 开始&#xff1a;1,1,2,3,5,8,13,21…&#xff09; 示例&#xff1a; fibonacci(0) > 1fibonacci(4) &g…
阅读更多...
【YOLOv13[基础]】热力图可视化实践 | 脚本升级 | 优化可视化效果 | 论文必备 | GradCAMPlusPlus, GradCAM, XGradCAM, EigenCAM等

【YOLOv13[基础]】热力图可视化实践 | 脚本升级 | 优化可视化效果 | 论文必备 | GradCAMPlusPlus, GradCAM, XGradCAM, EigenCAM等

本文将进行添加YOLOv13版本的升级版热力图可视化功能的实践，支持图像热力图可视化、优化可视化效果、 可以选择使用GradCAMPlusPlus, GradCAM, XGradCAM, EigenCAM, HiResCAM, LayerCAM, RandomCAM, EigenGradCAM。一个参数即可设置是否显示检测框等。 原图 结果图
阅读更多...
ElasticSearch相关术语介绍

ElasticSearch相关术语介绍

1.RESTful风格程序REST(英文全称为:"Representational State Transfer")指的是一组架构约束条件和原则。它是一种软件架构风格&#xff08;约束条件和原则的集合&#xff0c;但并不是标准&#xff09;。 REST通过资源的角度观察网络&#xff0c;以URI对网络资源进行…
阅读更多...
《从零构建大语言模型》学习笔记4，注意力机制1

《从零构建大语言模型》学习笔记4，注意力机制1

《从零构建大语言模型》学习笔记4&#xff0c;自注意力机制1 文章目录《从零构建大语言模型》学习笔记4&#xff0c;自注意力机制1前言一、实现一个简单的无训练权重的自注意力机制二、实现具有可训练权重的自注意力机制1. 分步计算注意力权重2.实现自注意力Python类三、将单头…
阅读更多...
昇思+昇腾开发板+DeepSeek模型推理和性能优化

昇思+昇腾开发板+DeepSeek模型推理和性能优化

昇思昇腾开发板DeepSeek模型推理和性能优化 模型推理 流程&#xff1a; 权重加载 -> 启动推理 -> 效果比较与调优 -> 性能测试 -> 性能优化 权重加载 如微调章节介绍&#xff0c;最终的模型包含两部分&#xff1a;base model 和 LoRA adapter&#xff0c;其中base …
阅读更多...
未给任务“Fody.WeavingTask”的必需参数“IntermediateDir”赋值。 WpfTreeView

未给任务“Fody.WeavingTask”的必需参数“IntermediateDir”赋值。 WpfTreeView

c#专栏记录&#xff1a; 报错 未给任务“Fody.WeavingTask”的必需参数“IntermediateDir”赋值。 WpfTreeView 生成 解决办法 清理和重新生成项目 完成上述配置后&#xff0c;尝试执行以下步骤&#xff1a; 清理项目&#xff1a;删除 bin 和 obj 文件夹。 重新生成项目&…
阅读更多...
[Linux]学习笔记系列 -- [arm][lib]

[Linux]学习笔记系列 -- [arm][lib]

文章目录arch/arm/lib/delay.cregister_current_timer_delay 注册当前定时器延迟read_current_timer 读取当前定时器drivers/clocksource/timer-stm32.cstm32_clocksource_init STM32 平台上初始化时钟源https://github.com/wdfk-prog/linux-study arch/arm/lib/delay.c regis…
阅读更多...
harbor仓库搭建（配置https）

harbor仓库搭建（配置https）

目录 1. 环境准备 2. 配置https的原因 3. 生成ca证书 4. 搭建harbor仓库 5. 访问harbor 6. 修改加密算法 1. 环境准备 需要提前安装docker和docker-compose&#xff0c;harbor仓库版本越新&#xff0c;对应的docker和docker-compose版本越新。 主机IP192.168.48.19dock…
阅读更多...
C++多线程服务器

C++多线程服务器

C多线程服务器 因为自己同时在看多本书&#xff0c;之前看过《TCP/IP 网络编程》一书&#xff0c;其中有一个自己编写一个多线程服务器的例子&#xff0c;于是就把代码直接抄了一变。 在学习网络编程前需要先了解网络的7层模型。 具体代码如下&#xff1a; 服务器端&#xff1a…
阅读更多...
【Pandas】常用数据处理技巧

【Pandas】常用数据处理技巧

一. 数据读取 1.pd.to_csv & pd.read_csv 细节&#xff1a; 1.pd.read_csv 需要 ignore_index True or ,index_col0 否则会有列Unnamed0 2.pickle具有更快的读取速度&#xff0c;与更小的体积。 读取前N行&#xff08;若不需获取所有数据&#xff09; pd.read_csv(…
阅读更多...
Docker Compose 部署高可用 MongoDB 副本集集群（含 Keepalived + HAProxy 负载均衡）

Docker Compose 部署高可用 MongoDB 副本集集群（含 Keepalived + HAProxy 负载均衡）

Docker Compose 部署高可用 MongoDB 副本集集群&#xff08;含 Keepalived HAProxy 负载均衡&#xff09;背景与目标&#x1f4cb; 环境规划**服务器信息****软件版本**部署步骤1. 创建目录结构2、生成 keyFile&#xff08;三台机器内容必须一致&#xff09;3. 准备 Keepalive…
阅读更多...
最新文章

Copyright @ 2022~2023