panlei
2019-12-16 35f6dd60f51b44b1e6b4ddaacd17f95b9aa87edc
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()())()
}