如何在Golang中实现TCP服务器-Golang-PHP中文网

如何在Golang中实现TCP服务器

P粉602998670

发布： 2025-10-28 13:49:01

原创

834人浏览过

答案：Golang通过net包实现TCP服务器，先监听端口，再循环接受连接并为每个连接启动协程处理数据收发。示例代码展示了一个回声服务，接收客户端消息后返回“echo: ”前缀的响应，可用telnet测试，适用于学习与小型应用。

如何在golang中实现tcp服务器

在Golang中实现一个TCP服务器非常直接，得益于标准库 net 包的强大支持。你只需要监听端口、接受连接，并处理客户端数据即可。下面是一个清晰的实现步骤和示例代码，帮助你快速搭建一个基础但功能完整的TCP服务器。

1. 监听指定端口

使用 net.Listen 函数来创建一个监听套接字，绑定到指定的IP地址和端口。通常使用 "tcp" 作为网络类型，比如监听本地的 8080 端口：

listener, err := net.Listen("tcp", ":8080")
if err != nil {
    log.Fatal("监听端口失败:", err)
}
defer listener.Close()
log.Println("TCP服务器已启动，监听 :8080...")

登录后复制

2. 接受客户端连接

通过 listener.Accept() 接受来自客户端的连接请求。这个方法会阻塞，直到有客户端连接进来。每次成功接受后，会返回一个 net.Conn 对象，代表与客户端的连接。

for {
    conn, err := listener.Accept()
    if err != nil {
        log.Println("接受连接出错:", err)
        continue
    }
    // 每个连接开启一个协程处理
    go handleConnection(conn)
}

登录后复制

3. 处理客户端请求

定义一个函数来处理每个客户端连接。你可以读取客户端发送的数据，进行处理，然后返回响应。注意：TCP是字节流协议，需要自己处理消息边界（例如通过换行符或长度前缀）。

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

如知AI笔记

如知笔记——支持markdown的在线笔记，支持ai智能写作、AI搜索，支持DeepseekR1满血大模型

查看详情

以下是一个简单回声服务器的处理逻辑：

func handleConnection(conn net.Conn) {
    defer conn.Close()

    buffer := make([]byte, 1024)
    for {
        n, err := conn.Read(buffer)
        if err != nil {
            log.Println("连接断开:", err)
            return
        }

        data := buffer[:n]
        log.Printf("收到消息: %s", data)

        // 回显给客户端
        _, err = conn.Write([]byte("echo: " + string(data)))
        if err != nil {
            log.Println("发送响应失败:", err)
            return
        }
    }
}

登录后复制

4. 完整示例代码

把上面的片段组合起来，就是一个完整可运行的TCP服务器：

package main

import (
    "log"
    "net"
)

func main() {
    listener, err := net.Listen("tcp", ":8080")
    if err != nil {
        log.Fatal("监听失败:", err)
    }
    defer listener.Close()
    log.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 != nil {
            return
        }

        received := buffer[:n]
        log.Printf("来自 %s: %s", conn.RemoteAddr(), received)
        conn.Write([]byte("echo: " + string(received)))
    }
}

登录后复制

基本上就这些。你可以用 telnet 或 nc 测试它：