答案:Golang中通过net包实现TCP通信,使用net.Listen创建服务器并Accept接收连接,为每个连接启动goroutine处理;客户端用net.Dial连接服务端,通过conn.Read/Write收发数据,最后关闭连接。示例为回声服务,服务器将客户端消息原样返回,需注意错误处理与资源释放。

在Golang中实现TCP通信主要依赖标准库中的net包。它提供了简单而强大的接口,用于创建TCP服务器和客户端。通过net.Listen监听端口,使用listener.Accept接收连接,再通过net.Dial建立客户端连接,即可完成基础的双向通信。下面从服务端和客户端两个角度详细说明实现方式。
创建TCP服务器
使用net.Listen函数启动一个TCP服务器,监听指定的IP地址和端口。通常传入"tcp"作为网络类型,以及如":8080"这样的地址表示监听本地所有网卡的8080端口。
服务器通过循环调用Accept()方法阻塞等待客户端连接。每当有新连接接入,就会返回一个net.Conn对象,代表与客户端的会话。
每个连接建议使用独立的goroutine处理,以支持并发通信。
立即学习“go语言免费学习笔记(深入)”;
- 调用
net.Listen("tcp", ":8080")启动监听 - 使用
for循环持续接收连接 - 每接受一个连接,启动一个goroutine执行处理逻辑
- 通过
conn.Read()读取客户端数据 - 使用
conn.Write()向客户端发送响应 - 处理完毕后调用
conn.Close()释放资源
实现TCP客户端
客户端使用net.Dial函数主动连接服务器。该函数同样接收网络类型和服务器地址作为参数,成功后返回一个net.Conn实例,可用于收发数据。
客户端流程相对简单:建立连接 → 发送请求 → 接收响应 → 关闭连接。
- 调用
net.Dial("tcp", "localhost:8080")连接本地服务 - 使用
conn.Write()发送数据到服务端 - 通过
conn.Read()读取服务端回传内容 - 完成交互后调用
conn.Close()断开连接
完整示例代码
以下是一个简单的回声(echo)服务示例:
服务器端:package main
import (
"io"
"log"
"net"
)
func main() {
listener, err := net.Listen("tcp", ":8080")
if err != nil {
log.Fatal(err)
}
defer listener.Close()
log.Println("Server started on :8080")
for {
conn, err := listener.Accept()
if err != nil {
log.Println("Accept error:", err)
continue
}
go handleConnection(conn)
}
}
func handleConnection(conn net.Conn) {
defer conn.Close()
buf := make([]byte, 1024)
for {
n, err := conn.Read(buf)
if err != nil {
if err != io.EOF {
log.Println("Read error:", err)
}
break
}
_, _ = conn.Write(buf[:n]) // 回写数据
}
}
客户端:
package main
import (
"fmt"
"io"
"log"
"net"
)
func main() {
conn, err := net.Dial("tcp", "localhost:8080")
if err != nil {
log.Fatal(err)
}
defer conn.Close()
_, _ = conn.Write([]byte("Hello, TCP Server!"))
buf := make([]byte, 1024)
n, err := conn.Read(buf)
if err != nil && err != io.EOF {
log.Fatal(err)
}
fmt.Printf("Received: %s\n", buf[:n])
}
运行服务器后再启动客户端,客户端发送的消息会被服务器原样返回。
基本上就这些。只要掌握Listen、Accept、Dial和Conn的基本用法,就能快速搭建可靠的TCP通信程序。注意错误处理和连接关闭,避免资源泄漏。实际项目中可在此基础上加入协议解析、心跳机制或超时控制来增强稳定性。










