首先实现TCP服务器监听8080端口，接受连接并并发处理客户端消息，回显收到的内容；然后实现TCP客户端连接服务器，发送用户输入的消息并接收响应；通过bufio按行读取数据，确保每次发送以换行符结尾；最后运行服务端和客户端程序进行测试，输入quit退出。
在Golang中实现TCP客户端和服务器非常直接，得益于标准库net包的强大支持。下面通过一个简单的例子展示如何创建一个基础的TCP服务器和客户端，实现消息的发送与接收。
1. 实现TCP服务器
一个基本的TCP服务器需要监听某个端口，接受客户端连接，并处理来自客户端的数据。
以下是一个简单TCP服务器的实现：
// server.gopackage main
立即学习“go语言免费学习笔记（深入）”；
import (
"bufio"
"fmt"
"log"
"net"
)
func main() {
// 监听本地 8080 端口
listener, err := net.Listen("tcp", ":8080")
if err != nil {
log.Fatal("监听端口失败:", err)
}
defer listener.Close()
fmt.Println("服务器已启动，正在监听 :8080...")
for {
// 接受客户端连接
conn, err := listener.Accept()
if err != nil {
log.Println("接受连接失败:", err)
continue
}
fmt.Printf("客户端 %s 已连接\n", conn.RemoteAddr())
// 处理每个连接（使用 goroutine 支持并发）
go handleConnection(conn)
}
}
func handleConnection(conn net.Conn) {
defer conn.Close()
scanner := bufio.NewScanner(conn)
for scanner.Scan() {
message := scanner.Text()
fmt.Printf("收到消息: %s\n", message)
// 回显消息给客户端
conn.Write([]byte("echo: " + message + "\n"))
}
if err := scanner.Err(); err != nil {
log.Println("读取数据出错:", err)
}
fmt.Printf("客户端 %s 已断开\n", conn.RemoteAddr())
}
2. 实现TCP客户端
客户端负责连接到服务器，发送消息，并接收服务器的响应。
// client.gopackage main
import (
"bufio"
"fmt"
"log"
"net"
"os"
)
func main() {
// 连接到本地 8080 端口的服务器
conn, err := net.Dial("tcp", "localhost:8080")
if err != nil {
log.Fatal("连接服务器失败:", err)
}
defer conn.Close()
fmt.Println("已连接到服务器")
scanner := bufio.NewScanner(os.Stdin)
fmt.Println("输入消息（回车发送），输入 'quit' 退出：")
for scanner.Scan() {
input := scanner.Text()
if input == "quit" {
break
}
// 发送消息到服务器
conn.Write([]byte(input + "\n"))
// 读取服务器响应
response, err := bufio.NewReader(conn).ReadString('\n')
if err != nil {
log.Println("读取响应失败:", err)
break
}
fmt.Printf("服务器回复: %s", response)
}
if err := scanner.Err(); err != nil {
log.Println("读取输入失败:", err)
}
fmt.Println("客户端退出")
}
3. 运行示例
打开两个终端窗口：
- 在第一个终端运行服务器：
go run server.go - 在第二个终端运行客户端：
go run client.go
在客户端输入任意文本并回车，服务器会打印收到的消息并返回“echo: xxx”，客户端将显示该响应。输入 quit 可退出客户端。
4. 关键点说明
-
并发处理：服务器使用
go handleConnection(conn)为每个连接启动一个 goroutine，实现并发处理多个客户端。 -
数据读取方式：使用
bufio.Scanner按行读取数据，适合文本协议。注意每次发送需换行符分隔消息。 -
连接关闭：确保调用
conn.Close()释放资源，避免连接泄漏。 - 错误处理：网络操作容易出错，应始终检查返回的 error 值。
