diff --git a/tcp-client-server/tcp-client/cmd/tcp-client.go b/tcp-client-server/tcp-client/cmd/tcp-client.go deleted file mode 100644 index 3948fac..0000000 --- a/tcp-client-server/tcp-client/cmd/tcp-client.go +++ /dev/null @@ -1,34 +0,0 @@ -package main - -import ( - "flag" - "fmt" - "log" - "net" -) - -func main() { - serverHostname := flag.String("hostname", "localhost", "Server hostname or IP") - serverPort := flag.Int("port", 8080, "Server port to connect to") - - tcpAddr, err := net.ResolveTCPAddr("tcp", fmt.Sprintf("%s:%d", *serverHostname, *serverPort)) - if err != nil { - log.Fatal(err) - } - conn, err := net.DialTCP("tcp", nil, tcpAddr) - if err != nil { - log.Fatal(err) - } - defer conn.Close() - - msg := "Hello, World!\n" - conn.Write([]byte(msg)) - log.Printf("Sent: %s\n", msg) - - resp := make([]byte, 1024) - n, err := conn.Read(resp) - if err != nil { - log.Fatal(err) - } - fmt.Printf("Server response: %s\n", resp[:n]) -} diff --git a/tcp-client-server/tcp-server/cmd/tcp-server.go b/tcp-client-server/tcp-server/cmd/tcp-server.go deleted file mode 100644 index 6a26252..0000000 --- a/tcp-client-server/tcp-server/cmd/tcp-server.go +++ /dev/null @@ -1,53 +0,0 @@ -package main - -import ( - "bufio" - "flag" - "fmt" - "log" - "net" - "net/textproto" - "time" -) - -func handleConnection(conn net.Conn, id int) { - - defer conn.Close() - reader := bufio.NewReader(conn) - tp := textproto.NewReader(reader) - log.Printf("New connection id:%d from %s \n", id, conn.RemoteAddr()) - - for { - if text, err := tp.ReadLine(); err != nil { - log.Printf("Connection id: %d got %s from %s closed!\n", id, err, conn.RemoteAddr()) - return - } else { - log.Print("id: ", id, " Received: ", text) - // write back to client - date := time.Now().Format(time.RFC3339Nano) - if _, err := conn.Write([]byte(fmt.Sprintf("%-40s ==> SERVER ACKed!\n", date))); err != nil { - log.Printf("Connection id: %d write back to %s failed!\n", id, conn.RemoteAddr()) - } - } - } -} - -func main() { - portNum := flag.Int("port", 8080, "Port number to listen on") - flag.Parse() - l, err := net.Listen("tcp", fmt.Sprintf(":%d", *portNum)) - if err != nil { - log.Fatal(err) - } - log.Printf("Listening on %d", *portNum) - defer l.Close() - for { - conn, err := l.Accept() - if err != nil { - log.Fatal(err) - } - file, err := conn.(*net.TCPConn).File() - defer file.Close() - go handleConnection(conn, int(file.Fd())) - } -}