when conn'num>50 close all,client reconn

liuxiaolong

2019-06-04 130d52d6dff343a1096fcdc04f01c649beda35d2

 server.go

@@ -5,6 +5,7 @@
   "fmt"
   "net"
   "strconv"
   "strings"
   "time"

   "github.com/long/test/esutil"
@@ -19,7 +20,7 @@
var sec = flag.Int("sec", 10, "the second for query data. ")

var Level = flag.String("level","ErrorLevel","log level")

//var ipMap map[string]net.Conn
func main() {
   flag.Parse()

@@ -39,11 +40,21 @@

   connArr:=make([]net.Conn,0)

   //ipMap = make(map[string]net.Conn,0)
   for {
      conn, err := listener.Accept()//

      //clientIpPort := conn.RemoteAddr().String()
      //index := strings.Index(clientIpPort, ":")
      //ipStr := clientIpPort[:index-1]
      //if oldConn,ok := ipMap[ipStr];ok {
      //   oldConn.Close()
      //}
      //ipMap[ipStr] = conn

      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)
   }
@@ -56,48 +67,54 @@
   ech := make(chan error)
   go func(conn net.Conn, ech chan error) {
      buf := make([]byte, 10)
      _, err := conn.Read(buf)
      if err != nil {
         ech <- err
      }
      readMsg, err := conn.Read(buf)
      log.Log.Infoln("Read completed,readMsg:",readMsg,",err:",err)
      ech <- err

   }(conn, ech)
   go func(conArray []net.Conn) {
      for {
         if len(conArray)>50 {
            for _,connEach :=range conArray{
               connEach.Close()
            }
            return
         }
         time.Sleep(200*time.Second)
      }
   }(connArr)
   tick := time.NewTicker(10 * time.Second)

   for {
      select {
      case <-tick.C:
         handleMessage(conn, connArr)
         if !handleMessage(conn, connArr){
            conn.Close()
            return
         }
      case err := <-ech:
         log.Log.Errorln(err, "remoteAddr ", remoteAddr, " close")
         log.Log.Infoln(err, "remoteAddr ", remoteAddr, " close")
         conn.Close()
         break
         return
      }

   }

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

func handleMessage(conn net.Conn, connArr []net.Conn) {
func handleMessage(conn net.Conn, connArr []net.Conn) bool {
   jsonstring := esutil.PostAction(*sec, *Eurl, *Picurl)
   if jsonstring == nil {
      log.Log.Infoln("the data is nil")
      return
      log.Log.Infoln("the data is nil,remoteArr:",conn.RemoteAddr())
      return true
   }
   jsonstring = append(jsonstring, []byte("\000")...)
   log.Log.Infoln("jsonstring len: ", len(jsonstring), "\000 data: ", len("\000"))
   _, err := conn.Write(jsonstring)
   if err !=nil{
      fmt.Println("conn: ",conn)
      log.Log.Errorln(err)
      conn.Close()
      index :=0
      for ;index < len(connArr); {
         if connArr[index] == conn{
            connArr = append(connArr[:index],connArr[index+1:]...)
            continue
         }
         index++
      }
      fmt.Println("connArr: ",connArr)
      log.Log.Infoln("conn.WriteErr:",err)
      return false
   }
   return true
}