---

panlei

2019-12-17 3ff1af612ee690063dceb5aa9a6e9791e6d9a943

 main.go

@@ -66,7 +66,7 @@

   go ruleserver.TimeTicker()
   go ruleserver.StartServer()

   personTrackPush()
   nReciever("ipc:///tmp/sdk-2-rules-process.ipc", deliver.PushPull, 1)
   wg.Wait()

@@ -93,8 +93,8 @@
         //_ = p.Submit(syncCalculateSum)
         Task(msg)
      } else {
         fmt.Println(err)
         logger.Info(err)
         //fmt.Println(err)
         //logger.Info(err)
      }
   }
}
@@ -126,4 +126,16 @@
   mess := f.(func(msg []byte, args *structure.SdkDatas)(protomsg.SdkMessage))(msg,args)
   return mess
}
// 启动追踪的请求
func personTrackPush(){
   p,err :=  plugin.Open("./algorithm/personTrack.so")
   if err != nil {
      panic(err)
   }
   f,err1 := p.Lookup("Push")
   if err1 != nil {
      panic("初始化人员追踪的推送函数")
   }
   go f.(func()())()
}