Go语言简易TCP客户端与服务端实现

服务端实现

服务端的核心逻辑是创建监听器并接受客户端连接。为了支持并发，每接收到一个新连接，就启动一个独立的Goroutine来处理该连接的读写操作。

第1步：创建TCP监听器

使用net.Listen函数监听指定的TCP地址和端口。在示例中，监听地址为192.168.1.27:50000。

func ServerBase() {    fmt.Println("Starting the server...")    //create listener    listener, err := net.Listen("tcp", "192.168.1.27:50000")    if err != nil {       fmt.Println("Error listening:", err.Error())       return    }    // listen and accept connections from clients:    for {       conn, err := listener.Accept()       if err != nil {          fmt.Println("Error accepting:", err.Error())          return       }       //create a goroutine for each request.       go doServerStuff(conn)    } }

第2步：处理客户端连接

定义doServerStuff函数，接收net.Conn对象。在该函数中，不断读取客户端发送的数据并打印。注意处理可能的读取错误。

func doServerStuff(conn net.Conn) {    fmt.Println("new connection:", conn.LocalAddr())    for {       buf := make([]byte, 1024)       length, err := conn.Read(buf)       if err != nil {          fmt.Println("Error reading:", err.Error())          return       }       fmt.Println("Receive data from client:", string(buf[:length]))    } }

客户端实现

客户端需要先与服务端建立TCP连接，然后通过控制台输入向服务器发送消息。程序支持循环发送，直到用户输入Q退出。

第3步：建立连接并获取用户输入

使用net.Dial连接到服务端。同时使用bufio.NewReader从标准输入读取用户名，以便在后续消息中标识发送者。

func ClientBase() {    //open connection:    conn, err := net.Dial("tcp", "192.168.1.27:50000")    if err != nil {       fmt.Println("Error dial:", err.Error())       return    }    inputReader := bufio.NewReader(os.Stdin)    fmt.Println("Please input your name:")    clientName, _ := inputReader.ReadString('\n')    inputClientName := strings.Trim(clientName, "\n")

第4步：循环发送数据

在循环中提示用户输入内容，若输入Q则退出循环。否则将用户名和内容组合后写入连接。Write方法会返回错误信息，需进行适当处理。

   //send info to server until Quit    for {       fmt.Println("What do you send to the server? Type Q to quit.")       content, _ := inputReader.ReadString('\n')       inputContent := strings.Trim(content, "\n")       if inputContent == "Q" {          return       }       _, err := conn.Write([]byte(inputClientName + " says " + inputContent))       if err != nil {          fmt.Println("Error Write:", err.Error())          return       }    } }

运行说明

由于某些IDE（如LiteIDE）可能不支持在同一环境中直接运行多个程序实例，建议在终端中使用命令行工具来同时运行服务端和客户端。

1. 启动服务端：打开一个终端窗口，执行 go run server.go 命令，确保服务端正在监听端口。
2. 启动客户端：打开另一个终端窗口，执行 go run client.go 命令，按照提示输入名称和消息。

通过这种方式，可以直观地观察到Go语言Goroutine对并发TCP请求的处理能力。

以上就是Go语言简易TCP客户端与服务端实现的详细内容，更多关于Go语言网络编程的资料请关注本站其它相关文章！