当前位置：首页 > 文章列表 > Golang > Go教程 > Golang用net包实现TCP监听详解

Golang用net包实现TCP监听详解

2025-12-15 09:00:37 0浏览收藏

一分耕耘，一分收获！既然都打开这篇《Golang如何使用net包进行TCP监听_Golang TCP监听实践》，就坚持看下去，学下去吧！本文主要会给大家讲到等等知识点，如果大家对本文有好的建议或者看到有不足之处，非常欢迎大家积极提出！在后续文章我会继续更新Golang相关的内容，希望对大家都有所帮助！

Go语言通过net包实现TCP服务，仅需监听端口、接受连接并处理数据。1. 使用net.Listen("tcp", ":8080")启动服务，监听所有接口的8080端口；2. 调用listener.Accept()阻塞等待客户端连接，每接收一个连接即启动goroutine并发处理；3. 在handleConnection函数中循环读取conn.Read数据，解析后通过conn.Write回传响应；4. 完整示例构建了一个回显服务器，支持多客户端同时连接通信，结合goroutine实现高效并发，适用于轻量级网络服务开发。

Golang如何使用net包进行TCP监听_Golang TCP监听实践

在Go语言中，net包是进行网络编程的核心工具，尤其适合实现TCP服务。使用它创建一个TCP监听服务非常直观，只需几步即可完成：监听端口、接受连接、处理数据。下面通过一个具体示例说明如何用Golang实现TCP监听。

1. 启动TCP监听

使用 net.Listen 函数可以启动一个TCP服务，监听指定的IP和端口。通常我们监听本地所有IP的某个端口，比如":8080"。

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

这里第一个参数指定网络类型为"tcp"，第二个参数是地址。空IP表示监听所有可用接口。

2. 接受客户端连接

通过 listener.Accept() 阻塞等待客户端连接。每次有新连接时，返回一个 net.Conn 对象。

for {
    conn, err := listener.Accept()
    if err != nil {
        log.Println("接受连接出错:", err)
        continue
    }
    log.Printf("来自 %s 的新连接\n", conn.RemoteAddr())
    // 处理连接
    go handleConnection(conn)
}

使用 goroutine 处理每个连接，保证服务器能同时响应多个客户端。

3. 处理客户端请求

定义 handleConnection 函数读取客户端发送的数据，并可回传响应。

func handleConnection(conn net.Conn) {
    defer conn.Close()
    buffer := make([]byte, 1024)
    for {
        n, err := conn.Read(buffer)
        if err != nil {
            log.Printf("连接关闭或读取错误: %v\n", err)
            return
        }
        // 打印接收到的内容
        log.Printf("收到数据: %s", string(buffer[:n]))
        // 回显数据
        _, _ = conn.Write([]byte("已收到：" + string(buffer[:n])))
    }
}

这个函数持续读取数据直到连接关闭。实际应用中可根据协议解析数据，比如按行、JSON 或自定义格式。

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
        }
        log.Printf("新连接: %s\n", conn.RemoteAddr())
        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
        }
        log.Printf("来自 %s: %s", conn.RemoteAddr(), string(buffer[:n]))
        conn.Write([]byte("echo: " + string(buffer[:n])))
    }
}

运行程序后，可用 telnet 或 nc 测试：