国标GB28181协议客户端EasyGBS国标视频平台级联EasyNVR：EasyGBS如何实现调阅EasyNVR的视频通道？
国标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青犀视频，可以联系我们获取演示方案，直观感受，也可自行进行下载及测试。