remove echo server
This commit is contained in:
74
main.go
74
main.go
@@ -4,12 +4,10 @@ import (
|
|||||||
"encoding/json"
|
"encoding/json"
|
||||||
"fmt"
|
"fmt"
|
||||||
"log"
|
"log"
|
||||||
"net"
|
|
||||||
"net/http"
|
"net/http"
|
||||||
"net/http/pprof"
|
"net/http/pprof"
|
||||||
"os"
|
"os"
|
||||||
"os/signal"
|
"os/signal"
|
||||||
"strings"
|
|
||||||
"syscall"
|
"syscall"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
@@ -243,43 +241,43 @@ func main() {
|
|||||||
w.Write([]byte("1.0.0"))
|
w.Write([]byte("1.0.0"))
|
||||||
})
|
})
|
||||||
|
|
||||||
l, err := net.Listen("tcp", ":1234")
|
// l, err := net.Listen("tcp", ":1234")
|
||||||
if err == nil {
|
// if err == nil {
|
||||||
|
|
||||||
go func(listener net.Listener) {
|
// go func(listener net.Listener) {
|
||||||
conn, err := l.Accept()
|
// conn, err := l.Accept()
|
||||||
log.Printf("Accepted connection from %s\n", conn.RemoteAddr())
|
// log.Printf("Accepted connection from %s\n", conn.RemoteAddr())
|
||||||
if err != nil {
|
// if err != nil {
|
||||||
log.Fatalf("Error accepting echo connection: %v\n", err)
|
// log.Fatalf("Error accepting echo connection: %v\n", err)
|
||||||
}
|
// }
|
||||||
go func(c net.Conn) {
|
// go func(c net.Conn) {
|
||||||
defer c.Close()
|
// defer c.Close()
|
||||||
buf := make([]byte, 1024)
|
// buf := make([]byte, 1024)
|
||||||
for {
|
// for {
|
||||||
n, err := c.Read(buf)
|
// n, err := c.Read(buf)
|
||||||
if err != nil {
|
// if err != nil {
|
||||||
log.Printf("Error reading from connection: %v\n", err)
|
// log.Printf("Error reading from connection: %v\n", err)
|
||||||
break
|
// break
|
||||||
}
|
// }
|
||||||
if n == 0 {
|
// if n == 0 {
|
||||||
break
|
// break
|
||||||
}
|
// }
|
||||||
str := string(buf[:n])
|
// str := string(buf[:n])
|
||||||
if strings.HasPrefix(str, "exit") {
|
// if strings.HasPrefix(str, "exit") {
|
||||||
break
|
// break
|
||||||
}
|
// }
|
||||||
log.Println("Echoing", str)
|
// log.Println("Echoing", str)
|
||||||
_, err = c.Write([]byte(str))
|
// _, err = c.Write([]byte(str))
|
||||||
if err != nil {
|
// if err != nil {
|
||||||
log.Printf("Error writing to connection: %v\n", err)
|
// log.Printf("Error writing to connection: %v\n", err)
|
||||||
break
|
// break
|
||||||
}
|
// }
|
||||||
}
|
// }
|
||||||
}(conn)
|
// }(conn)
|
||||||
}(l)
|
// }(l)
|
||||||
} else {
|
// } else {
|
||||||
log.Printf("Error creating echo server: %v\n", err)
|
// log.Printf("Error creating echo server: %v\n", err)
|
||||||
}
|
// }
|
||||||
|
|
||||||
sigs := make(chan os.Signal, 1)
|
sigs := make(chan os.Signal, 1)
|
||||||
done := make(chan bool, 1)
|
done := make(chan bool, 1)
|
||||||
|
|||||||
Reference in New Issue
Block a user