From 04c61912ae829434122291f3706536fddbde42a0 Mon Sep 17 00:00:00 2001 From: panlei <2799247126@qq.com> Date: 星期四, 19 九月 2019 17:33:27 +0800 Subject: [PATCH] 异常处理 --- insertdata/insertDataToEs.go | 5 +++++ ruleserver/ruleToformula.go | 5 +++++ main.go | 7 +------ 3 files changed, 11 insertions(+), 6 deletions(-) diff --git a/insertdata/insertDataToEs.go b/insertdata/insertDataToEs.go index 3e3a447..945be3a 100644 --- a/insertdata/insertDataToEs.go +++ b/insertdata/insertDataToEs.go @@ -135,6 +135,11 @@ // //} //} func InsertToEs(msg ruleserver.ResultMsg) { + defer func() { + if err := recover(); err != nil { + logger.Error("es妯″潡鍎跨殑寮傚父鎹曡幏锛�",err) + } + }() InsertFace(msg, "") // 濡傛灉鏍囩涓惈鏈夋寔缁椂闂撮娆℃姤璀︾殑timeLabel鐨勮瘽鍒欎笉闇�瑕佽繃浜轰綋杩借釜锛屼笉鐒跺氨娌$殑鎻掑叆浜� fk := ruleserver.TrackOrNot(msg.RuleResult) diff --git a/main.go b/main.go index c8f71b3..424edc9 100644 --- a/main.go +++ b/main.go @@ -49,11 +49,6 @@ } func main() { //fmt.Println("缂撳瓨鍒濆鍖栧畬鎴�",<- initchan)//dbserver鍒濆鍖栧畬姣� - defer func() { - if err := recover(); err != nil { - logger.Error("鏈�澶栧眰鐨勫紓甯告崟鎹�",err.(string)) - } - }() go func() { http.ListenAndServe("0.0.0.0:8899",nil) }() @@ -132,7 +127,7 @@ func paramFormat(msg []byte, args *ruleserver.SdkDatas) protomsg.SdkMessage { defer func() { if err := recover(); err != nil { - logger.Info("瑙e寘杩囩▼鐨勯敊璇�", err.(string)) + logger.Info("瑙e寘杩囩▼鐨勫紓甯告崟鑾�", err.(string)) } }() diff --git a/ruleserver/ruleToformula.go b/ruleserver/ruleToformula.go index ae1e45a..a3f3354 100644 --- a/ruleserver/ruleToformula.go +++ b/ruleserver/ruleToformula.go @@ -116,6 +116,11 @@ // 瀵瑰崟甯у浘鍍忕殑鍒ゆ柇 thisSdkDatas 褰撳墠浼犲叆鐨勮繖甯ф暟鎹紝cacheSdkData 瀹氭椂鍣ㄩ噷缂撳瓨鐨勪竴甯ф暟鎹� 娌℃湁灏辫繑鍥瀗il (thisSdkDatas SdkDatas, cacheSdkDatas SdkDatas) func Judge(args *SdkDatas, message *protomsg.SdkMessage) { + defer func() { + if err := recover(); err != nil { + logger.Error("瑙勫垯妯″潡鍎跨殑寮傚父鎹曡幏锛�",err) + } + }() if len(args.Sdkdata) > 0 { // 鎷垮埌鏈憚鍍忔満鐨勫尯鍩� cameraPolygons := GetPolygons(args.CameraId) -- Gitblit v1.8.0