From e6982607fbbeaa96d3d14409df780266646b793d Mon Sep 17 00:00:00 2001 From: panlei <2799247126@qq.com> Date: 星期五, 01 十一月 2019 18:22:44 +0800 Subject: [PATCH] 换一个chan --- main.go | 326 +++++++++++++++++------------------------------------ 1 files changed, 105 insertions(+), 221 deletions(-) diff --git a/main.go b/main.go index 69e09cf..1969eb4 100644 --- a/main.go +++ b/main.go @@ -4,54 +4,70 @@ "basic.com/dbapi.git" "basic.com/pubsub/protomsg.git" "basic.com/valib/deliver.git" - "bufio" - "bytes" + "net/http" + _ "net/http/pprof" + "ruleprocess/insertdata" + "ruleprocess/labelFilter" + "ruleprocess/structure" + "ruleprocess/util" + "time" + + "basic.com/valib/logger.git" + //"bufio" + //"bytes" "flag" "fmt" "github.com/golang/protobuf/proto" - "gocv.io/x/gocv" - "image" - "image/color" - "os" + "github.com/spf13/viper" + //"gocv.io/x/gocv" + //"image" + //"image/color" + //"os" "ruleprocess/cache" - "ruleprocess/insertdata" "ruleprocess/ruleserver" - "ruleprocess/util" - "ruleprocess/logger" "sync" ) -var dbIp = flag.String("dbIp","127.0.0.1","dbserver ip") -var dbPort = flag.Int("dbPort",8001,"default dbPort=8001") -var surveyPort = flag.Int("surveyPort",40007,"survey port") //蹇冭烦 -var pubPort = flag.Int("pubPort",50007,"pubsub port") //鏁版嵁鏇存柊 -var initchan = make(chan bool) -func init () { - var logFile = "./info.log" - var logSaveDays = 15 +var dbIp = flag.String("dbIp", "127.0.0.1", "dbserver ip") +var dbPort = flag.Int("dbPort", 8001, "default dbPort=8001") +var surveyPort = flag.Int("surveyPort", 40007, "survey port") //蹇冭烦 +var pubPort = flag.Int("pubPort", 50007, "pubsub port") //鏁版嵁鏇存柊 +var initchan = make(chan bool) +var env = flag.String("env","pro","env set") + +func init() { + flag.Parse() // 鏃ュ織鍒濆鍖� + + insertdata.Init(*env) + var logFile = "./logger/" + if viper.GetString("LogBasePath") != "" { + logFile = viper.GetString("LogBasePath") + } + logFile = logFile + "ruleprocess.log" + fmt.Println("鏃ュ織鍦板潃锛�",logFile) logger.Config(logFile, logger.DebugLevel) - logger.SetSaveDays(logSaveDays) - logger.Info("loginit success !") + logger.SetSaveDays(7) + logger.Info("鏃ュ織鍒濆鍖栨垚鍔燂紒") } func main() { + //fmt.Println("缂撳瓨鍒濆鍖栧畬鎴�",<- initchan)//dbserver鍒濆鍖栧畬姣� + go func() { + http.ListenAndServe("0.0.0.0:8899",nil) + }() flag.Parse() wg := sync.WaitGroup{} - wg.Add(2) + wg.Add(3) - dbapi.Init(*dbIp,*dbPort) - go cache.Init(initchan,*dbIp,*surveyPort,*pubPort) - logger.Info("cache init completed!!!",<- initchan)//dbserver鍒濆鍖栧畬姣� - //fmt.Println("缂撳瓨鍒濆鍖栧畬鎴�",<- initchan)//dbserver鍒濆鍖栧畬姣� - + dbapi.Init(*dbIp, *dbPort) + go cache.Init(initchan, *dbIp, *surveyPort, *pubPort) + logger.Info("cache init completed!!!", <-initchan) //dbserver鍒濆鍖栧畬姣� + ruleserver.Init() + labelFilter.Init() go ruleserver.TimeTicker() + go ruleserver.StartServer() nReciever("ipc:///tmp/sdk-2-rules-process.ipc", deliver.PushPull, 1) wg.Wait() - //resp,err := DrawPolygonOnImage() - //if err != nil { - // logger.Println("鐢绘鎴栬�呬笂浼犳湁闂") - //} - //logger.Println(resp["fileUrl"].(string)) } func nReciever(url string, m deliver.Mode, count int) { c := deliver.NewServer(m, url) @@ -62,36 +78,48 @@ var msg []byte var err error - + //msgChan := make(chan []byte,100) for { select { // case <-ctx.Done(): // return default: msg, err = c.Recv() + //msgChan <- msg if err != nil { logger.Info("recv error : ", err) fmt.Println("recv error : ", err) continue } else { - arg := ruleserver.SdkDatas{} - m := paramFormat(msg, &arg) - logger.Info("瑙f瀽鍑烘潵鐨勬暟鎹細", arg) - ruleserver.Judge(&arg) - // 鎶奱rg閲岀殑鎵撶殑鏍囩鎷垮嚭鏉ョ粰m鍐嶅皝瑁呬竴灞� - resultMag := ruleserver.ResultMsg{SdkMessage: m, RuleResult: arg.RuleResult} - //logger.Info("鎵撳畬鏍囩鍚庣殑缁撴灉锛�",resultMag) - - // 灏嗘墦瀹屾爣绛剧殑鏁版嵁鎻掑叆鍒癊S - insertdata.InsertToEs(resultMag) + //runtime.GOMAXPROCS(runtime.NumCPU()) + //logger.Debug("浣跨敤鐨刢pu涓暟锛�",runtime.NumCPU()) + //go func(msg []byte) { + logger.Debug("褰撳墠鏃堕棿鎴筹細", time.Now().Unix()) + arg := structure.SdkDatas{} + //paramFormat(msg, &arg) + start := time.Now() + m := paramFormat(msg, &arg) + // 杩涜瑙勫垯澶勭悊鍒ゆ柇(鎵撲笂瑙勫垯鐨勬爣绛�) + ruleserver.Judge(&arg, &m) // 鎶妔dkMessage浼犺繘鍘伙紝鏂逛究缂撳瓨鏁版嵁鏃舵嫾鍑轰竴涓猺esultMag + // 鎶奱rg閲岀殑鎵撶殑鏍囩鎷垮嚭鏉ョ粰m鍐嶅皝瑁呬竴灞� + resultMsg := structure.ResultMsg{SdkMessage: &m, RuleResult: arg.RuleResult} + logger.Debug("瑙勫垯鍒ゆ柇瀹屾墍鐢ㄦ椂闂达細", time.Since(start)) + // 灏嗘墦瀹屾爣绛剧殑鏁版嵁鎻掑叆鍒癊S + insertdata.InsertToEs(resultMsg) + logger.Debug("鎻掑叆瀹孍s鎵�鐢ㄦ椂闂达細", time.Since(start)) + //浜嬩欢鎺ㄩ�� + labelFilter.PushSomthing(resultMsg) + //}(msg) } } } } + // 灏嗗閮ㄤ紶杩涙潵鐨剅ect锛坱op,bottom,left,right锛夎浆鍖栦负鑷繁鍐呴儴鐨剅ect(left top width height) -func rectFormat(rcobj *protomsg.Rect) ruleserver.Rect { - rect := ruleserver.Rect{} +func rectFormat(rcobj *protomsg.Rect) structure.Rect { + //logger.Info("++++++++++++++++++++++++++++++鏀跺埌鐨剏olo鐨勫尯鍩熷潗鏍囷細",rcobj) + rect := structure.Rect{} rect.X = float64(rcobj.Left) rect.Y = float64(rcobj.Top) rect.Width = float64(rcobj.Right - rcobj.Left) @@ -100,10 +128,10 @@ } // 灏嗗閮ㄤ紶杩涙潵鐨剆dk鏁版嵁鍖呰В鎴� SdkDatas -func paramFormat(msg []byte, args *ruleserver.SdkDatas) protomsg.SdkMessage { +func paramFormat(msg []byte, args *structure.SdkDatas) protomsg.SdkMessage { defer func() { if err := recover(); err != nil { - logger.Info("瑙e寘杩囩▼鐨勯敊璇�", err.(string)) + logger.Info("瑙e寘杩囩▼鐨勫紓甯告崟鑾�", err.(string)) } }() @@ -113,7 +141,11 @@ if err != nil { panic("瑙f瀽msg鏃跺嚭鐜伴敊璇�") } + + // 鍏堣繘琛屼竴涓嬭拷韪� + ruleserver.FaceIsSame(&m) args.CameraId = m.Cid + args.TaskId = m.Tasklab.Taskid // 鎶婂浘鐗囩殑浜岃繘鍒惰В鍘嬬缉杩涜鐢绘鍦ㄥ帇缂╁洖鍘� bdata, err := util.UnCompress(m.Data) if err != nil { @@ -121,25 +153,26 @@ } i := protomsg.Image{} err = proto.Unmarshal(bdata, &i) + logger.Info("鎺ュ埌鏁版嵁锛屾憚鍍忔満涓猴細", m.Cid, "鍥剧墖鐨刬d涓猴細", i.Id) //logger.Info("----------------鐪嬬湅鏈夊嚑涓畻娉曪細",len(m.Tasklab.Sdkinfos)) for _, sdkinfo := range m.Tasklab.Sdkinfos { // yolo绠楁硶 if sdkinfo.Sdktype == "Yolo" { - arg := ruleserver.SdkData{} + arg := structure.SdkData{} arg.TaskId = m.Tasklab.Taskid - arg.SdkId = sdkinfo.Sdkid - arg.SdkName = sdkinfo.SdkName + arg.IpcId = sdkinfo.Ipcid arg.IsYolo = true - bdata, err := util.UnCompress(m.Data) - if err != nil { - panic("瑙e帇缂╁浘鐗囨椂鍑虹幇閿欒") - } - i := protomsg.Image{} - err = proto.Unmarshal(bdata, &i) + //bdata, err := util.UnCompress(m.Data) + //if err != nil { + // panic("瑙e帇缂╁浘鐗囨椂鍑虹幇閿欒") + //} + //i := protomsg.Image{} + //err = proto.Unmarshal(bdata, &i) arg.ImageWidth = int(i.Width) arg.ImageHeight = int(i.Height) // 鏆傛椂鍐欐锛宻dk杩樻病鏈夎繖淇╃畻娉� arg.KeepRight = false arg.IsStatic = false + logger.Info("-----杩借釜涔嬪悗sdkinfo.Sdkdata鐨勯暱搴︿负锛�----", len(sdkinfo.Sdkdata)) if len(sdkinfo.Sdkdata) > 1 { // 澶т簬1鎵嶆湁鏁版嵁 yoloParam := protomsg.ParamYoloObj{} @@ -148,31 +181,33 @@ logger.Info("瑙f瀽YOLO sdk鏁版嵁鏃跺嚭鐜伴敊璇�", err) continue } - logger.Info("------褰撳墠绠楁硶name",sdkinfo.SdkName,"--------------鐪嬬湅yolo涓湁鍑犱釜鐩爣锛�",len(yoloParam.Infos)) + var yoloNum int = 0 for _, info := range yoloParam.Infos { if info.Typ == 0 { - photoMap := ruleserver.PhotoMap{Rects: rectFormat(info.RcObj), Score: float64(info.Prob)*100,IsYolo:true} + //logger.Debug("-------------yolo鐨勫潗鏍囨湁鍑犱釜",info.RcObj) + photoMap := structure.PhotoMap{Rects: rectFormat(info.RcObj), Score: float64(info.Prob) * 100, IsYolo: true,Id:info.ObjID} arg.Photo = append(arg.Photo, photoMap) + yoloNum++ } } - args.Sdkdata = append(args.Sdkdata,&arg) + logger.Info("--------------杩借釜涔嬪悗yolo鐨勪釜鏁帮細", yoloNum) + args.Sdkdata = append(args.Sdkdata, &arg) } else { continue } } if sdkinfo.Sdktype == "FaceDetect" { // 浜鸿劯妫�娴� - arg := ruleserver.SdkData{} + arg := structure.SdkData{} arg.TaskId = m.Tasklab.Taskid - arg.SdkId = sdkinfo.Sdkid - arg.SdkName = sdkinfo.SdkName + arg.IpcId = sdkinfo.Ipcid arg.IsYolo = false - bdata, err := util.UnCompress(m.Data) - if err != nil { - panic("瑙e帇缂╁浘鐗囨椂鍑虹幇閿欒") - } - i := protomsg.Image{} - err = proto.Unmarshal(bdata, &i) + //bdata, err := util.UnCompress(m.Data) + //if err != nil { + // panic("瑙e帇缂╁浘鐗囨椂鍑虹幇閿欒") + //} + //i := protomsg.Image{} + //err = proto.Unmarshal(bdata, &i) arg.ImageWidth = int(i.Width) arg.ImageHeight = int(i.Height) // 鏆傛椂鍐欐锛宻dk杩樻病鏈夎繖淇╃畻娉� @@ -185,168 +220,17 @@ logger.Info("瑙f瀽FACE sdk鏁版嵁鏃跺嚭鐜伴敊璇�", err) continue } - logger.Info("------褰撳墠绠楁硶name",sdkinfo.SdkName,"--------------鐪嬬湅浜鸿劯妫�娴嬩腑鏈夊嚑涓洰鏍囷細",len(faceParam.Faces)) + logger.Info("--------------杩借釜涔嬪悗浜鸿劯鐨勪釜鏁帮細", len(faceParam.Faces)) for _, info := range faceParam.Faces { - photoMap := ruleserver.PhotoMap{Rects: rectFormat(info.Pos.RcFace), Score: float64(info.Pos.Quality)*100, IsYolo:false,ThftRes:*(info.Result)} + //logger.Info("_______________________________________________绗竴娆$湅鐩镐技鍊硷細",info.Pos.FAngle.Confidence*100) + photoMap := structure.PhotoMap{Id: info.Pos.FaceID, Rects: rectFormat(info.Pos.RcFace), Score: float64(info.Pos.FAngle.Confidence * 100), IsYolo: false, ThftRes: *(info.Result), Feature: info.Feats} arg.Photo = append(arg.Photo, photoMap) } - args.Sdkdata = append(args.Sdkdata,&arg) + args.Sdkdata = append(args.Sdkdata, &arg) } else { continue } } - if sdkinfo.Sdktype == "FaceExtract" { // 浜鸿劯鎻愬彇 - arg := ruleserver.SdkData{} - arg.TaskId = m.Tasklab.Taskid - arg.SdkId = sdkinfo.Sdkid - arg.SdkName = sdkinfo.SdkName - arg.IsYolo = false - bdata, err := util.UnCompress(m.Data) - if err != nil { - panic("瑙e帇缂╁浘鐗囨椂鍑虹幇閿欒") - } - i := protomsg.Image{} - err = proto.Unmarshal(bdata, &i) - arg.ImageWidth = int(i.Width) - arg.ImageHeight = int(i.Height) - // 鏆傛椂鍐欐锛宻dk杩樻病鏈夎繖淇╃畻娉� - arg.KeepRight = false - arg.IsStatic = false - if len(sdkinfo.Sdkdata) > 1 { - faceParam := protomsg.ParamFaceFeature{} - err = proto.Unmarshal(sdkinfo.Sdkdata, &faceParam) - if err != nil { - logger.Info("瑙f瀽FACE sdk鏁版嵁鏃跺嚭鐜伴敊璇�", err) - continue - } - for _,faceExtCom := range faceParam.ExtComp { - binfos := protomsg.Binfos{} - err := proto.Unmarshal(faceExtCom.Comp, &binfos) - if err != nil { - logger.Info("瑙f瀽浜鸿劯姣斿鏁版嵁鏃跺嚭鐜伴敊璇�", err) - continue - } - logger.Info("_________________________________________________________________瑙f瀽鍑虹殑浜鸿劯鐨勭浉浼肩殑搴曞簱鏁版嵁",binfos.Infos[0].CompareScore) - } - logger.Info("------褰撳墠绠楁硶name",sdkinfo.SdkName,"--------------鐪嬬湅浜鸿劯鎻愬彇涓湁鍑犱釜鐩爣锛�",len(faceParam.ExtComp)) - for _, extComp := range faceParam.ExtComp { - baseinfos := protomsg.Binfos{} - err1 := proto.Unmarshal(extComp.Comp, &baseinfos) - if err1 != nil { - logger.Info("瑙f瀽FACE sdk鏁版嵁鏃跺嚭鐜伴敊璇�", err) - continue - } - photoMap := ruleserver.PhotoMap{Rects: rectFormat(extComp.Pos.Pos.RcFace), Score: float64(extComp.Pos.Pos.Quality)*100, IsYolo:false,ThftRes:*(extComp.Pos.Result),Liker:baseinfos.Infos} - arg.Photo = append(arg.Photo, photoMap) - } - args.Sdkdata = append(args.Sdkdata,&arg) - } else { - continue - } - } - } return m } - -func DrawPolygonOnImage()(maps map[string]interface{}, err0 error){ - // draw the rook - //rook := gocv.NewMatWithSize(w, w, gocv.MatTypeCV8UC3) - //imgs := gocv.NewMat() - ddd, err := RetrieveROM("./105.jpg") - if err != nil { - logger.Info("瑙g爜鏈夎",err) - } - bbb := bytes.NewBuffer(ddd) // 蹇呴』鍔犱竴涓猙uffer 涓嶇劧娌℃湁read鏂规硶灏变細鎶ラ敊 - rook, _ := gocv.NewMatFromBytes(500, 500, gocv.MatTypeCV8UC3, bbb.Bytes()) - defer rook.Close() - green := color.RGBA{0, 255, 0, 0} - points := [][]image.Point{ - { - image.Pt(100., 100), - image.Pt(100., 400), - image.Pt(400, 400), - image.Pt(400, 100), - }, - } - gocv.FillPoly(&rook, points, green) - // 涓婁紶 - //fdata,_ := gocv.IMEncode(".jpg",rook) - //body := &bytes.Buffer{} - //writer := multipart.NewWriter(body) - //_, err1 := writer.CreateFormFile("file", "fasjuierf") - //if err1 != nil { - // return nil, err1 - //} - //boundary := writer.Boundary() - ////close_string := fmt.Sprintf("\r\n--%s--\r\n", boundary) - //close_buf := bytes.NewBufferString(fmt.Sprintf("\r\n--%s--\r\n", boundary)) - //file := bytes.NewBuffer(fdata) - //request_reader := io.MultiReader(body, file, close_buf) - ////_, err = io.Copy(part, file) - ////writer.WriteField(key, val) - //request, err := http.NewRequest("POST", "http://192.168.1.182:6333/submit", request_reader) - //request.Header.Add("Content-Type", writer.FormDataContentType()) - //timeout := time.Duration(5 * time.Second) //瓒呮椂鏃堕棿50ms - //client := &http.Client{Timeout: timeout} - //resp, err := client.Do(request) - //if err != nil { - // logger.Fatal(err) - // return nil, err - //} - //defer func() { - // if r := recover(); r != nil { - // fmt.Printf("panic鐨勫唴瀹�%v\n", r) - // msg := "涓婁紶鍥剧墖鏈嶅姟鍣ㄥ紓甯�" - // if _, ok := r.(error); ok { - // msg = r.(error).Error() - // logger.Info("panic--recover()寰楀埌鐨勬槸error绫诲瀷") - // } - // if _, ok := r.(string); ok { - // msg = r.(string) - // logger.Info("panic--recover()寰楀埌鐨勬槸string绫诲瀷") - // } - // err0 = errors.New(msg) - // } - //}() - //defer resp.Body.Close() - //{ - // body := &bytes.Buffer{} - // _, err := body.ReadFrom(resp.Body) - // if err != nil { - // logger.Fatal(err) - // } - // logger.Info(resp.StatusCode) - // //logger.Info(resp.Header) - // logger.Info(body) - // //decoder := json.NewDecoder(strings.NewReader(body.String())) - // decoder := make(map[string]interface{}) - // if err := json.Unmarshal([]byte(body.String()), &decoder); err != nil { - // return nil, err - // } - return nil, nil - //} -} - -// 鎶婂浘鐗囪浆鎴愪簩杩涘埗娴� -func RetrieveROM(filename string) ([]byte, error) { - file, err := os.Open(filename) - - if err != nil { - return nil, err - } - defer file.Close() - - stats, statsErr := file.Stat() - if statsErr != nil { - return nil, statsErr - } - - var size int64 = stats.Size() - bytes := make([]byte, size) - - bufr := bufio.NewReader(file) - _, err = bufr.Read(bytes) - - return bytes, err -} \ No newline at end of file -- Gitblit v1.8.0