server.go
@@ -1,6 +1,8 @@ package main import ( "andriodServer/controllers" "andriodServer/router" "flag" "fmt" "strconv" @@ -36,6 +38,8 @@ config.Init(*env, *confPath) fmt.Println(*port) controllers.EsUrl = *Eurl mqAddr := "amqp://" + *mqUser + ":" + *mqPass + "@" + *mqIp + ":" + strconv.Itoa(*mqPort)+"/" conn, err := amqp.Dial(mqAddr) @@ -64,6 +68,8 @@ log.Log.Infof("Failed to declare a queue,err:",err) return } r := router.NewRouter() go r.Run("0.0.0.0:"+strconv.Itoa(*port)) handleAlarmData2MQ(q, ch) }