---

panlei

2019-12-13 596fe167e4bdba16b68ad9951bec0f2b077e0122

 main.go

@@ -35,18 +35,18 @@
   flag.Parse()
   // 日志初始化

   insertdata.Init(*env)
   structure.Init(*env)
   var logFile = "./logger/"
   if viper.GetString("LogBasePath") != "" {
      logFile = viper.GetString("LogBasePath")
   }
   logFile = logFile + "ruleprocess.log"
   //fmt.Println("日志地址：",logFile)
   fmt.Println("日志地址：",logFile)
   logger.Config(logFile, logger.DebugLevel)
   logger.SetSaveDays(7)
   // log4go
   //logger.LoadConfiguration("./logger/log.xml")
   logger.Info("日志初始化成功！")
   logger.Info("日志初始化成功！",logFile)

}
func main() {
@@ -78,22 +78,23 @@

func nRecvImpl(c deliver.Deliver, index int) {
   var msg []byte
   var wg1 sync.WaitGroup
   p,_ := ants.NewPool(20)
   syncCalculateSum := func() {
      Task(msg)
      wg1.Done()
   }
   wg1.Wait()
   //var wg1 sync.WaitGroup
   //p,_ := ants.NewPool(20)
   //syncCalculateSum := func() {
   //   Task(msg)
   //   wg1.Done()
   //}
   //wg1.Wait()
   var err error
   for {
      msg, err = c.Recv()
      if err == nil {
         wg1.Add(1)
         _ = p.Submit(syncCalculateSum)
         //go Task(msg)
         //wg1.Add(1)
         //_ = p.Submit(syncCalculateSum)
         Task(msg)
      } else {
         fmt.Println("接收数据失败",err)
         fmt.Println(err)
         logger.Info(err)
      }
   }
}