17370845950

如何使用Golang net实现网络通信_Golang net网络通信示例
Golang的net包支持TCP/UDP通信,通过示例展示TCP服务器监听8080端口、处理客户端连接,以及客户端发送消息并接收响应的过程,结合goroutine实现并发;同时提供UDP通信简例,体现其在高性能网络服务中的应用潜力。

使用 Golang 的 net 包可以轻松实现底层网络通信,支持 TCP、UDP 和 Unix 域套接字等协议。net 包封装了常见的网络操作,使开发者能快速构建服务器和客户端程序。下面通过一个简单的 TCP 通信示例,展示如何使用 net 包进行数据传输。

1. 实现 TCP 服务器

TCP 服务器通过监听指定端口,等待客户端连接,并处理来自客户端的数据请求。

func startServer() {

    listener, err := net.Listen("tcp", ":8080")

    if err != nil {

        log.Fatal("监听失败:", err)

    }

    defer listener.Close()

    fmt.Println("服务器启动,监听 8080 端口...")

    for {

        conn, err := listener.Accept()

        if err != nil {

            log.Println("接受连接失败:", err)

            continue

        }

        go handleConnection(conn)

    }

}

func handleConnection(conn net.Conn) {

    defer conn.Close()

    buffer := make([]byte, 1024)

    for {

        n, err := conn.Read(buffer)

        if err == io.EOF {

            break

        }

        if err != nil {

            log.Println("读取数据错误:", err)

            break

        }

        fmt.Printf("收到消息: %s", string(buffer[:n]))

        _, _ = conn.Write([]byte("已收到\n"))

    }

}

2. 实现 TCP 客户端

客户端主动连接服务器,发送数据并接收响应。

func startClient() {

    conn, err := net.Dial("tcp", "localhost:8080")

    if err != nil {

        log.Fatal("连接失败:", err)

    }

    defer conn.Close()

    _, _ = conn.Write([]byte("Hello, Server!\n"))

    buffer := make([]byte, 1024)

    n, _ := conn.Read(buffer)

    fmt.Printf("服务器回复: %s", string(buffer[:n]))

}

3. 运行与测试

启动服务器后,在另一个终端或协程中运行客户端,即可看到通信过程。

  • 先调用 startServer() 启动服务端监听
  • 再执行 startClient() 发起连接和消息发送
  • 服务器打印接收到的消息,并返回确认信息
  • 客户端输出服务器的响应内容

4. 扩展:UDP 通信简例

UDP 是无连接协议,适用于对实时性要求高的场景。

// UDP 服务器

serverAddr, _ := net.ResolveUDPAddr("udp", ":9090")

conn, _ := net.ListenUDP("udp", serverAddr)

defer conn.Close()

buffer := make([]byte, 1024)

n, clientAddr, _ := conn.ReadFromUDP(buffer)

fmt.Printf("收到 UDP 消息: %s 来自 %s\n", string(buffer[:n]), clientAddr)

conn.WriteToUDP([]byte("UDP 已接收"), clientAddr)

基本上就这些。Golang 的 net 包设计简洁,配合 goroutine 可高效处理并发连接,适合构建高性能网络服务。实际应用中可结合 JSON 编解码、超时控制、心跳机制等增强稳定性。