conn close log

liuxiaolong

2019-05-31 c7cfafb13d36512f3e73457e94c26e31dedf5f7a

 server.go

@@ -2,6 +2,7 @@

import (
   "flag"
   "fmt"
   "net"
   "strconv"
   "time"
@@ -10,8 +11,9 @@
   log "github.com/long/test/log"
)

var addr = flag.String("addr", "192.168.1.124", "The address to listen to;")
var addr = flag.String("addr", "0.0.0.0", "The address to listen to;")
var Eurl = flag.String("eurl", "http://192.168.1.182:9200/", "The port to listen on; ")
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. ")
@@ -19,8 +21,7 @@
func main() {
   flag.Parse()

   log.Log.Infoln("starting server...")

   fmt.Println(*port)
   src := *addr + ":" + strconv.Itoa(*port)
   listener, err := net.Listen("tcp", src)
   if err != nil {
@@ -29,18 +30,22 @@
   }
   log.Log.Infof("Listening on %s.\n", src)

   fmt.Println("starting server success.")
   defer listener.Close()

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

   for {
      conn, err := listener.Accept()
      conn, err := listener.Accept()//
      connArr = append(connArr,conn)
      if err != nil {
         log.Log.Errorf("some connecion error: %s\n", err)
      }
      go handleConnection(conn)
      go handleConnection(conn,connArr)
   }
}

func handleConnection(conn net.Conn) {
func handleConnection(conn net.Conn, connArr []net.Conn) {
   remoteAddr := conn.RemoteAddr().String()
   log.Log.Infoln("Client connected from ", remoteAddr)

@@ -57,9 +62,10 @@
   for {
      select {
      case <-tick.C:
         handleMessage(conn)
         handleMessage(conn, connArr)
      case err := <-ech:
         log.Log.Errorln(err, "remoteAddr ", remoteAddr, " close")
         conn.Close()
         break
      }
   }
@@ -67,13 +73,27 @@
   log.Log.Infoln("Client at " + remoteAddr + " disconnected.")
}

func handleMessage(conn net.Conn) {
   jsonstring := esutil.PostAction(*sec, *Eurl)
func handleMessage(conn net.Conn, connArr []net.Conn) {
   jsonstring := esutil.PostAction(*sec, *Eurl, *Picurl)
   if jsonstring == nil {
      log.Log.Infoln("the data is nil")
      return
   }
   jsonstring = append(jsonstring, []byte("\000")...)
   log.Log.Infoln("jsonstring len: ", len(jsonstring), "\000 data: ", len("\000"))
   conn.Write(jsonstring)
   _, 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)
   }
}