---

panlei

2019-12-13 9ef37b12abea2fbbc9d4d390fe7c9ae52903da92

 main.go

@@ -3,13 +3,16 @@
import (

   "flag"
   "fmt"
   "github.com/spf13/viper"
   "sync"
   "net/http"
   _ "net/http/pprof"
   "plugin"

   //"github.com/spf13/viper"
   logger "github.com/alecthomas/log4go"
   //"basic.com/valib/logger.git"
   "basic.com/valib/logger.git"
   "github.com/panjf2000/ants/v2"

   "basic.com/pubsub/protomsg.git"
@@ -26,24 +29,24 @@
var surveyPort = flag.Int("surveyPort", 40007, "survey port") //心跳
var pubPort = flag.Int("pubPort", 50007, "pubsub port")       //数据更新
var initchan = make(chan bool)
var env =  flag.String("env","pro","env set")
var env =  flag.String("env","dev","env set")

func init() {
   flag.Parse()
   // 日志初始化

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

}
func main() {
@@ -76,7 +79,7 @@
func nRecvImpl(c deliver.Deliver, index int) {
   var msg []byte
   //var wg1 sync.WaitGroup
   //p,_ := ants.NewPool(100)
   //p,_ := ants.NewPool(20)
   //syncCalculateSum := func() {
   //   Task(msg)
   //   wg1.Done()
@@ -89,6 +92,9 @@
         //wg1.Add(1)
         //_ = p.Submit(syncCalculateSum)
         Task(msg)
      } else {
         fmt.Println(err)
         logger.Info(err)
      }
   }
}