tcp server 用于给andriod 客户端定时发送消息
liuxiaolong
2019-06-01 1c62ece5b48728079823c3963c51317a9c2f5635
server.go
@@ -43,7 +43,7 @@
      conn, err := listener.Accept()//
      connArr = append(connArr,conn)
      if err != nil {
         log.Log.Errorf("some connecion error: %s\n", err)
         log.Log.Infoln("some connecion error: ", err)
      }
      go handleConnection(conn,connArr)
   }
@@ -58,10 +58,10 @@
      buf := make([]byte, 10)
      for {
         _, err := conn.Read(buf)
         log.Log.Errorln("Read completed!")
         log.Log.Infoln("Read completed!")
         if err != nil {
            ech <- err
            log.Log.Errorln("Read Error!conn.Close")
            log.Log.Infoln("Read Error!conn.Close")
            break
         }
      }
@@ -73,7 +73,7 @@
      case <-tick.C:
         handleMessage(conn, connArr)
      case err := <-ech:
         log.Log.Errorln(err, "remoteAddr ", remoteAddr, " close")
         log.Log.Infoln(err, "remoteAddr ", remoteAddr, " close")
         conn.Close()
         break
      }
@@ -92,7 +92,7 @@
   log.Log.Infoln("jsonstring len: ", len(jsonstring), "\000 data: ", len("\000"))
   _, err := conn.Write(jsonstring)
   if err !=nil{
      log.Log.Errorln(err)
      log.Log.Infoln("conn.WriteErr:",err)
      //index :=0
      //for ;index < len(connArr); {