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

国标GB28181协议国标视频智能分析平台EasyGBS运行过程中日志持续打印导致存量过大的问题排查

程序员文章站 2022-07-06 09:42:38
...

国标GB28181视频智能分析平台EasyGBS运行过程中,每个步骤都会通过日志打印来反馈运行的成功与否,正常情况下,每个步骤的日志会打印一次,如果重新建立连接或者重新开启某一步骤,则会重复打印运行情况,日志是TSINGSEE青犀视频运维团队排查问题时的一种依据。

国标GB28181协议国标视频智能分析平台EasyGBS运行过程中日志持续打印导致存量过大的问题排查

EasyGBS国标安防视频可视化平台在运行中,我们发现日志一直在打印,导致日志过大,对服务的运行带来了阻碍,经过排查日志内容发现是一个推流地址被重复推流导致的。

国标GB28181协议国标视频智能分析平台EasyGBS运行过程中日志持续打印导致存量过大的问题排查

随后我们排查了代码,了解到当有多个设备开启非按需直播时,重启EasyGBS后,程序会自动对摄像头进行视频流保活,但是因为传入的是通道指针所以导致,同样的通道被传入了多次,造成了同一路设备流播放多次的情况,引发日志频繁打印错误。

if start {
		if _, ok := atsMap.Load(key); !ok {
			atsMap.Store(key, true)
			go func(channelInfo *models.Channel, key string) {
				ticker := time.NewTicker(15 * time.Second)
				defer ticker.Stop()
				//先执行一次
				sipDev := Server.GetDevice(channelInfo.DeviceID)
				if sipDev != nil {
					StreamStart(sipDev, channelInfo.ToSIPChannel(), "", false, "", "", "")
				}
				for {
					select {
					case <-ticker.C:
						if _, ok := atsMap.Load(key); !ok {
							return
						}
						sipDev := Server.GetDevice(channelInfo.DeviceID)
						if sipDev != nil {
							log.Println("key===", key, "===========sipDev DeviceID===", sipDev.DeviceID)
							StreamStart(sipDev, channelInfo.ToSIPChannel(), "", false, "", "", "")
						}
					}
				}
			}(channelInfo, key)
		}

所以需要对传入参数进行只传递,不使用引用传递,参考代码如下:

func AutoTouchStream(channelInfo *models.Channel, start bool) {
	key := fmt.Sprintf("%s_%s", channelInfo.DeviceID, channelInfo.ID)
	fmt.Println("AutoTouchStream======key", key)
	if start {
		if _, ok := atsMap.Load(key); !ok {
			atsMap.Store(key, true)
			go func(channelInfo models.Channel, key string) {
				ticker := time.NewTicker(15 * time.Second)
				defer ticker.Stop()
				//先执行一次
				sipDev := Server.GetDevice(channelInfo.DeviceID)
				if sipDev != nil {
					StreamStart(sipDev, channelInfo.ToSIPChannel(), "", false, "", "", "")
				}
				for {
					select {
					case <-ticker.C:
						if _, ok := atsMap.Load(key); !ok {
							return
						}
						sipDev := Server.GetDevice(channelInfo.DeviceID)
						if sipDev != nil {
							log.Println("key===", key, "===========sipDev DeviceID===", sipDev.DeviceID)
							StreamStart(sipDev, channelInfo.ToSIPChannel(), "", false, "", "", "")
						}
					}
				}
			}(*channelInfo, key)
		}

经过验证,日志过大问题得到解决,再次打印的日志如下,情况恢复正常。

国标GB28181协议国标视频智能分析平台EasyGBS运行过程中日志持续打印导致存量过大的问题排查

EasyGBS国标视频流媒体平台的一大特点就是支持通过GB28181协议与第三方国标平台进行级联,也能够接收TSINGSEE青犀视频平台EasyNVR的级联,如果大家对EasyGBS的级联功能或者告警功能比较感兴趣,欢迎联系我们了解,EasyGBS、EasyNVR等视频平台均提供试用版本供大家测试,欢迎咨询。

国标GB28181协议国标视频智能分析平台EasyGBS运行过程中日志持续打印导致存量过大的问题排查

相关标签: EasyGBS