exercise: add an client server demo

Author: CodeWater404

exercise/interview/client_server/client.go

@@ -0,0 +1,41 @@
+package main
+
+import (
+	"fmt"
+	"net"
+)
+
+/**
+  @author: CodeWater
+  @since: 2024/3/7
+  @desc: $
+**/
+
+func main() {
+	// 连接服务器
+	conn, err := net.Dial("tcp", "localhost:8080")
+	if err != nil {
+		fmt.Println("连接服务器失败:", err)
+		return
+	}
+	defer conn.Close()
+
+	// 发送消息给服务器
+	msg := "Hello"
+	_, err = conn.Write([]byte(msg))
+	if err != nil {
+		fmt.Println("发送消息失败:", err)
+		return
+	}
+	fmt.Println("已向服务器发送消息:", msg)
+
+	// 接收服务器回复的消息
+	buffer := make([]byte, 1024)
+	n, err := conn.Read(buffer)
+	if err != nil {
+		fmt.Println("接收服务器回复消息失败:", err)
+		return
+	}
+	serverMsg := string(buffer[:n])
+	fmt.Println("服务器回复消息:", serverMsg)
+}

exercise/interview/client_server/server.go

@@ -0,0 +1,57 @@
+package main
+
+import (
+	"fmt"
+	"net"
+)
+
+/**
+  @author: CodeWater
+  @since: 2024/3/7
+  @desc: $
+**/
+
+func handleConnection(conn net.Conn) {
+	defer conn.Close()
+
+	// 接收客户端发送的消息
+	buffer := make([]byte, 1024)
+	n, err := conn.Read(buffer)
+	if err != nil {
+		fmt.Println("接收消息失败:", err)
+		return
+	}
+	clientMsg := string(buffer[:n])
+	fmt.Println("客户端消息:", clientMsg)
+
+	// 回复客户端消息
+	reply := "你好"
+	_, err = conn.Write([]byte(reply))
+	if err != nil {
+		fmt.Println("回复消息失败:", err)
+		return
+	}
+	fmt.Println("已向客户端回复:", reply)
+}
+
+func main() {
+	// 监听端口
+	listener, err := net.Listen("tcp", ":8080")
+	if err != nil {
+		fmt.Println("监听端口失败:", err)
+		return
+	}
+	defer listener.Close()
+	fmt.Println("服务器已启动，等待客户端连接...")
+
+	// 接受客户端连接
+	for {
+		conn, err := listener.Accept()
+		if err != nil {
+			fmt.Println("接受客户端连接失败:", err)
+			continue
+		}
+		fmt.Println("客户端连接成功:", conn.RemoteAddr())
+		go handleConnection(conn)
+	}
+}