Go 网络编程实战：构建一个最小可用的 TCP 交互程序

Go 网络编程实战构建一个最小可用的 TCP 交互程序TCP 服务端和TCP 客户端两部分运行后能实现服务端启动后监听本地 8888 端口能同时处理多个客户端的连接并发客户端主动连接服务端你可以在客户端输入任意文字服务端会 “原样返回”Echo 回声功能交互效果客户端输入hello→ 服务端返回【服务端回声】hello客户端输入ip→ 服务端返回服务端回复127.0.0.1:63341net.ResolveTCPAddr客户端输入exit→ 客户端主动断开连接服务端提示 “客户端已断开”。实例代码// server.gopackagemainimport(bufiofmtnetstrings)// 启动TCP服务端funcstartTCPServer(){// 解析地址tcpAddr,err:net.ResolveTCPAddr(tcp,:8888)iferr!nil{fmt.Printf(解析地址失败%v\n,err)return}// 监听端口listener,err:net.ListenTCP(tcp,tcpAddr)iferr!nil{fmt.Printf(监听端口失败%v\n,err)return}deferlistener.Close()fmt.Println(等待客户端连接...)// 接受客户端连接for{conn,err:listener.AcceptTCP()// 阻塞等待新连接iferr!nil{fmt.Printf(接受连接失败%v\n,err)continue}// 并发处理每个客户端连接避免阻塞其他连接gohandleClientConn(conn)}}// 处理单个客户端连接funchandleClientConn(conn*net.TCPConn){clientAddr:conn.RemoteAddr().String()// 获取客户端地址fmt.Printf(客户端 [%s] 已连接\n,clientAddr)deferfunc(){conn.Close()fmt.Printf(客户端 [%s] 已断开连接\n,clientAddr)}()// 创建缓冲区读取客户端数据reader:bufio.NewReader(conn)for{// 读取客户端发送的数据msg,err:reader.ReadString(\n)iferr!nil{iferr.Error()EOF{return}fmt.Printf(读取客户端 [%s] 数据失败%v\n,clientAddr,err)return}msgstrings.TrimSpace(msg)ifmsgexit{return}// special command: return client addressvarresponsestringifmsgip{responseclientAddr\n}else{// 普通回声响应responsefmt.Sprintf(【服务端回声】%s\n,msg)}_,errconn.Write([]byte(response))iferr!nil{fmt.Printf(向客户端 [%s] 发送数据失败%v\n,clientAddr,err)return}fmt.Printf(客户端 [%s] 发送%s → 响应%s,clientAddr,msg,strings.TrimSpace(response))}}funcmain(){fmt.Println(启动服务...)startTCPServer()}// client.gopackagemainimport(bufiofmtnetosstrings)// 启动TCP客户端funcstartTCPClient(){// 解析服务端地址tcpAddr,err:net.ResolveTCPAddr(tcp,:8888)iferr!nil{fmt.Printf(解析服务端地址失败%v\n,err)return}// 连接服务端conn,err:net.DialTCP(tcp,nil,tcpAddr)iferr!nil{fmt.Printf(连接服务端失败%v\n,err)return}deferconn.Close()fmt.Println(输入任意文字发送输入 exit 断开连接)// 读取用户输入reader:bufio.NewReader(os.Stdin)for{fmt.Print( )input,err:reader.ReadString(\n)iferr!nil{fmt.Printf(读取输入失败%v\n,err)return}// 处理退出指令inputstrings.TrimSpace(input)ifinputexit{conn.Write([]byte(exit\n))fmt.Println(已断开与服务端的连接)return}// 向服务端发送数据_,errconn.Write([]byte(input\n))iferr!nil{fmt.Printf(发送数据失败%v\n,err)return}// 读取服务端响应response,err:bufio.NewReader(conn).ReadString(\n)iferr!nil{fmt.Printf(读取服务端响应失败%v\n,err)return}fmt.Printf(服务端回复%s,strings.TrimSpace(response))}}funcmain(){fmt.Println(启动客户端...)startTCPClient()}基础概念Net 包介绍核心协议TCP、HTTP、RPC都是基于 net 包或其上层封装实现的。实际用途日常开发中我们更多使用 Gin、gRPC 等框架直接写原生 net 包的场景有限。学习价值理解底层原理能让你在排查网络问题、调优框架时更有底气也能更好地理解 “框架到底帮你做了什么”。TCP 基本概念这部分是理论基础理解了这些后面的代码就顺理成章了数据结构TCP 是面向字节流的协议数据以流的形式传输没有天然的消息边界。传输协议可靠、面向连接的传输层协议通过三次握手建立连接四次挥手断开连接。握手 / 挥手机制三次握手确保双方都具备收发能力建立可靠连接。四次挥手确保双方数据都传输完毕优雅断开连接。服务端流程监听并接受连接ResolveTCPAddr作用将字符串形式的地址如localhost:8088解析成*net.TCPAddr对象。参数网络类型tcp地址字符串localhost:8088意义为后续的监听和连接操作提供统一的地址对象。ListenTCP作用在指定的网络和地址上启动监听。步骤使用ResolveTCPAddr创建的地址对象。设置网络协议为tcp。返回一个net.Listener接口用于后续接受连接。AcceptTCP作用从监听队列中接受一个新的客户端连接。返回一个net.Conn接口代表与客户端的连接。注意这是一个阻塞操作直到有新连接到来或发生错误。循环监听新连接核心模式在一个无限for循环中反复调用AcceptTCP。并发处理每次接受新连接后必须启动一个新的 goroutine去处理它例如go handleConn(conn)否则服务端会阻塞无法处理下一个连接。回调函数handleConn就是你之前问的handler它负责与客户端进行具体的交互。客户端流程主动发起连接DialTCP作用主动向服务端发起 TCP 连接。参数本地地址可选。由ResolveTCPAddr创建的服务端地址。返回一个net.Conn接口代表与服务端的连接。发送接收信息WriteToConn通过conn.Write()方法将数据发送到服务端。ReadFromConn通过conn.Read()方法从服务端读取响应数据。注意TCP 是流协议需要自己处理粘包问题比如定义消息长度前缀或特殊分隔符。长连接维护循环读取客户端输入客户端可以在一个循环中不断读取用户输入并发送给服务端保持连接活跃。Error 检测EOF 异常处理当Read返回io.EOF时说明服务端已经关闭了连接。断开连接通知客户端或服务端都可以主动关闭连接另一方需要检测到并做相应清理。使用场景TCP 解决「可靠传输」的问题Go 的net.TCP让实现高并发、高性能的 TCP 服务变得简单。要求「可靠传输」的长连接服务最核心场景物联网IoT设备通信智能家居、工业传感器、车载终端等设备需要和云端服务端保持长连接设备定时上报温湿度、位置、状态数据丢包会导致监控失效云端下发控制指令如「开关灯」「调整温度」需要设备确认收到Go 服务端用ListenTCP监听goroutine处理每个设备的TCPConn稳定支撑上千台设备并发。游戏服务器网游 / 手游的实时通信层如走位、攻击、聊天玩家操作指令如「移动」「释放技能」必须有序到达服务端否则画面错乱服务端实时推送其他玩家状态需要全双工通信Go 的TCPConn结合bufio做消息拆包性能和并发都能满足中小游戏需求。金融 / 支付系统银行、支付网关的私有通信协议转账、交易指令绝对不能丢包 / 重复TCP 可靠传输是底线长连接减少多次建立连接的开销提升交易速度Go 的TCP编程可轻松加解密、签名验证保障数据安全。自定义私有协议的服务替代 HTTP更轻量 / 灵活内部运维工具公司内部的服务器监控 / 管理工具自定义极简协议客户端发status→ 服务端返回 CPU / 内存占用客户端发restart→ 服务端执行重启逻辑比 HTTP 少了Header/Cookie等开销通信更高效。高性能数据传输大数据平台的节点间通信自定义协议如「数据类型 数据长度 数据内容」避免 HTTP 的文本解析开销直接二进制传输TCP 可靠传输保证大数据块完整到达。高吞吐的大数据传输文件 / 视频 / 日志文件传输工具替代FTP/SFTP的轻量文件传输服务客户端把文件按块通过TCPConn.Write发送服务端TCPConn.Read拼接TCP 保证文件块有序、不丢实现完整文件传输。日志实时采集分布式系统的日志中心业务服务器客户端通过 TCP 把日志实时发送到日志服务端日志数据不能丢失否则排查问题无依据长连接持续传输比 HTTP 轮询更高效。分布式系统 / 微服务的内部通信微服务间的 RPC 底层gRPC 底层基于 HTTP/2但 HTTP/2 本质还是 TCP 长连接自定义 RPC 框架如内部私有 RPC直接基于net.TCP实现更灵活。集群节点心跳 / 同步分布式缓存如 Redis 集群、分布式数据库如 TiDB的节点间通过 TCP 长连接发送心跳包确认节点在线、同步数据如分片信息、事务日志。网络代理 / 隧道反向代理、VPNTCP 反向代理把客户端的 TCP 连接转发到后端服务如把 8080 端口的 TCP 请求转发到 8081/8082 端口的服务实现负载均衡。简易 VPN / 内网穿透内网服务通过 TCP 隧道暴露到公网公网客户端连接隧道服务端服务端把流量转发到内网服务基于TCPConn双向转发字节流。