Golang如何实现TCP客户端与服务器_Golang TCP客户端服务器实践详解-Golang-PHP中文网

Golang如何实现TCP客户端与服务器_Golang TCP客户端服务器实践详解

P粉602998670

发布： 2025-11-17 12:39:17

原创

656人浏览过

答案：Go语言通过net包实现TCP通信，服务器用net.Listen监听并Accept接收连接，每个连接由goroutine处理；客户端通过net.Dial建立连接，利用bufio按行读写数据；需解决TCP粘包问题，常用换行符分隔消息；结合defer关闭连接、设置超时及合理错误处理可构建稳定并发的网络应用。

golang如何实现tcp客户端与服务器_golang tcp客户端服务器实践详解

在Go语言中实现TCP客户端与服务器通信非常直观，得益于标准库net包的强大支持。通过简单的API调用，就能快速构建稳定、高效的网络应用。下面从基本结构出发，逐步讲解如何用Golang实现一个完整的TCP通信模型。

1. TCP服务器的基本实现

使用net.Listen函数监听指定地址和端口，等待客户端连接。一旦有连接到来，通过Accept接收并处理数据。

示例代码：

JoinMC智能客服

JoinMC智能客服，帮您熬夜加班，7X24小时全天候智能回复用户消息，自动维护媒体主页，全平台渠道集成管理，电商物流平台一键绑定，让您出海轻松无忧！

查看详情

package main

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

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

    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)

        // 回传响应
        _, _ = conn.Write([]byte("已收到: " + message + "\n"))
    }
}

登录后复制

关键点说明：

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

使用net.Listen("tcp", ":9000")开启监听
Accept阻塞等待新连接，每次返回一个新的net.Conn对象
每个连接交由独立的goroutine处理，实现并发通信

2. TCP客户端的实现方式

客户端通过net.Dial连接服务器，之后可发送和接收数据。

示例代码：

package main

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

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

    // 开启读取服务器响应的协程
    go func() {
        scanner := bufio.NewScanner(conn)
        for scanner.Scan() {
            fmt.Println("服务端回复:", scanner.Text())
        }
    }()

    // 从标准输入读取用户输入并发送
    input := bufio.NewScanner(os.Stdin)
    for input.Scan() {
        line := input.Text()
        _, err := conn.Write([]byte(line + "\n"))
        if err != nil {
            log.Println("发送失败:", err)
            return
        }
    }
}

登录后复制

注意细节：