tcp server 用于给andriod 客户端定时发送消息
liuxiaolong
2020-07-28 89a3b406aabf07ba6faf0b6eb2a0c147d62b75d5
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)
}