| | |
| | | package main |
| | | |
| | | import ( |
| | | "errors" |
| | | "flag" |
| | | "fmt" |
| | | "net" |
| | |
| | | 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 |
| | | for { |
| | | _, err := conn.Read(buf) |
| | | log.Log.Errorln("Read completed!") |
| | | if err != nil { |
| | | ech <- err |
| | | log.Log.Errorln("Read Error!conn.Close") |
| | | break |
| | | } |
| | | } |
| | | }(conn, ech) |
| | | tick := time.NewTicker(10 * time.Second) |
| | |
| | | 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) |
| | | |
| | | //index :=0 |
| | | //for ;index < len(connArr); { |
| | | // if connArr[index] == conn{ |
| | | // connArr = append(connArr[:index],connArr[index+1:]...) |
| | | // continue |
| | | // } |
| | | // index++ |
| | | //} |
| | | } |
| | | } |