| | |
| | | "bufio" |
| | | "bytes" |
| | | "flag" |
| | | "fmt" |
| | | "github.com/golang/protobuf/proto" |
| | | "gocv.io/x/gocv" |
| | | "image" |
| | |
| | | dbapi.Init(*dbIp,*dbPort) |
| | | go cache.Init(initchan,*dbIp,*surveyPort,*pubPort) |
| | | logger.Info("cache init completed!!!",<- initchan)//dbserver初始化完毕 |
| | | //fmt.Println("缓存初始化完成",<- initchan)//dbserver初始化完毕 |
| | | |
| | | go ruleserver.TimeTicker() |
| | | nReciever("ipc:///tmp/sdk-2-rules-process.ipc", deliver.PushPull, 1) |
| | |
| | | msg, err = c.Recv() |
| | | if err != nil { |
| | | logger.Info("recv error : ", err) |
| | | fmt.Println("recv error : ", err) |
| | | continue |
| | | } else { |
| | | arg := ruleserver.SdkDatas{} |