用纯Qt实现GB28181协议/实时视频/云台控制/预置位/录像回放和下载/事件订阅/语音对讲

一、前言

在技术的长河中探索,有些目标一旦确立,便如同璀璨星辰,指引着我们不断前行。早在2014年,我心中就种下了用纯Qt实现GB28181协议的种子,如今回首,一晃十年已逝,好在整体框架和逻辑终于打通,个中滋味,只有自己知晓。

最初接触GB28181协议时,我就发现它远比熟悉的onvif协议复杂。onvif协议在局域网内表现出色,配置简单、使用方便,很多安防设备在局域网环境下借助onvif协议能轻松实现设备间的互联互通。然而,当涉及外网访问时,onvif就显得力不从心,几乎找不到有效的解决办法。在如今监控设备遍布大街小巷,各部门机构都急需外网远程取流的大环境下,GB28181协议应运而生。它作为一套视频监控规范,旨在解决外网访问监控视频的诸多痛点。但GB28181协议也面临着网络通信的固有难题,比如服务端在未收到客户端消息时,无法知晓客户端的具体通信地址,这就导致双方无法直接通信,必须由客户端主动向服务器发送消息来建立联系。

在实现GB28181协议的过程中,选择何种方式解析SIP协议是关键。市面上关于SIP协议的第三方库五花八门,功能看似完备。但经过深思熟虑,我最终决定采用Qt底层的udp通信协议来进行解析。这么做主要有两方面的考量。一方面,从底层入手能让我更深入地理解协议的每一个细节。在解析过程中,我可以根据实际需求打造友好的使用接口,避免了使用第三方库时可能遇到的各种问题,比如繁琐的编译过程,不同版本库之间的兼容性难题等。另一方面,考虑到项目后期的拓展性,从底层“手撸”代码是最好的选择。只有牢牢掌握底层实现,才能灵活应对各种新需求和新场景,将兼容性和易用性放在首位。毕竟,只有真正解决了客户在使用过程中的痛点,产品才有市场价值。

二、效果图在这里插入图片描述

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

三、相关地址

  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. 支持警情订阅,各种警情事件比如运动目标检测报警、入侵检测报警、徘徊检测报警等自动上报。
  14. 国标服务同时支持udp和tcp方式,可选只监听一种或者两种都监听,tcp方式自动处理粘包问题。
  15. 收流端口自动纠错,自动跳过被占用的端口,不会出现端口占用导致收流失败的情况。
  16. 支持几千路国标消息交互并发,实时视频流支持64路同时显示,可以拓展更多路数。
  17. 支持阿里云等云服务器,可以分别设置内网监听地址和外网访问地址,一般云服务器上是监听地址用内网,对外访问用外网地址。
  18. 支持视频分发,也就是推流,视频通道打开后可以自动推流到流媒体服务器,其他需要的地方拉流即可,支持rtsp、rtmp、hls、webrtc等方式拉流。
  19. SIP解析和交互采用纯Qt底层代码实现,udp/tcp通信交互,祖传原创代码解析,不依赖任何第三方。
  20. 代码量少,gb28181交互部分共几千行代码,注释详细,接口友好,使用极其简单,提供非常详细的使用示例。
  21. 支持海康、大华、宇视、华为、天地伟业等所有国标设备。
  22. 支持所有Qt版本和编译器以及操作系统,包括但不限于win、linux、mac、android、嵌入式linux、树莓派香橙派、国产os等。

五、相关代码

#include "frmconfig.h"
#include "frmserver.h"
#include "ui_frmserver.h"
#include "qthelper.h"
#include "apphelper.h"
#include "rtpthread.h"
#include "gb28181server.h"
#include "gb28181helper.h"frmServer::frmServer(QWidget *parent) : QWidget(parent), ui(new Ui::frmServer)
{ui->setupUi(this);this->initForm();this->initConfig();
}frmServer::~frmServer()
{delete ui;
}void frmServer::closeEvent(QCloseEvent *)
{if (AppConfig::ServerStart) {on_btnStart_clicked();}qApp->quit();
}void frmServer::initForm()
{ui->tabPlayback->setEnabled(false);ui->tabDownload->setEnabled(false);ui->widgetControl->setEnabled(false);ui->widget->setFixedWidth(AppData::RightWidth);connect(ui->tabPreview, SIGNAL(selectVideo(QString, QString)), this, SLOT(selectVideo(QString, QString)));ui->treeWidget->setAnimated(false);ui->treeWidget->setIndentation(15);ui->treeWidget->setExpandsOnDoubleClick(false);//立即启动服务server = NULL;if (AppConfig::ServerStart) {on_btnStart_clicked();}
}void frmServer::initConfig()
{ui->tabWidget->setCurrentIndex(AppConfig::TabIndexMain);connect(ui->tabWidget, SIGNAL(currentChanged(int)), this, SLOT(saveConfig()));ui->cboxFlag->addItem(AppConfig::FilterType == 0 ? "00000000000000000000" : "0.0.0.0");ui->cboxFlag->lineEdit()->setText(AppConfig::FilterFlag);connect(ui->cboxFlag->lineEdit(), SIGNAL(textChanged(QString)), this, SLOT(saveConfig()));
}void frmServer::saveConfig()
{AppConfig::TabIndexMain = ui->tabWidget->currentIndex();AppConfig::FilterFlag = ui->cboxFlag->lineEdit()->text();AppConfig::writeConfig();
}void frmServer::receiveEvent(GB28181Event event)
{if (event.alarmMethod != 5) {return;}//设备中的某个通道离线和上线QTreeWidgetItem *itemChannel = AppHelper::findItem(ui->treeWidget, event.deviceId, event.channelId);if (itemChannel) {if (event.alarmInfo == 13) {itemChannel->setDisabled(true);ui->tabPreview->closeVideo(event.deviceId, event.channelId);} else if (event.alarmInfo == 14) {itemChannel->setDisabled(false);}}
}void frmServer::deviceChanged(const QString &deviceId, bool online)
{//关闭对应的画面if (!online) {ui->tabPreview->closeVideo(deviceId);}QList<GB28181Device> devices = server->getDevices();GB28181Device device = GB28181Helper::getDevice(deviceId, devices);QString text = deviceId + " [" + device.deviceName + "]";QTreeWidgetItem *itemDevice = AppHelper::findItem(ui->treeWidget, deviceId, "");if (itemDevice) {itemDevice->setText(0, text);itemDevice->setDisabled(!online);return;}//不存在则添加顶层节点QTreeWidgetItem *item = new QTreeWidgetItem;item->setText(0, text);item->setData(0, Qt::UserRole, deviceId);ui->treeWidget->insertTopLevelItem(0, item);//添加到下拉框QString flag = (AppConfig::FilterType == 0 ? device.deviceId : device.deviceIp);if (ui->cboxFlag->findText(flag) < 0) {ui->cboxFlag->addItem(flag);}
}void frmServer::channelChanged(const QString &deviceId)
{//每次都清空通道再重新添加QList<GB28181Device> devices = server->getDevices();QTreeWidgetItem *itemDevice = AppHelper::findItem(ui->treeWidget, deviceId, "");if (itemDevice) {qDeleteAll(itemDevice->takeChildren());QStringList ids, names;GB28181Helper::getChannelInfo(deviceId, devices, ids, names);for (int i = 0; i < ids.count(); ++i) {QTreeWidgetItem *itemChannel = new QTreeWidgetItem(itemDevice);itemChannel->setText(0, ids.at(i) + " [" + names.at(i) + "]");itemChannel->setData(0, Qt::UserRole, ids.at(i));}}//通过单次定时器去执行/防止频繁上线期间卡主界面static QTimer *timer = NULL;if (!timer) {timer = new QTimer(this);connect(timer, SIGNAL(timeout()), this, SLOT(finshed()));timer->setSingleShot(true);timer->setInterval(300);}timer->stop();timer->start();
}void frmServer::finshed()
{//展开所有节点ui->treeWidget->expandAll();//自动调整列宽ui->treeWidget->resizeColumnToContents(0);
}void frmServer::on_btnStart_clicked()
{if (ui->btnStart->text() == "启动服务") {ui->tabDebug->clear();ui->tabEvent->clear();if (AppConfig::ServerIp == "0.0.0.0") {QtHelper::showMessageBoxError("请先打开系统设置, 选择网卡地址!");return;}server = new GB28181Server;connect(server, SIGNAL(sendData(QString, int, QString, QString)), ui->tabDebug, SLOT(sendData(QString, int, QString, QString)));connect(server, SIGNAL(receiveData(QString, int, QString, QString)), ui->tabDebug, SLOT(receiveData(QString, int, QString, QString)));connect(server, SIGNAL(receiveInfo(QString, int, QString, QString)), ui->tabDebug, SLOT(receiveInfo(QString, int, QString, QString)));connect(server, SIGNAL(playStart(QString, int, QString, int, int)), ui->tabDebug, SLOT(playStart(QString, int, QString, int, int)));connect(server, SIGNAL(receiveEvent(GB28181Event)), this, SLOT(receiveEvent(GB28181Event)));connect(server, SIGNAL(receiveEvent(GB28181Event)), ui->tabEvent, SLOT(receiveEvent(GB28181Event)));connect(server, SIGNAL(receiveRecord(QList<GB28181Record>)), ui->tabPlayback, SLOT(receiveRecord(QList<GB28181Record>)));connect(server, SIGNAL(receiveRecord(QList<GB28181Record>)), ui->tabDownload, SLOT(receiveRecord(QList<GB28181Record>)));connect(server, SIGNAL(receiveStatus(GB28181Status)), ui->tabPlayback, SLOT(receiveStatus(GB28181Status)));connect(server, SIGNAL(receiveStatus(GB28181Status)), ui->tabDownload, SLOT(receiveStatus(GB28181Status)));connect(server, SIGNAL(deviceChanged(QString, bool)), this, SLOT(deviceChanged(QString, bool)));connect(server, SIGNAL(channelChanged(QString)), this, SLOT(channelChanged(QString)));connect(server, SIGNAL(presetChanged(QStringList, QStringList)), ui->widgetControl, SLOT(presetChanged(QStringList, QStringList)));GB28181ServerPara para;para.serverId = AppConfig::ServerId;para.serverRealm = AppConfig::ServerRealm;para.serverHost = AppConfig::ServerHost;para.serverIp = AppConfig::ServerIp;para.serverPort = AppConfig::ServerPort;para.serverPwd = AppConfig::ServerPwd;para.timeout = AppConfig::Timeout;server->setServerPara(para);server->start((ListenMode)AppConfig::ListenMode);ui->btnStart->setText("停止服务");ui->tabPreview->setServer(server);ui->tabPlayback->setServer(server);ui->tabDownload->setServer(server);ui->widgetControl->setServer(server);ui->tabPlayback->setEnabled(true);ui->tabDownload->setEnabled(true);ui->widgetControl->setEnabled(true);} else {ui->treeWidget->clear();ui->treeWidget->resizeColumnToContents(0);ui->btnStart->setText("启动服务");ui->tabPreview->closeAll();ui->tabPlayback->closeAll();ui->tabDownload->closeAll();ui->widgetControl->closeAll();ui->tabPlayback->setEnabled(false);ui->tabDownload->setEnabled(false);ui->widgetControl->setEnabled(false);//停顿下处理事件qApp->processEvents();server->stop();server->deleteLater();server = NULL;RtpThread::Port = 6900;}//按钮触发的要保存启动状态if (sender() == ui->btnStart) {AppConfig::ServerStart = (ui->btnStart->text() == "停止服务");AppConfig::writeConfig();}
}void frmServer::on_btnConfig_clicked()
{static frmConfig *config = new frmConfig;config->show();config->activateWindow();
}void frmServer::selectVideo(const QString &deviceId, const QString &channelId)
{//视频通道按下自动选中设备通道节点QTreeWidgetItem *itemChannel = AppHelper::selectItem(ui->treeWidget, deviceId, channelId);if (itemChannel) {on_treeWidget_itemClicked(itemChannel, 0);}
}void frmServer::itemClicked(QTreeWidgetItem *item, bool dbClick)
{QString deviceId, channelId;AppHelper::getItemId(item, deviceId, channelId);ui->tabPlayback->setId(deviceId, channelId);ui->tabDownload->setId(deviceId, channelId);ui->widgetControl->setId(deviceId, channelId);if (dbClick) {ui->tabPreview->openVideo(deviceId, channelId);}
}void frmServer::on_treeWidget_itemClicked(QTreeWidgetItem *item, int)
{this->itemClicked(item, false);
}void frmServer::on_treeWidget_itemDoubleClicked(QTreeWidgetItem *item, int)
{this->itemClicked(item, true);
}

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

0x01、Redis 主从复制的实现原理是什么?

Redis 主从复制概述 Redis 的主从复制是一种机制&#xff0c;允许一个主节点&#xff08;主实例&#xff09;将数据复制到一个或多个从节点&#xff08;从实例&#xff09;。通过这一机制&#xff0c;从节点可以获取主节点的数据并与之保持同步。 复制流程 开始同步&#xf…

整活 kotlin + springboot3 + sqlite 配置一个 SQLiteCache

要实现一个 SQLiteCache 也是很简单的只需要创建一个 cacheManager Bean 即可 // 如果配置文件中 spring.cache.sqlite.enable false 则不启用 Bean("cacheManager") ConditionalOnProperty(name ["spring.cache.sqlite.enable"], havingValue "t…

深入探索如何压缩 WebAssembly

一、初始体积&#xff1a;默认 Release 构建 我们从最基础的构建开始&#xff0c;不开启调试符号&#xff0c;仅使用默认的 release 模式&#xff1a; $ wc -c pkg/wasm_game_of_life_bg.wasm 29410 pkg/wasm_game_of_life_bg.wasm这是我们优化的起点 —— 29,410 字节。 二…

多角度分析Vue3 nextTick() 函数

nextTick() 是 Vue 3 中的一个核心函数&#xff0c;它的作用是延迟执行某些操作&#xff0c;直到下一次 DOM 更新循环结束之后再执行。这个函数常用于在 Vue 更新 DOM 后立即获取更新后的 DOM 状态&#xff0c;或者在组件渲染完成后执行某些操作。 官方的解释是&#xff0c;当…

前端面试-自动化部署

基础概念 什么是CI/CD&#xff1f;在前端项目中如何应用&#xff1f;自动化部署相比手动部署有哪些优势&#xff1f;常见的自动化部署工具有哪些&#xff1f;举例说明它们的区别&#xff08;如Jenkins vs GitHub Actions&#xff09;。如何通过Git Hook实现自动化部署&#xf…

架构生命周期(高软57)

系列文章目录 架构生命周期 文章目录 系列文章目录前言一、软件架构是什么&#xff1f;二、软件架构的内容三、软件设计阶段四、构件总结 前言 本节讲明架构设计的架构生命周期概念。 一、软件架构是什么&#xff1f; 二、软件架构的内容 三、软件设计阶段 四、构件 总结 就…

GPTNet如何革新创意与效率

引言 人工智能正在以前所未有的速度改变我们的工作与生活方式&#xff0c;从智能写作到视觉创作&#xff0c;AI工具已成为不可或缺的伙伴。在众多平台中&#xff0c;GPTNet以其强大的功能整合和直观体验崭露头角。它不仅汇集了GPT系列、Claude、Grok、Gemini等顶级对话模型&am…

【计网】SSL/TLS核心原理

序言 在HTTP协议中&#xff0c;信息是明文传输的&#xff0c;因此为了通信安全就有了HTTPS(Hyper Text Transfer Protocol over Secure Socket Layer)协议。HTTPS也是一种超文本传送协议&#xff0c;在HTTP的基础上加入了SSL/TLS协议&#xff0c;SSL/TLS依靠证书来验证服务端的…

Web Components 开发与集成

以下是关于 Web Components 开发与集成 的系统知识梳理,涵盖核心概念、高级特性、集成与优化等内容: 一、Web Components 核心概念 技术作用核心 APICustom Elements定义可复用的自定义 HTML 元素customElements.define()、生命周期钩子(connectedCallback 等)Shadow DOM封…

day26 学习笔记

文章目录 前言一、图像颜色转换1.HSV颜色空间2.颜色转换 二、灰度化1.最大值法2.平均值法3.加权均值法 三、二值化1.全局阈值法1.阈值法(THRESH_BINARY)2.反阈值法(THRESH_BINARY_INV)3.截断阈值法(THRESH_TRUNC)4.低阈值零处理(THRESH_TOZERO)5.超阈值零处理(THRESH_TOZERO_IN…

威锋VL822-Q7T10GHUB芯片适用于扩展坞显示器

一、概述 VL822-Q7T是VIA Lab&#xff08;威盛电子旗下专注于USB相关技术研发的子公司&#xff09;精心打造的一款高性能USB 3.1 Gen2集线器控制器芯片。在当今数字化时代&#xff0c;USB接口作为设备连接与数据传输的核心通道&#xff0c;其性能与稳定性至关重要。VL822-Q7T凭…

华为OD机试真题——最小的调整次数/特异性双端队列(2025A卷:100分)Java/python/JavaScript/C++/C语言/GO六种最佳实现

2025 A卷 100分 题型 本文涵盖详细的问题分析、解题思路、代码实现、代码详解、测试用例以及综合分析&#xff1b; 并提供Java、python、JavaScript、C、C语言、GO六种语言的最佳实现方式&#xff01; 2025华为OD真题目录全流程解析/备考攻略/经验分享 华为OD机试真题《最小的调…

关于 Spring Boot 微服务解决方案的对比,并以 Spring Cloud Alibaba 为例,详细说明其核心组件的使用方式、配置及代码示例

以下是关于 Spring Boot 微服务解决方案的对比&#xff0c;并以 Spring Cloud Alibaba 为例&#xff0c;详细说明其核心组件的使用方式、配置及代码示例&#xff1a; 关于 Spring Cloud Alibaba 致力于提供微服务开发的一站式解决方案! https://sca.aliyun.com/?spm7145af80…

常见的爬虫算法

1.base64加密 base64是什么 Base64编码&#xff0c;是由64个字符组成编码集&#xff1a;26个大写字母AZ&#xff0c;26个小写字母az&#xff0c;10个数字0~9&#xff0c;符号“”与符号“/”。Base64编码的基本思路是将原始数据的三个字节拆分转化为四个字节&#xff0c;然后…

B树、红黑树、B+树和平衡二叉树(如AVL树)的区别

B树、红黑树、B树和平衡二叉树&#xff08;如AVL树&#xff09;的区别及优缺点的总结&#xff1a; 1. 平衡二叉树&#xff08;AVL树&#xff09; 结构&#xff1a;二叉搜索树&#xff0c;每个节点的左右子树高度差不超过1。平衡方式&#xff1a;通过旋转&#xff08;左旋/右旋…

Python Cookbook-6.5 继承的替代方案——自动托管

任务 你需要从某个类或者类型继承&#xff0c;但是需要对继承做一些调整。比如&#xff0c;需要选择性地隐藏某些基类的方法&#xff0c;而继承并不能做到这一点。 解决方案 继承是很方便的&#xff0c;但它并不是万用良药。比如&#xff0c;它无法让你隐藏基类的方法或者属…

长短期记忆网络:从理论到创新应用的深度剖析

一、引言 1.1 研究背景 深度学习在人工智能领域的发展可谓突飞猛进&#xff0c;而长短期记忆网络&#xff08;LSTM&#xff09;在其中占据着至关重要的地位。随着数据量的不断增长和对时序数据处理需求的增加&#xff0c;传统的神经网络在处理长序列数据时面临着梯度消失和梯…

vue3.2 + element-plus 实现跟随input输入框的弹框,弹框里可以分组或tab形式显示选项

效果 基础用法&#xff08;分组选项&#xff09; 高级用法&#xff08;带Tab栏&#xff09; <!-- 弹窗跟随通用组件 SmartSelector.vue --> <!-- 弹窗跟随通用组件 --> <template><div class"smart-selector-container"><el-popove…

C语言中冒泡排序和快速排序的区别

冒泡排序和快速排序都是常见的排序算法&#xff0c;但它们在原理、效率和应用场景等方面存在显著区别。以下是两者的详细对比&#xff1a; 一、算法原理 1. 冒泡排序 原理&#xff1a;通过重复遍历数组&#xff0c;比较相邻元素的大小&#xff0c;并在必要时交换它们的位置。…

软件信息安全性测试如何进行?有哪些注意事项?

随着信息技术的高速发展&#xff0c;软件已经成为我们生活和工作中不可或缺的一部分。然而&#xff0c;随着软件产品的广泛普及&#xff0c;软件信息安全性问题也日益凸显&#xff0c;因此软件信息安全性测试必不可少。那么软件信息安全性测试应如何进行呢?在进行过程中又有哪…