Golang如何实现Socket编程-Golang-PHP中文网

Golang如何实现Socket编程

P粉602998670

发布： 2025-11-09 22:37:02

原创

603人浏览过

Go语言通过net包实现TCP/UDP通信，支持并发处理、资源释放、错误处理与超时控制，适用于高性能网络服务开发。

golang如何实现socket编程

Go语言（Golang）通过标准库中的net包提供了强大且简洁的Socket编程支持。它封装了底层网络通信细节，使开发者能轻松实现TCP、UDP等协议的网络通信。

使用net包实现TCP Socket通信

TCP是一种面向连接的协议，适合需要可靠传输的场景。Golang中通过net.Listen监听端口，用listener.Accept()接收客户端连接。

以下是一个简单的TCP服务器示例：

package main

import (
    "bufio"
    "fmt"
    "net"
")

func main() {
    // 监听本地8080端口
    listener, err := net.Listen("tcp", ":8080")
    if err != nil {
        fmt.Println("启动失败:", err)
        return
    }
    defer listener.Close()
    fmt.Println("服务器已启动，等待连接...")

    for {
        // 等待客户端连接
        conn, err := listener.Accept()
        if err != nil {
            fmt.Println("连接出错:", err)
            continue
        }

        // 启动协程处理每个连接
        go handleConnection(conn)
    }
}

func handleConnection(conn net.Conn) {
    defer conn.Close()
    scanner := bufio.NewScanner(conn)
    for scanner.Scan() {
        message := scanner.Text()
        fmt.Printf("收到消息: %s\n", message)

        // 回显消息
        conn.Write([]byte("echo: " + message + "\n"))
    }
}

登录后复制

对应的TCP客户端代码：

立即学习“go语言免费学习笔记（深入）”；

豆包AI编程

豆包推出的AI编程助手

483

查看详情

package main

import (
    "bufio"
    "fmt"
    "net"
    "os"
")

func main() {
    conn, err := net.Dial("tcp", "localhost:8080")
    if err != nil {
        fmt.Println("连接失败:", err)
        return
    }
    defer conn.Close()

    go func() {
        scanner := bufio.NewScanner(conn)
        for scanner.Scan() {
            fmt.Println(scanner.Text())
        }
    }()

    // 从标准输入读取用户输入
    input := bufio.NewScanner(os.Stdin)
    for input.Scan() {
        msg := input.Text()
        conn.Write([]byte(msg + "\n"))
    }
}

登录后复制

UDP Socket编程

UDP是无连接协议，适用于对实时性要求高、可容忍部分丢包的场景。Golang中使用net.ListenPacket创建UDP服务。

UDP服务器示例：

package main

import (
    "fmt"
    "net"
")

func main() {
    addr, _ := net.ResolveUDPAddr("udp", ":8080")
    conn, _ := net.ListenUDP("udp", addr)
    defer conn.Close()

    buffer := make([]byte, 1024)
    for {
        n, clientAddr, err := conn.ReadFromUDP(buffer)
        if err != nil {
            fmt.Println("读取失败:", err)
            continue
        }

        fmt.Printf("来自 %s: %s\n", clientAddr, string(buffer[:n]))
        
        // 回复客户端
        conn.WriteToUDP([]byte("收到:"+string(buffer[:n])), clientAddr)
    }
}

登录后复制

UDP客户端：

package main

import (
    "fmt"
    "net"
")

func main() {
    addr, _ := net.ResolveUDPAddr("udp", "localhost:8080")
    conn, _ := net.DialUDP("udp", nil, addr)
    defer conn.Close()

    message := "Hello UDP Server"
    conn.Write([]byte(message))

    response := make([]byte, 1024)
    n, _ := conn.Read(response)
    fmt.Println("响应:", string(response[:n]))
}

登录后复制