| | |
| | | |
| | | var msg []byte |
| | | var err error |
| | | msgChan := make(chan []byte,100) |
| | | //msgChan := make(chan []byte,100) |
| | | for { |
| | | select { |
| | | // case <-ctx.Done(): |
| | | // return |
| | | default: |
| | | msg, err = c.Recv() |
| | | msgChan <- msg |
| | | //msgChan <- msg |
| | | if err != nil { |
| | | logger.Info("recv error : ", err) |
| | | fmt.Println("recv error : ", err) |
| | | continue |
| | | } else { |
| | | for msg := range msgChan { |
| | | //for msg := range msgChan { |
| | | go func(msg []byte) { |
| | | logger.Debug("当前时间戳:",time.Now().Unix()) |
| | | arg := ruleserver.SdkDatas{} |
| | |
| | | //事件推送 |
| | | //go labelFilter.Judge(resultMsg) |
| | | }(msg) |
| | | } |
| | | //} |
| | | } |
| | | } |
| | | } |