net.Listen("tcp", ":8080") 创建 TCP 服务端监听器,需指定网络类型和地址格式,配合 listener.Accept() 和 goroutine 处理并发连接,并注意错误处理、资源释放与协议分包。

怎么用 net.Listen 创建 TCP 服务端
Go 的 net.Listen 是启动 TCP 服务端的第一步,它返回一个 net.Listener 接口,后续靠它接收连接。注意必须指定完整的网络类型和地址格式,常见错误是写成 "localhost:8080" 或漏掉 "tcp"。
正确写法是 "tcp" + ":端口号"(监听所有网卡)或 "127.0.0.1:端口号"(仅本地)。绑定已占用端口会 panic,建议加错误检查。
listener, err := net.Listen("tcp", ":8080")
if err != nil {
log.Fatal("无法启动服务端:", err)
}
defer listener.Close()-
net.Listen("tcp4", ...)和net.Listen("tcp6", ...)可分别强制 IPv4/IPv6,避免双栈行为不一致 - Windows 上某些端口(如 1–1023)需要管理员权限
- 如果程序要支持快速重启,可设置
SO_REUSEADDR:用net.ListenConfig{Control: controlFunc}配合syscall.SetsockoptInt
如何安全地 accept 并处理多个 TCP 连接
listener.Accept() 是阻塞调用,每次返回一个 net.Conn。不加 goroutine 直接处理会导致新连接被卡住——这是新手最常踩的坑。必须为每个连接启一个 goroutine,但要注意连接生命周期管理,防止 goroutine 泄漏。
for {
conn, err := listener.Accept()
if err != nil {
log.Println("接受连接失败:", err)
continue // 不要 break,否则服务停止
}
go handleConnection(conn) // 每个连接独立协程
}-
handleConnection函数里务必用defer conn.Close(),否则连接资源不释放 - 若需限制并发连接数,可在 accept 前加计数器 + channel 控制,或用
semaphore库 - 客户端断开时
conn.Read会返回io.EOF,不是错误,应正常退出该 goroutine
TCP 客户端怎么 dial 并可靠收发数据
net.Dial 是客户端建立连接的入口,和服务端一样,参数是 "tcp" + "host:port"。常见错误是传入未解析的域名(如 "example.com:80")且 DNS 不通,导致超时久;或没设超时,卡死在 dial 阶段。
立即学习“go语言免费学习笔记(深入)”;
行盟APP是结合了通信和互联网的优势,加之云计算所拥有的强大信息资源,借助广大的终端传递服务,潜在的拥有巨大商机。她到底是什么,又有什么作用?她是一款手机应用软件;她是一款专门为企业服务的手机应用软件;她是一款能够将企业各种信息放入其中并进行推广传播的手机应用软件!只要轻轻一点,企业的简介,产品信息以及其他优势就能最快最大限度的透过手机展现在客户的眼前,一部手机,一个APP,你面对的将是一个6亿&
conn, err := net.Dial("tcp", "127.0.0.1:8080")
if err != nil {
log.Fatal("连接失败:", err)
}
defer conn.Close()
, = conn.Write([]byte("Hello Server\n"))
buf := make([]byte, 1024)
n, _ := conn.Read(buf)
log.Printf("收到:%s", string(buf[:n]))
- 生产环境强烈建议用
net.DialTimeout或&net.Dialer{Timeout: 5 * time.Second}显式控制连接超时 - TCP 是字节流,
Read不保证一次读完所有数据,也不保证一次只读一条消息;需自行按协议分包(比如加长度头、换行符分隔) - 不要混用
fmt.Fprintln(conn, ...)和conn.Write,底层缓冲行为可能不一致
为什么 Read/Write 经常卡住或丢数据
根本原因在于 TCP 没有“消息边界”概念。你调用一次 Write,对方可能分多次 Read 到;也可能一次 Read 拿到多条消息。没有应用层协议约定,通信必然错乱。
简单场景可用换行符分隔(\n),复杂场景推荐固定头长+内容长度方式。Go 标准库的 bufio.Scanner 默认按行扫描,适合文本协议;bufio.Reader.ReadString('\n') 更可控。
scanner := bufio.NewScanner(conn)
for scanner.Scan() {
line := scanner.Text()
if line == "quit" {
break
}
conn.Write([]byte("Echo: " + line + "\n"))
}-
scanner.Scan()内部会自动处理缓冲和换行,但单次读取上限默认 64KB,超长行会报scanner.Err();可通过scanner.Buffer(make([]byte, 64), 1 调大 - 二进制协议必须自己解析 header:先读 4 字节长度,再按该长度读 payload
- 别依赖
conn.SetReadDeadline后就不管了——每次 Read 前都得重设,否则第二次就超时
实际跑起来后最容易忽略的是连接异常终止后的清理:goroutine 是否真退出、error 是否被忽略、buffer 是否复用导致脏数据。这些不会立刻报错,但压测或长时间运行时一定会暴露。









