在Go语言的网络编程场景中,net包是处理网络操作的核心标准库,其中的Listen函数可以快速创建监听指定网络地址的服务端,是搭建TCP服务的基础入口。通过合理配置参数和处理连接逻辑,就能实现稳定的TCP服务端程序。

net.Listen的基本用法
net.Listen的函数签名如下,它接收两个字符串参数,返回监听对象和错误信息:
func Listen(network, address string) (Listener, error)
第一个参数network指定网络类型,建立TCP服务时传入"tcp"即可,也可以传入"tcp4"表示仅使用IPv4,"tcp6"表示仅使用IPv6。第二个参数address是监听的地址和端口,格式为"ip:port",如果监听所有网卡可以省略IP部分,直接写":端口号"。
完整TCP服务搭建步骤
使用net.Listen搭建TCP服务的核心流程分为四步:创建监听、循环接收连接、处理单个连接、关闭资源。下面是完整的示例代码:
package main
import (
"bufio"
"fmt"
"net"
"strings"
)
func main() {
// 第一步:创建TCP监听,监听8080端口
listener, err := net.Listen("tcp", ":8080")
if err != nil {
fmt.Printf("创建监听失败:%vn", err)
return
}
// 函数退出时关闭监听
defer listener.Close()
fmt.Println("TCP服务已启动,监听端口8080")
// 第二步:循环接收客户端连接
for {
conn, err := listener.Accept()
if err != nil {
fmt.Printf("接收连接失败:%vn", err)
continue
}
// 启动协程处理单个连接,避免阻塞后续连接接收
go handleConn(conn)
}
}
// 处理单个客户端连接的函数
func handleConn(conn net.Conn) {
// 连接处理完成后关闭连接
defer conn.Close()
// 获取客户端地址
clientAddr := conn.RemoteAddr().String()
fmt.Printf("客户端%s已连接n", clientAddr)
// 使用bufio读取客户端发送的数据
reader := bufio.NewReader(conn)
for {
// 读取到换行符为止的数据
data, err := reader.ReadString('n')
if err != nil {
fmt.Printf("客户端%s断开连接:%vn", clientAddr, err)
return
}
// 去除数据中的换行符和回车符
data = strings.TrimSpace(data)
fmt.Printf("收到客户端%s的消息:%sn", clientAddr, data)
// 给客户端回复消息
reply := fmt.Sprintf("已收到你的消息:%sn", data)
_, err = conn.Write([]byte(reply))
if err != nil {
fmt.Printf("回复客户端%s失败:%vn", clientAddr, err)
return
}
}
}
代码逻辑说明
监听创建与错误处理
调用net.Listen之后必须判断返回的err是否为空,如果端口被占用、地址格式错误都会导致监听创建失败,此时需要终止程序或者进行重试逻辑。
连接接收与并发处理
listener.Accept()会阻塞等待新的客户端连接,当有客户端连接进来时会返回一个net.Conn对象,代表当前的连接。这里使用for循环不断调用Accept,同时使用go关键字启动协程处理每个连接,这样服务端可以同时处理多个客户端的请求,不会因为处理一个连接而阻塞其他连接的接入。
连接数据交互
net.Conn对象实现了io.Reader和io.Writer接口,所以可以使用标准的IO方法读取和写入数据。示例中使用了bufio.Reader来按行读取客户端发送的内容,处理完成后通过Write方法给客户端回复消息,实际开发中可以根据协议调整读取和写入的逻辑。
常见注意事项
- 监听地址的端口如果被其他程序占用,net.Listen会返回错误,需要确保端口没有被占用,或者动态选择可用端口。
- 每个连接处理完成后一定要调用conn.Close()关闭连接,否则会造成资源泄漏,示例中通过defer语句保证连接一定会关闭。
- 处理连接时如果读取数据返回错误,通常是客户端已经断开连接,此时可以直接结束连接处理流程。
- 如果服务需要优雅退出,可以监听系统信号,在收到退出信号时先关闭listener,再等待现有连接处理完成。
简单客户端测试代码
可以使用下面的简单客户端代码测试上面搭建的TCP服务:
package main
import (
"bufio"
"fmt"
"net"
"os"
)
func main() {
// 连接服务端
conn, err := net.Dial("tcp", "127.0.0.1:8080")
if err != nil {
fmt.Printf("连接服务端失败:%vn", err)
return
}
defer conn.Close()
// 读取服务端回复
go func() {
reader := bufio.NewReader(conn)
for {
data, err := reader.ReadString('n')
if err != nil {
return
}
fmt.Printf("收到服务端回复:%s", data)
}
}()
// 从标准输入读取内容发送给服务端
inputReader := bufio.NewReader(os.Stdin)
for {
fmt.Print("请输入要发送的内容:")
data, _ := inputReader.ReadString('n')
_, err := conn.Write([]byte(data))
if err != nil {
fmt.Printf("发送失败:%vn", err)
return
}
}
}
GolangTCP服务net_ListenGo网络编程修改时间:2026-07-11 02:39:24