tcp server 用于给andriod 客户端定时发送消息
fix
liuxiaolong
2021-05-19 ed8c09655a43d9ec44142fb968e5abfbb69416cb
server.go
@@ -18,7 +18,7 @@
//var Picurl = flag.String("picurl", "http://58.118.225.79:41242/", "picture url")
var port = flag.Int("port", 6000, "The port to listen on")
var sec = flag.Int("sec", 10, "the second for query data")
var sec = flag.Int("sec", 20, "the second for query data")
var Level = flag.String("level","ErrorLevel","log level")
var IsHub = flag.String("hub", "hub", "hub is personIsHub=1")
@@ -53,6 +53,21 @@
   }
   defer ch.Close()
   ////如果有多个客户端接收,需要改为广播模式
   //exErr := ch.ExchangeDeclare(
   //   "alarmExchange",
   //   "fanout",
   //   false,
   //   false,
   //   false,
   //   false,
   //   nil,
   //)
   //if exErr != nil {
   //   log.Log.Infof("Failed to declare a exchange,err:", exErr)
   //   return
   //}
   q, err := ch.QueueDeclare(
      "alarm2Android", // name
      false,   // durable