国标GB28181协议客户端EasyGBS国标视频平台级联EasyNVR:EasyGBS如何实现调阅EasyNVR的视频通道?
了解TSINGSEE青犀视频产品的用户知道,作为音视频流媒体行业的视频能力平台设计者,TSINGSEE青犀视频的产品不限设备品牌只要协议支持就可以接入做流转换,其中EasyNVR主要作为RTSP协议设备/平台接入,EasyGBS主要作为GB28181协议设备/平台接入。当有的客户现场设备环境复杂,需要同时使用EasyGBS和EasyNVR两个平台,但是又不希望两个平台件是互相独立的,我们就可以考虑将EasyNVR接入到EasyGBS中,使其方便管理。上文我们已经介绍了EasyNVR接入到EasyGBS的配置过程。本文将详细描述EasyGBS如何实现调阅EasyNVR的视频通道。
EasyNVR视频监控直播解决方案
EasyGBS国标视频云直播解决方案
上一篇我们讲到EasyNVR已经成功注册到EasyGBS了(EasyNVR到EasyGBS上是如何注册及注销的)。但是EasyGBS的设备列表界面看到EasyNVR的设备通道数为0,肯定是不合理的,我们如何将EasyNVR的通道传递给EasyGBS,然后通过EasyGBS调阅EasyNVR通道呢?
我们观察EasyGBS和EasyNVR的通道列表,进行对比发现,EasyGBS的通道ID长度都是20位字符串,而EasyNVR的通道ID都是1-16这样的数字。我们的EasyGBS产品文档里面写明了,EasyGBS设备里面得通道ID必须是20位,如果想实现通道互通,就需要通过自定义一个方法将EasyNVR的通道ID计算成EasyGBS中的ID。
/**
通过计算将nvr的通道ID转为gbs需要的通道ID
*/
func CalcChannelId(channelId uint) (channel string) {
channelIdStr := "34020000001310000000"
idStr := strconv.Itoa(int(channelId))
id := channelIdStr[0 : len(channelIdStr)-len(idStr)]
channel = id + idStr
return channel
}
EasyNVR级联注册到EasyGBS中之后,通过文档和日志可以发现EasyGBS会向EasyNVR发送一个请求,让EasyNVR将自己的通道上传上去。因为EasyNVR并不是真正的摄像头,而是我们虚构的一个边缘设备,通过gb28181协议来交互,所以我们需要修改EasyNVR上传通道的逻辑。
case "catalog":
//上传通道
_ = c.Req.MakeResponse().SendByTransport(c.Transport)
var caremas []models.Camera
models.DB.Model(models.Camera{}).Find(&caremas)
err := c.Client.MakeCataLogRequest(serial, c.Client.Cascade.Realm, sn, caremas)
if err != nil {
log.Printf("make catalog request failed, %v", err)
return
}
//log.Printf("级联上传通道: make catalog request caremas: %v", caremas)
c.Client.DevCache.Set(fmt.Sprintf("cascade_channels@%d", c.Client.Cascade), caremas, -1)
真正上传通道的逻辑在MakeCataLogRequest方法里面,只将通道ID、通道名称、在线状态这关键字段上传过去即可。
func (c *Client) MakeCataLogRequest(toSerial, toRealm, sn string, cameras []models.Camera) (err error) {
if len(cameras) == 0 {
doc := etree.NewDocument()
doc.CreateProcInst("xml", fmt.Sprintf(`version="1.0" encoding="%s"`, c.Cascade.Charset))
resp := doc.CreateElement("Response")
resp.CreateElement("CmdType").SetText("Catalog")
resp.CreateElement("SN").SetText(sn)
resp.CreateElement("DeviceID").SetText(c.LocalSerial)
resp.CreateElement("SumNum").SetText(strconv.Itoa(len(cameras)))
//deviceList := resp.CreateElement("DeviceList")
var body string
body, err = doc.WriteToString()
if err != nil {
return
}
if strings.ToLower(c.Cascade.Charset) == "gb2312" {
if _body, err := global.UTF82GBK([]byte(body)); err == nil {
body = string(_body)
}
}
var req *Request
req, err = c.MakeRequest("MESSAGE", fmt.Sprintf("%s@%s", toSerial, toRealm), body)
if err != nil {
return
}
req.SetHeader("Content-Type", XML_CONTENT_TYPE)
err = req.SendByTransport(c.Transport)
if err != nil {
log.Printf("catalog request send failed, %v", err)
return
}
} else {
for _, camera := range cameras {
// camera开启后才有channel,通过channelId获取channel
channelInfo := channels.GetChannel(camera.ID)
var online = "OFF"
if channelInfo != nil {
if channelInfo.Online == 1 {
online = "ON"
} else {
online = "OFF"
}
}
doc := etree.NewDocument()
doc.CreateProcInst("xml", fmt.Sprintf(`version="1.0" encoding="%s"`, c.Cascade.Charset))
resp := doc.CreateElement("Response")
resp.CreateElement("CmdType").SetText("Catalog")
resp.CreateElement("SN").SetText(sn)
resp.CreateElement("DeviceID").SetText(c.LocalSerial)
resp.CreateElement("SumNum").SetText(strconv.Itoa(len(cameras)))
deviceList := resp.CreateElement("DeviceList")
channelId := CalcChannelId(camera.ID)
//一次只上传一个通道
deviceList.CreateAttr("Num", strconv.Itoa(1))
item := deviceList.CreateElement("Item")
item.CreateElement("DeviceID").SetText(channelId)
item.CreateElement("Name").SetText(camera.Name)
item.CreateElement("Status").SetText(online)
doc.Indent(4)
var body string
body, err = doc.WriteToString()
if err != nil {
return
}
if strings.ToLower(c.Cascade.Charset) == "gb2312" {
if _body, err := global.UTF82GBK([]byte(body)); err == nil {
body = string(_body)
}
}
var req *Request
req, err = c.MakeRequest("MESSAGE", fmt.Sprintf("%s@%s", toSerial, toRealm), body)
if err != nil {
return
}
req.SetHeader("Content-Type", XML_CONTENT_TYPE)
err = req.SendByTransport(c.Transport)
if err != nil {
log.Printf("catalog request send failed, %v", err)
return
}
}
}
return
}
实际效果图:
此时就已经将EasyNVR级联注册到EasyGBS中了,且EasyGBS已经可以看到EasyNVR的所有通道信息。如果有朋友对此种方法仍有疑问,欢迎联系我们一起探讨。视频相关解决方案均可访问TSINGSEE青犀视频,可以联系我们获取演示方案,直观感受,也可自行进行下载及测试。
- ASM 翻译系列第十五弹:ASM Internal ASM File Directory
- ASM 翻译系列第十六弹:ASM Internal ASM Active Change Directory
- ASM 翻译系列第十七弹:ASM Internal ASM Disk Directory
- Windows 7下获取System权限
- ASM 翻译系列第十八弹:ASM Internal ASM file number 5
- 菜单式Shell运维脚本调试小记
- 优化Postgres-x2 GTM
- 启用某些Linux发行版的root帐号
- Linux中的完美截图工具:Deepin-ScreenShot
- ASM 翻译系列第二十弹:ASM Internal ASM file number 7
- Linux:awk命令详解
- 给已安装的Linux新增Swap交换分区
- ASM 翻译系列第二十一弹:ASM Attributes Directory
- Linux:sed命令详解
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- Android自定义控件实现时钟效果
- Android倒计时控件 Splash界面5秒自动跳转
- Android仿抖音上下滑动布局
- 一个简单的Android轨迹动画
- Android自定义圆环倒计时控件
- Android 使用URLConnection下载音频文件的方法
- Android自定义TimeButton实现倒计时按钮
- android自定义圆形倒计时显示控件
- android实现上下左右滑动界面布局
- Android使用MediaCodec将摄像头采集的视频编码为h264
- Android开发人脸识别登录功能
- Android利用碎片fragment实现底部标题栏(Github模板开源)
- Android MediaPlayer 播放音频的方式
- Android切圆角的几种常见方式总结
- Android DSelectorBryant 单选滚动选择器的实例代码