Golang net TCP与UDP网络通信实践

Go语言中net包支持TCP与UDP编程。1. TCP通过net.Listen监听,Accept接收连接,每连接启goroutine处理;2. UDP用net.ListenUDP监听,ReadFromUDP收包,WriteToUDP回包;3. 注意错误处理、TCP粘包、UDP大小限制及资源释放。

golang net tcp与udp网络通信实践

Go语言标准库中的net包为TCP和UDP网络编程提供了简洁而强大的支持。无论是构建高性能服务器还是轻量级客户端,Golang都能以极少的代码实现稳定通信。下面通过实际示例展示TCP与UDP的基本用法和关键细节。

TCP通信:可靠连接的基础

TCP是面向连接的协议,适合需要确保数据完整性和顺序的应用场景,比如HTTP服务、文件传输等。

1. TCP服务器
使用net.Listen监听端口,接受客户端连接并处理数据:

func startTCPServer() {    listener, err := net.Listen("tcp", ":8080")    if err != nil {        log.Fatal(err)    }    defer listener.Close()    log.Println("TCP服务器启动,监听 :8080")    for {        conn, err := listener.Accept()        if err != nil {            log.Println("接受连接失败:", err)            continue        }        go handleTCPConn(conn)    }}func handleTCPConn(conn net.Conn) {    defer conn.Close()    buffer := make([]byte, 1024)    for {        n, err := conn.Read(buffer)        if err != nil {            log.Println("读取结束或出错:", err)            return        }        log.Printf("收到: %s", string(buffer[:n]))        // 回显数据        conn.Write([]byte("echo: " + string(buffer[:n])))    }}

2. TCP客户端
连接服务器并发送消息:

func tcpClient() {    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, _ := conn.Read(buf)    log.Printf("回显: %s", string(buf[:n]))}

TCP的关键在于连接管理。服务器通常为每个连接启动一个goroutine,利用Go的轻量级并发模型高效处理多个客户端。

UDP通信:无连接的高效传输

UDP不建立连接,适合对实时性要求高、可容忍少量丢包的场景,如音视频流、心跳包等。

立即学习“go语言免费学习笔记(深入)”;

千帆AppBuilder 千帆AppBuilder

百度推出的一站式的AI原生应用开发资源和工具平台,致力于实现人人都能开发自己的AI原生应用。

千帆AppBuilder 174 查看详情 千帆AppBuilder

1. UDP服务器
使用net.ListenUDP绑定地址,接收任意来源的数据包:

func startUDPServer() {    addr, _ := net.ResolveUDPAddr("udp", ":9090")    conn, err := net.ListenUDP("udp", addr)    if err != nil {        log.Fatal(err)    }    defer conn.Close()    log.Println("UDP服务器启动,监听 :9090")    buffer := make([]byte, 1024)    for {        n, clientAddr, err := conn.ReadFromUDP(buffer)        if err != nil {            log.Println("读取失败:", err)            continue        }        log.Printf("来自 %s: %s", clientAddr, string(buffer[:n]))        // 回复客户端        conn.WriteToUDP([]byte("UDP echo"), clientAddr)    }}

2. UDP客户端
直接向目标地址发送数据包:

func udpClient() {    serverAddr, _ := net.ResolveUDPAddr("udp", "localhost:9090")    conn, err := net.DialUDP("udp", nil, serverAddr)    if err != nil {        log.Fatal(err)    }    defer conn.Close()    conn.Write([]byte("Hello UDP Server"))    response := make([]byte, 1024)    n, _, _ := conn.ReadFromUDP(response)    log.Printf("收到回复: %s", string(response[:n]))}

UDP通信中,服务器通过ReadFromUDP获取客户端地址,再用WriteToUDP回复。客户端则可通过DialUDP建立虚拟连接简化收发流程。

实践建议与注意事项

在真实项目中,以下几点值得特别关注:

错误处理不能忽略,尤其是网络中断、超时等常见问题 TCP粘包问题需自行处理,常见方案有固定长度、分隔符或头部带长度字段 UDP有最大报文限制(通常64KB),过大数据需应用层拆分 高并发下注意资源释放,避免文件描述符泄漏 可结合context控制超时和取消

Go的net包接口设计直观,配合goroutine能轻松实现并发网络服务。理解TCP与UDP的本质差异,才能根据业务需求选择合适协议。

基本上就这些,不复杂但容易忽略细节。动手写一遍,比看十篇理论都管用。

以上就是Golang net TCP与UDP网络通信实践的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1162219.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2025年12月2日 23:04:22
下一篇 2025年12月2日 23:05:18

相关推荐

发表回复

登录后才能评论
关注微信