如何在Golang中使用net.Listen建立TCP服务

来源:苹果APP网作者:印尼程序员头衔:程序员
导读:本期聚焦于小伙伴创作的《如何在Golang中使用net.Listen建立TCP服务》,敬请观看详情,探索知识的价值。以下视频、文章将为您系统阐述其核心内容与价值。如果您觉得《如何在Golang中使用net.Listen建立TCP服务》有用,将其分享出去将是对创作者最好的鼓励。

在Go语言的网络编程场景中,net包是处理网络操作的核心标准库,其中的Listen函数可以快速创建监听指定网络地址的服务端,是搭建TCP服务的基础入口。通过合理配置参数和处理连接逻辑,就能实现稳定的TCP服务端程序。

如何在Golang中使用net.Listen建立TCP服务

net.Listen的基本用法

net.Listen的函数签名如下,它接收两个字符串参数,返回监听对象和错误信息:

func Listen(network, address string) (Listener, error)

第一个参数network指定网络类型,建立TCP服务时传入"tcp"即可,也可以传入"tcp4"表示仅使用IPv4,"tcp6"表示仅使用IPv6。第二个参数address是监听的地址和端口,格式为"ip:port",如果监听所有网卡可以省略IP部分,直接写":端口号"。

完整TCP服务搭建步骤

使用net.Listen搭建TCP服务的核心流程分为四步:创建监听、循环接收连接、处理单个连接、关闭资源。下面是完整的示例代码:

package main

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

func main() {
    // 第一步:创建TCP监听,监听8080端口
    listener, err := net.Listen("tcp", ":8080")
    if err != nil {
        fmt.Printf("创建监听失败:%vn", err)
        return
    }
    // 函数退出时关闭监听
    defer listener.Close()
    fmt.Println("TCP服务已启动,监听端口8080")

    // 第二步:循环接收客户端连接
    for {
        conn, err := listener.Accept()
        if err != nil {
            fmt.Printf("接收连接失败:%vn", err)
            continue
        }
        // 启动协程处理单个连接,避免阻塞后续连接接收
        go handleConn(conn)
    }
}

// 处理单个客户端连接的函数
func handleConn(conn net.Conn) {
    // 连接处理完成后关闭连接
    defer conn.Close()
    // 获取客户端地址
    clientAddr := conn.RemoteAddr().String()
    fmt.Printf("客户端%s已连接n", clientAddr)

    // 使用bufio读取客户端发送的数据
    reader := bufio.NewReader(conn)
    for {
        // 读取到换行符为止的数据
        data, err := reader.ReadString('n')
        if err != nil {
            fmt.Printf("客户端%s断开连接:%vn", clientAddr, err)
            return
        }
        // 去除数据中的换行符和回车符
        data = strings.TrimSpace(data)
        fmt.Printf("收到客户端%s的消息:%sn", clientAddr, data)

        // 给客户端回复消息
        reply := fmt.Sprintf("已收到你的消息:%sn", data)
        _, err = conn.Write([]byte(reply))
        if err != nil {
            fmt.Printf("回复客户端%s失败:%vn", clientAddr, err)
            return
        }
    }
}

代码逻辑说明

监听创建与错误处理

调用net.Listen之后必须判断返回的err是否为空,如果端口被占用、地址格式错误都会导致监听创建失败,此时需要终止程序或者进行重试逻辑。

连接接收与并发处理

listener.Accept()会阻塞等待新的客户端连接,当有客户端连接进来时会返回一个net.Conn对象,代表当前的连接。这里使用for循环不断调用Accept,同时使用go关键字启动协程处理每个连接,这样服务端可以同时处理多个客户端的请求,不会因为处理一个连接而阻塞其他连接的接入。

连接数据交互

net.Conn对象实现了io.Reader和io.Writer接口,所以可以使用标准的IO方法读取和写入数据。示例中使用了bufio.Reader来按行读取客户端发送的内容,处理完成后通过Write方法给客户端回复消息,实际开发中可以根据协议调整读取和写入的逻辑。

常见注意事项

  • 监听地址的端口如果被其他程序占用,net.Listen会返回错误,需要确保端口没有被占用,或者动态选择可用端口。
  • 每个连接处理完成后一定要调用conn.Close()关闭连接,否则会造成资源泄漏,示例中通过defer语句保证连接一定会关闭。
  • 处理连接时如果读取数据返回错误,通常是客户端已经断开连接,此时可以直接结束连接处理流程。
  • 如果服务需要优雅退出,可以监听系统信号,在收到退出信号时先关闭listener,再等待现有连接处理完成。

简单客户端测试代码

可以使用下面的简单客户端代码测试上面搭建的TCP服务:

package main

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

func main() {
    // 连接服务端
    conn, err := net.Dial("tcp", "127.0.0.1:8080")
    if err != nil {
        fmt.Printf("连接服务端失败:%vn", err)
        return
    }
    defer conn.Close()

    // 读取服务端回复
    go func() {
        reader := bufio.NewReader(conn)
        for {
            data, err := reader.ReadString('n')
            if err != nil {
                return
            }
            fmt.Printf("收到服务端回复:%s", data)
        }
    }()

    // 从标准输入读取内容发送给服务端
    inputReader := bufio.NewReader(os.Stdin)
    for {
        fmt.Print("请输入要发送的内容:")
        data, _ := inputReader.ReadString('n')
        _, err := conn.Write([]byte(data))
        if err != nil {
            fmt.Printf("发送失败:%vn", err)
            return
        }
    }
}

GolangTCP服务net_ListenGo网络编程修改时间:2026-07-11 02:39:24

免责声明:​ 已尽一切努力确保本网站所含信息的准确性。网站内容多为原创整理与精心编撰,观点力求客观中立。本站旨在免费分享,内容仅供个人学习、研究或参考使用。若引用了第三方作品,版权归原作者所有。如内容涉及您的权益,请联系我们处理。
内容垂直聚焦
专注技术核心技术栏目,确保每篇文章深度聚焦于实用技能。从代码技巧到架构设计,为用户提供无干扰的纯技术知识沉淀,精准满足专业提升需求。
知识结构清晰
覆盖从开发到部署的全链路。AI、前端、编程、数据库、服务器、建站、系统层层递进,构建清晰学习路径,帮助用户系统化掌握开发与运维所需的核心技术。
深度技术解析
拒绝泛泛而谈,深入技术细节与实践难点。无论是数据库优化还是服务器配置,均结合真实场景与代码示例进行剖析,致力于提供可直接应用于工作的解决方案。
专业领域覆盖
精准对应开发生命周期。从前端界面到后端编程,从数据库操作到服务器运维,形成完整闭环,一站式满足全栈工程师和运维人员的技术需求。
即学即用高效
内容强调实操性,步骤清晰、代码完整。用户可根据教程直接复现和应用于自身项目,显著缩短从学习到实践的距离,快速解决开发中的具体问题。
持续更新保障
专注既定技术方向进行长期、稳定的内容输出。确保各栏目技术文章持续更新迭代,紧跟主流技术发展趋势,为用户提供经久不衰的学习价值。