server client initial code

assignment1/client.go

+package main
+
+import (
+	"fmt"
+	"net"
+	"os"
+	"bufio"
+	"encoding/gob"
+)
+
+func client() {
+	conn, err := net.Dial("tcp", "localhost:5000")
+	//defer conn.Close()
+
+	if err != nil {
+		fmt.Println("Err:", err)
+		return
+	}
+
+	reader := bufio.NewReader(os.Stdin)
+	for {
+		msg, _ := reader.ReadString('\n')
+		fmt.Println(msg)
+		err = gob.NewEncoder(conn).Encode(msg)
+		if err != nil {
+			fmt.Println("Err:", err)
+		}
+	}
+}
+
+func main() {
+	go client()
+	var input string
+	fmt.Scanln(&input)
+}

assignment1/server.go

+package main
+
+import (
+	"fmt"
+	"encoding/gob"
+	"net"
+)
+
+func startServer() {
+	fmt.Println("Server started")
+	listener, err := net.Listen("tcp", ":5000")
+	if err != nil {
+		panic("Could not start server!")
+	}
+
+	//infinite loop
+	for {
+		conn, err := listener.Accept()
+		if err != nil {
+			fmt.Println(err)
+			continue
+		}
+
+		go handleClient(conn)
+	}
+}
+
+func handleClient(conn net.Conn) {
+	//defer conn.Close()
+	var msg string
+	for {
+		err := gob.NewDecoder(conn).Decode(&msg)
+		if err != nil {
+			//fmt.Println("Err: ", err)
+		} else {
+			fmt.Println("Received: ", msg)
+		}
+	}
+}
+
+func main() {
+	go startServer()
+	var input string
+	fmt.Scanln(&input)
+}