| | |
| | | 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) |
| | | } |
| | |
| | | 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 |
| | | } |
| | | } |
| | |
| | | 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 |
| | | } |
| | |
| | | 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); { |