欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

国标GB28181协议客户端EasyGBS国标视频平台级联EasyNVR:EasyGBS如何实现调阅EasyNVR的视频通道?

程序员文章站 2022-07-06 09:31:20
...

了解我们产品的用户知道,作为音视频流媒体行业的视频能力平台设计者,我们的产品不限设备品牌只要协议支持就可以接入做流转换,其中EasyNVR主要作为RTSP协议设备/平台接入,EasyGBS主要作为GB28181协议设备/平台接入。当有的客户现场设备环境复杂,需要同时使用EasyGBS和EasyNVR两个平台,但是又不希望两个平台件是互相独立的,我们就可以考虑将EasyNVR接入到EasyGBS中,使其方便管理。上文我们已经介绍了EasyNVR接入到EasyGBS的配置过程。本文将详细描述EasyGBS如何实现调阅EasyNVR的视频通道。

EasyNVR视频监控直播解决方案

国标GB28181协议客户端EasyGBS国标视频平台级联EasyNVR:EasyGBS如何实现调阅EasyNVR的视频通道?

EasyGBS国标视频云直播解决方案

国标GB28181协议客户端EasyGBS国标视频平台级联EasyNVR:EasyGBS如何实现调阅EasyNVR的视频通道?

上一篇我们讲到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
}

实现效果图:

国标GB28181协议客户端EasyGBS国标视频平台级联EasyNVR:EasyGBS如何实现调阅EasyNVR的视频通道?

国标GB28181协议客户端EasyGBS国标视频平台级联EasyNVR:EasyGBS如何实现调阅EasyNVR的视频通道?

此时就已经将EasyNVR级联注册到EasyGBS中了,且EasyGBS已经可以看到EasyNVR的所有通道信息。如果有朋友对此种方法仍有疑问,欢迎联系我们一起探讨。视频相关解决方案均可访问TSINGSEE青犀视频,可以联系我们获取演示方案,直观感受,也可自行进行下载及测试。