基于WVP的轻量化智能监控平台-程序员宅基地

技术标签: java  人工智能  http  数据库  分布式  

当代智能监控平台不乏功能强大的产品,但由于涉及模块、组件多,产品容易臃肿,对私有化场景增加了一定的阻碍。于是,轻量化智能监控平台很有必要。

下面为大家一一介绍~

01. WVP是什么?

WEB VIDEO PLATFORM是一个基于GB28181-2016标准实现的开箱即用的网络视频平台,负责实现核心信令与设备管理后台部分,支持NAT穿透,支持海康、大华、宇视等品牌的IPC、NVR接入。支持国标级联,支持将不带国标功能的摄像机/直播流/直播推流转发到其他国标平台。

02. 基于WVP平台的智能监控产品

在WVP开源框架的基础上进行重构和融合,把强大的业务功能与WVP开源的强大底层视频支撑能力进行结合,构建新的智能监控平台。新的智能监控平台更加轻量化、功能更全面、部署更快捷。

03. Web服务端技术架构

0a4ed77e2950cd7e88085e409710e5fe.png

各组件责任与功能:

  1. 1.  摄像头:提供视频流(国标摄像头需注册到Sip服务器);

  2. 2.  Sip Server:国标摄像头sip信令鉴权,提供国标摄像头注册、注销、心跳,保活、开流、关流等一系列摄像头服务;

  3. 3.  ZLMediaKit:流媒体服务器(一个基于C++11的高性能运营级流媒体服务框架),提供各种视频流协议推拉流直播点播等服务;

  4. 4. KubeEdge:一套开源的边缘计算平台,负责从MediaKit拉取视频流,抽帧,调取AI接口获取事件,并存放到Kafka消息队列中,实时监控设备在离线状态等;

  5. 5. AI服务:提供多种人脸识别,入侵检测,吸烟检测等多种算法的AI服务;

  6. 6.  OSS:AI事件的图片、视频等储存服务,由KubeEdge实时上传;

  7. 7. Kafka:消息队列(KubeEdge与Web服务端之间),存放与传输KubeEdge检测出的AI事件;

  8. 8.  Web Server:web服务端,提供设备管理、技能管理、事件管理、数据统计、数据分析等一系列web后端功能;

  9. 9.  MongoDB:云存事件、AI事件的储存;

  10. 10. Mysql:Web服务端数据的储存;

  11. 11. Milvus数据库:储存人脸特征向量,并提供一系列人脸比对功能;

  04. 摄像头技能下发时序图

上图描述了如何赋予摄像头AI技能:

  1. 1.  前端将页面每个摄像头配置了对应技能的信息按照一定的格式储存为json字符串传递给web服务端 ;

  2. 2.  Web服务端将摄像头技能信息储存数据库同时,透传并下发给边缘端,消费Kafka的AI事件;

  3. 3.  KudeEdge实时从MediaKit拉取视频流,并根据Web服务端下发的技能信息进行抽帧,调AI接口,并将检测到的事件上传到S3,存入Kafka消息队列;

  4. 4.  S3:储存来自KudeEdge上传的图片与小视频,并提供URL下载地址;

  5. 5.  Kafka:接收从KudeEdge生产过来的事件,提供给Web服务端进行消费。

  05. 国标摄像机SIP信令注册流程图

91ce302bc5f1cf718189df7d9b5a23f8.png

  1. 1. 提前分配好摄像头用户名密码。

  2. 2. 国标摄像机后台填写好Sip服务器IP,用户名密码,国标Id,通道ID等相关信息,点击确定。

  3. 3. 摄像头会主动向填写的Sip地址发送注册请求。

  4. 4. Sip服务器会携带相关的鉴权字段,并返回401。

  5. 5. 摄像头拿到鉴权信息并重新发送注册请求,返回200成功。

       该鉴权方法为Digest鉴权算法,常用于国标摄像机,1400摄像机等注册流程。

    06. 国标摄像头实时开流技术架构

a5af280683a50478cf32ddf22bea6fe4.png

1. 媒体流接收者向SIP服务器发送 Invite消息;

2. SIP服务器收到Invite请求后,向媒体服务器发送 Invite消息;

3. 媒体服务器收到SIP服务器的 Invite请求后,回复200 OK响应;

4. SIP服务器收到媒体服务器返回的200 OK响应后,向媒体流发送者发送 Invite请求;

5. 媒体流发送者收到SIP服务器的Invite请求后,回复200 OK响应;

6. SIP服务器收到200 OK响应后向媒体服务器发送ACK请求, 完成与媒体服务器的Invite会话建立过程;

7. SIP服务器收到媒体流发送者返回的200 OK 响应后,向媒体流发送者发送ACK请求,完成与媒体流发送者的Invite会话建立过程;

8. 完成三方呼叫控制后,SIP服务器通过B2BUA代理方式建立媒体流接收者和媒体服务器之间的媒体连接;

9. 媒体服务器收到Invite请求,回复200OK响应,携带SDP消息体,消息体中描述了媒体服务器发送媒体流的IP端口、媒体格式SSRC值等内容;

10. SIP服务器将消息9转发给媒体流接收者;

11. 媒体流接收看收到200 OK响应后回复ACK消息,完成与SHP服务器的Invite会话建立过程;

12. SIP服务器将消息11转发给媒体服务器完成与媒体服务器的-Invite会话建立过程;

13. 最终两端都收到ack确认码后,媒体服务器将实时流推送给媒体接收者(播放端)。

07. 功能展示

总览页如下图:

2f935bc8d326dfa7c28f9c0403de88d8.png

de49db237f5c6c40110839ce53b84540.png

支持的核心功能:

1. 支持海康,RTSP,国标等多种协议;

2. 技能配置;

3. 技能下发;

4. 事件的告警,统计等数据可视化,数据分析;

5. 设备管理;

6. 地图定位;

7. 云存回看;

8. 实时播放;

9. 车牌库;

10. 人脸库管理。

已实现的AI技能如下图:

d47c5f1f8059e36b82e693204873fc86.png

08. 技术创新

使用MongoDb取代原先的Mysql来接收事件数据:

假如一家企业接入100路摄像头,每个摄像头平均5秒产生一个事件,预计每天将会有接近200万的数据进入数据库。对于海量数据库存储,为提高存储和查询效率,决定使用MongoDB。(Mysql:90ms, Mongo:10ms)

边缘端使用KubeEdge灵活调度盒子:

无需手动配置摄像头给盒子。根据负载情况灵活将摄像头分配到不同盒子(pod)。以前一个盒子就是一个单体,机器跑着一个服务,现在集群方式,服务跑在pod(盒子)上,可灵活调度pod。缓解摄像头拉流,抽帧,调AI接口等高频操作的压力,提高效率。

事件的图片和小视频分两次上报:

能更快获取到时间信息,提高告警时效性。

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/qihoo_tech/article/details/127543791

智能推荐

初始Linux的基本操作_桌面操作系统,手机操作系统,服务器操作系统,嵌入式操作系统-程序员宅基地

文章浏览阅读652次。Linux的相关概念和理解Linux的基本指令ls,cd,pwd, touch, mkdir, whoami, tree, adduser, userdel实现_桌面操作系统,手机操作系统,服务器操作系统,嵌入式操作系统

centos8使用命令修改主机名_centos8stream 关于的名称-程序员宅基地

文章浏览阅读1.1k次。hostnamectl set-hostname layuiFilehostname #查看主机名然后先跳到普通用户再exit退到root看其生效或reboot重启生效_centos8stream 关于的名称

安卓高手之路之图形系统(6)requestLayout的流程_kotlin requestlayout-程序员宅基地

文章浏览阅读1.1w次。当一个View调用requestLayout的时候,会给当前的View设置一个FORCE_LAYOUT标记。由此向ViewParent请求布局。这样从这个View开始向上一直requestLayout。最终到达ViewRootImpl。ViewParent 就是当前的传输链。【参见职责链设计模式】 第一步。ViewRootImpl发现请求了布局。那么就会调用measure方_kotlin requestlayout

python opencv 灰度图转换和resize函数的使用_python cv2 resize(img1, ())-程序员宅基地

文章浏览阅读1.7k次。import cv2import numpy as npimg1 = cv2.imread('left.png',1)img1 = cv2.resize(img1, (797,1212))dst1 = cv2.cvtColor(img1,cv2.COLOR_BGR2GRAY)cv2.imwrite('l.png',dst1)img1 = cv2.imread('left.png',1..._python cv2 resize(img1, ())

Socket基础六:基于数据报套接字的网络程序(udp丢包测试)_数据报套接字 丢包测试-程序员宅基地

文章浏览阅读656次。Socket基础五:基于数据报套接字的网络程序(udp丢包测试)作者:刘磊 2020.4.27   参考书目:《Windows网络编程》刘琰等著一、功能函数1、int udp_server_fun_packetloss(SOCKET s){ int iResult = 0; int count = 0; struct sockaddr_in cliaddr; int addrlen = sizeof(sockaddr_in); char recvline[MAXLINE]; do_数据报套接字 丢包测试

国内elasticsearch和kibana镜像、ik分词器_ik分词器国内镜像-程序员宅基地

文章浏览阅读1.6k次。发现华为云有一个好用的国内镜像kibana各个版本下载地址:https://mirrors.huaweicloud.com/elasticsearch/kibana各个版本下载地址:https://mirrors.huaweicloud.com/kibana/ik分词器各个版本下载地址:https://github.com/medcl/elasticsearch-analysis-ik/releases亲测下载速度非常快..._ik分词器国内镜像

随便推点

Coursera—Andrew Ng机器学习—课程笔记 Lecture 5 Octave Tutorial-程序员宅基地

文章浏览阅读575次。定义函数 squareThisNumber(x),内容如下:

超级应用 - 免费应用内测托管平台|APP应用分发平台|iOS应用分发|Android应用分发|免费应用内测托管平台 源码下载_awjd1.tv-程序员宅基地

文章浏览阅读4k次。网站标题:超级应用 - 免费应用内测托管平台|APP应用分发平台|iOS应用分发|Android应用分发|免费应用内测托管平台源码下载网站关键词:超级应用(www.awwjd.com) 为您提供测试测试应用、应用托管、分发测试、兼容测试等,为客户提供APP托管和免费的下载分发渠道!源码下载网站描述:超级应用,分发平台,内测平台,内测分发,app分发,ios企业签名,ios分发平台,ios免签封装,苹果企业签名,苹果超级签名,免签封装,应用打包,苹果App下载,安卓应用,苹果应用,扫码下载,UDID,iO_awjd1.tv

阿里数据库内核月报:2017年05月-程序员宅基地

文章浏览阅读45次。# 01MySQL·引擎特性·InnoDBBufferPool# 02AliSQL·特性介绍·动态加字段# 03PgSQL·特性分析·数据库崩溃恢复(上)# 04MySQL·答疑解惑·MySQL的那些网络超时错误# 05HybridDB·最佳实践·HybridDB数据合并的方法与原理...

FPGA时序约束、时序分析(一)-程序员宅基地

文章浏览阅读163次。很多人询问关于约束、时序分析的问题,比如:如何设置setup,hold时间?如何使用全局时钟和第二全局时钟(长线资源)?如何进行分组约束?如何约束某部分组合逻辑?如何通过约束保证异步时钟域之间的数据交换可靠?如何使用I/O逻辑单元内部的寄存器资源?如何进行物理区域约束,完成物理综合和物理实现?为了解决大家的疑难,我们将逐一讨论这些问题。(注:以下主要设计时序约束)A 时序约束的概念和基本策略..._如何约束fpga寄存器到pad的延时

2024年软件测试工具总结 —— 性能测试工具_magicotp,软件测试基础入门_web页面性能测试工具-程序员宅基地

文章浏览阅读512次,点赞19次,收藏12次。WebLOAD是一款针对Web应用程序的企业级负载和性能测试工具,提供性能、完整性和可伸缩性测试等功能,能够同时模拟数千个用户,因此您可以测试重流量负载,并报告应用程序中的弱点、约束和性能瓶颈。它是一个以开发人员为中心(当然,测试人员亦可以使用,因为真的很方便),免费和开源的负载测试工具,旨在使性能测试具有生产力和令人愉悦的体验,可最大程度地减少系统资源的消耗。在线性能监控是指借助监控工具,监控系统性能的实际数据,因为是真实数据,比研发环境中通过工具产生负载得到的测试结果更客观,更有分析价值。_web页面性能测试工具

Java进制转换, 数据类型, 运算符_java 32进制递增-程序员宅基地

文章浏览阅读511次。 1:进制转换转换规则:先把数据的每一位上的系数乘以对应基数的次幂(低位从零开始),然后相加即可十进制到其他进制规则:除基取余,直到商为0,最后将余数反转十进制到二进制: 除2取余,直到商为0,最后将余数反转 例: 十进制13对应的二进制数据是1101 二进制到十进制的技巧(8421码)十进制到八进制: 除8取余,直到商为0,最后将余数反转 例: ..._java 32进制递增