如何使用Golang实现Socket通信-Golang-PHP中文网

如何使用Golang实现Socket通信

P粉602998670

发布： 2025-10-08 18:32:01

原创

511人浏览过

答案：Golang通过net包实现TCP/UDP通信，TCP示例包含服务器监听、并发处理连接及客户端收发消息，关键点包括goroutine并发、bufio读取、错误与资源管理，UDP示例展示无连接通信，整体简洁高效。

如何使用golang实现socket通信

使用Golang实现Socket通信并不复杂，Go语言标准库中的net包提供了强大且简洁的API，能够轻松实现TCP和UDP通信。下面以TCP为例，介绍如何用Golang构建一个简单的客户端-服务器模型进行Socket通信。

1. 实现TCP服务器

一个基本的TCP服务器需要监听指定端口，接受客户端连接，并处理数据收发。

示例代码：

package main

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

func main() {
    // 监听本地8080端口
    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()
    scanner := bufio.NewScanner(conn)
    for scanner.Scan() {
        message := scanner.Text()
        fmt.Printf("收到消息: %s\n", message)

        // 回传响应
        _, err := conn.Write([]byte("已收到: " + message + "\n"))
        if err != nil {
            log.Println("发送响应失败:", err)
            return
        }
    }
}

登录后复制

2. 实现TCP客户端

客户端负责连接服务器，发送数据并接收响应。

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

package main

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

func main() {
    // 连接本地服务器
    conn, err := net.Dial("tcp", "localhost:8080")
    if err != nil {
        log.Fatal("连接失败:", err)
    }
    defer conn.Close()

    fmt.Println("已连接到服务器")

    // 发送用户输入的消息
    go func() {
        scanner := bufio.NewScanner(os.Stdin)
        for scanner.Scan() {
            text := scanner.Text()
            _, err := conn.Write([]byte(text + "\n"))
            if err != nil {
                log.Println("发送失败:", err)
                return
            }
        }
    }()

    // 接收服务器响应
    responseScanner := bufio.NewScanner(conn)
    for responseScanner.Scan() {
        fmt.Println("服务器回复:", responseScanner.Text())
    }
}

登录后复制

3. 关键点说明

并发处理：服务器使用go handleConnection(conn)为每个连接启动独立协程，实现并发通信。

数据读取方式：使用bufio.Scanner按行读取，适合文本协议；若传输二进制数据，可直接使用conn.Read()和conn.Write()。

微信 WeLM

WeLM不是一个直接的对话机器人，而是一个补全用户输入信息的生成模型。

查看详情

连接关闭：确保在出错或完成时调用conn.Close()，避免资源泄漏。

错误处理：网络操作容易出错，务必检查每个I/O调用的返回值。

4. UDP通信简要示例

UDP是无连接协议，适用于低延迟场景。

服务器监听：

addr, _ := net.ResolveUDPAddr("udp", ":8080")
conn, _ := net.ListenUDP("udp", addr)
buffer := make([]byte, 1024)
n, clientAddr, _ := conn.ReadFromUDP(buffer)
fmt.Printf("收到UDP消息: %s\n", string(buffer[:n]))
conn.WriteToUDP([]byte("UDP响应"), clientAddr)

登录后复制

基本上就这些。Golang的net包让Socket编程变得直观高效，配合goroutine天然支持高并发，非常适合构建网络服务。不复杂但容易忽略的是边界处理和连接超时设置，实际项目中建议结合context控制超时与取消。

以上就是如何使用Golang实现Socket通信的详细内容，更多请关注php中文网其它相关文章！