TCP服务器是网络编程中非常基础的应用场景，Golang凭借简洁的语法和原生支持的并发特性，实现TCP服务器会比很多其他语言更简单高效。下面我们就一步步实现这个需求。
实现核心思路
Golang的标准库net包封装了TCP相关的底层操作，实现简单TCP服务器的核心流程可以分为三步：
- 使用
net.Listen函数在指定端口启动TCP监听，等待客户端连接 - 循环调用监听器的
Accept方法接收客户端连接，每个连接会返回一个net.Conn对象 - 针对每个连接启动独立的goroutine处理通信逻辑，避免阻塞主监听流程
完整实现代码
下面是可直接运行的简单TCP服务器代码，实现了接收客户端消息并原样返回的功能：
package main
import (
"fmt"
"net"
"bufio"
"strings"
)
func main() {
// 监听本地8080端口，协议为TCP
listener, err := net.Listen("tcp", "127.0.0.1:8080")
if err != nil {
fmt.Println("启动监听失败:", err)
return
}
defer listener.Close()
fmt.Println("TCP服务器已启动，监听地址: 127.0.0.1:8080")
// 循环接收客户端连接
for {
conn, err := listener.Accept()
if err != nil {
fmt.Println("接收连接失败:", err)
continue
}
// 启动goroutine处理当前连接，实现并发
go handleConn(conn)
}
}
// 处理单个客户端连接的函数
func handleConn(conn net.Conn) {
// 函数退出时关闭连接
defer conn.Close()
// 创建带缓冲的读取器，按行读取客户端消息
reader := bufio.NewReader(conn)
fmt.Println("新客户端连接:", conn.RemoteAddr())
for {
// 读取客户端发送的消息，直到遇到换行符
msg, err := reader.ReadString('\n')
if err != nil {
fmt.Println("客户端断开连接:", conn.RemoteAddr(), err)
return
}
// 去除消息两端的空白字符
msg = strings.TrimSpace(msg)
fmt.Printf("收到客户端 %s 的消息: %s\n", conn.RemoteAddr(), msg)
// 给客户端返回响应，原样返回收到的消息
response := fmt.Sprintf("服务器已收到: %s\n", msg)
_, err = conn.Write([]byte(response))
if err != nil {
fmt.Println("发送响应失败:", err)
return
}
}
}代码关键部分说明
监听端口
net.Listen的第一个参数指定网络协议为tcp，第二个参数是监听的地址，这里使用127.0.0.1:8080表示只监听本地回环地址的8080端口，如果需要允许外部访问可以改成:8080表示监听所有网卡。
并发处理连接
每次调用listener.Accept()获取到新连接后，使用go handleConn(conn)启动新的goroutine处理，这样主流程不会被单个连接的阻塞操作卡住，可以同时处理多个客户端的请求，这是Golang实现高并发TCP服务的核心优势。
连接数据处理
这里使用bufio.Reader按行读取客户端消息，实际开发中可以根据需求调整读取逻辑，比如读取固定长度的字节、使用自定义的协议分隔符等。处理完通信后一定要调用conn.Close()关闭连接，释放资源。
测试验证
运行上面的代码后，可以使用系统自带的telnet工具测试服务器功能：
# 打开终端输入以下命令连接服务器 telnet 127.0.0.1 8080 # 连接成功后输入任意内容按回车，就能收到服务器的响应
注意事项
- 实际生产环境中需要添加更完善的错误处理，比如监听端口被占用、客户端异常断开等场景的处理
- 如果处理大量并发连接，需要注意goroutine的数量控制，避免资源耗尽，可以结合连接池或者限流机制
- 如果需要传输二进制数据，不要用按行读取的方式，要改用
Read方法读取指定长度的字节数组 - 服务器退出时要确保所有的连接都正确关闭，避免客户端出现连接泄漏问题