| | |
| | | labelFilter.Init() |
| | | go ruleserver.TimeTicker() |
| | | go ruleserver.StartServer() |
| | | //timeEle := ruleserver.TimeElement{N: 300, InitN: 300} |
| | | //ruleserver.TimeEleList["ruleprocess"] = &timeEle |
| | | nReciever("ipc:///tmp/sdk-2-rules-process.ipc", deliver.PushPull, 1) |
| | | wg.Wait() |
| | | } |
| | |
| | | fmt.Println("recv error : ", err) |
| | | continue |
| | | } else { |
| | | //runtime.GOMAXPROCS(runtime.NumCPU()) |
| | | //logger.Debug("使用的cpu个数:",runtime.NumCPU()) |
| | | |
| | | //go func(msg []byte) { |
| | | logger.Debug("当前时间戳:", time.Now().Unix()) |
| | | log.Info("当前时间戳",time.Now().String()) |
| | | log.Warn(time.Now().Format("2006-01-02 15:04:05")) |
| | | arg := structure.SdkDatas{} |
| | | //paramFormat(msg, &arg) |
| | | start := time.Now() |
| | |
| | | resultMsg := structure.ResultMsg{SdkMessage: &m, RuleResult: arg.RuleResult} |
| | | ruleserver.GetAttachInfo(resultMsg.SdkMessage) |
| | | ruleEnd := time.Since(start) |
| | | log.Debug("规则判断完所用时间:", ruleEnd) |
| | | logger.Debug("规则判断完所用时间:", ruleEnd) |
| | | // 将打完标签的数据插入到ES |
| | | insertdata.InsertToEs(resultMsg) |
| | | esEnd := time.Since(start) |
| | | log.Debug("插入完Es所用时间:", esEnd) |
| | | logger.Debug("插入完Es所用时间:", esEnd) |
| | | //事件推送 |
| | | labelFilter.PushSomthing(resultMsg) |
| | | //}(msg) |
| | |
| | | mess := f.(func(msg []byte, args *structure.SdkDatas)(protomsg.SdkMessage))(msg,args) |
| | | return mess |
| | | } |
| | | |
| | | // 5分钟收不到消息杀死自己重启 |