| | |
| | | |
| | | go ruleserver.TimeTicker() |
| | | go ruleserver.StartServer() |
| | | |
| | | personTrackPush() |
| | | nReciever("ipc:///tmp/sdk-2-rules-process.ipc", deliver.PushPull, 1) |
| | | wg.Wait() |
| | | |
| | |
| | | //_ = p.Submit(syncCalculateSum) |
| | | Task(msg) |
| | | } else { |
| | | fmt.Println(err) |
| | | logger.Info(err) |
| | | //fmt.Println(err) |
| | | //logger.Info(err) |
| | | } |
| | | } |
| | | } |
| | |
| | | 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()())() |
| | | } |
| | | |