国标GB28181协议客户端EasyGBS国标视频平台级联EasyNVR:EasyGBS如何实现调阅EasyNVR的视频通道?
了解我们产品的用户知道,作为音视频流媒体行业的视频能力平台设计者,我们的产品不限设备品牌只要协议支持就可以接入做流转换,其中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("aaa@qq.com%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("%aaa@qq.com%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("%aaa@qq.com%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青犀视频,可以联系我们获取演示方案,直观感受,也可自行进行下载及测试。
推荐阅读
-
如何解决国标GB28181协议EasyGBS视频平台CPU占用过高的情况?
-
国标GB28181协议客户端EasyGBS视频平台更新后界面出现滚动条是什么原因导致的?
-
国标GB28181协议客户端EasyGBS国标视频平台级联EasyNVR:EasyNVR到EasyGBS上是如何注册及注销的?
-
国标GB28181协议视频平台EasyGBS授权不限通道的情况下无法接入新通道,如何排查?
-
国标GB28181协议客户端EasyGBS视频平台如何优化告警功能接收数据的频率?
-
国标GB28181协议客户端EasyGBS国标视频平台级联EasyNVR:EasyGBS如何实现调阅EasyNVR的视频通道?
-
RTSP协议视频平台EasyNVR级联GB28181视频平台EasyGBS云台控制不可用的原因分析
-
国标GB28181协议客户端EasyGBS如何实现调阅EasyNVR视频平台的视频?
-
国标GB28181协议国标视频平台国标流媒体服务器EasyGBS向上级联多个平台设备及通道选择错位问题解析
-
国标GB28181流媒体协议客户端EasyGBS视频平台权限功能的实现