add hub flag

liuxiaolong

2019-06-06 22955cd5a948ace0f497c9d618914607f86dba5c

 server.go

@@ -19,6 +19,7 @@
var sec = flag.Int("sec", 10, "the second for query data. ")

var Level = flag.String("level","ErrorLevel","log level")
var IsHub = flag.String("hub", "hub", "hub is personIsHub=1")

func main() {
   flag.Parse()
@@ -41,6 +42,7 @@

   for {
      conn, err := listener.Accept()//

      connArr = append(connArr,conn)
      if err != nil {
         log.Log.Infoln("some connecion error: ", err)
@@ -56,13 +58,12 @@
   ech := make(chan error)
   go func(conn net.Conn, ech chan error) {
      buf := make([]byte, 10)
      for {
         readMsg, err := conn.Read(buf)
         log.Log.Infoln("Read completed,readMsg:",readMsg,",err:",err)
         ech <- err
         break
      }
      readMsg, err := conn.Read(buf)
      log.Log.Infoln("Read completed,readMsg:",readMsg,",err:",err)
      ech <- err

   }(conn, ech)

   tick := time.NewTicker(10 * time.Second)

   for {
@@ -77,16 +78,16 @@
         conn.Close()
         return
      }

   }

   log.Log.Infoln("Client at " + remoteAddr + " disconnected.")
}

func handleMessage(conn net.Conn, connArr []net.Conn) bool {
   jsonstring := esutil.PostAction(*sec, *Eurl, *Picurl)
   jsonstring := esutil.PostAction(*sec, *Eurl, *Picurl, *IsHub)
   if jsonstring == nil {
      log.Log.Infoln("the data is nil,remoteArr:",conn.RemoteAddr())
      conn.Write([]byte("\000"))
      return true
   }
   jsonstring = append(jsonstring, []byte("\000")...)