当前位置：首页 > 文章列表 > Golang > Go教程 > Golangnet包TCP连接详解

Golangnet包TCP连接详解

2025-08-14 18:50:28 0浏览收藏

**Golang TCP连接教程：net包实现高效网络通信** Go语言net包是构建网络应用的基础，它简化了TCP通信的复杂性。本文通过一个回声服务示例，详细讲解如何使用net包创建TCP连接。服务端通过`net.Listen`监听端口，`Accept`接收连接，并利用goroutine并发处理客户端请求。客户端则使用`net.Dial`发起连接，并通过`net.Conn`进行数据读写。文章重点解析了TCP服务端和客户端的实现代码，强调了并发处理、连接管理和数据流控制的关键点。掌握这些知识，能帮助开发者快速构建稳定、高效的Golang网络服务。

Go语言通过net包实现TCP通信，服务端使用net.Listen监听端口，Accept接收连接并用goroutine处理；客户端通过net.Dial发起连接，利用net.Conn进行读写。示例展示回声服务：服务端接收消息后回显，客户端发送输入并打印响应。关键点包括并发处理、连接管理和数据流控制，体现Go在网络编程中的简洁与高效。

Golang网络编程基础是什么使用net包建立TCP连接示例

Go语言的网络编程基础主要依赖于标准库中的 net 包，它封装了底层的网络通信细节，提供了简单而强大的接口来处理TCP、UDP、HTTP等协议。其中，TCP作为面向连接、可靠的传输层协议，是构建稳定网络服务的常用选择。

使用 net 包建立TCP连接，核心涉及两个角色：服务端监听连接请求，客户端发起连接。下面通过一个简单的回声（echo）示例展示如何使用 net 包实现基本的TCP通信。

1. TCP服务端实现

服务端通过 net.Listen 监听指定地址和端口，等待客户端连接。每当有新连接到来，使用 listener.Accept 接受连接并启动一个 goroutine 处理数据读写，以实现并发处理多个客户端。

示例代码：

package main

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

func main() {
    // 监听本地 8080 端口
    listener, err := net.Listen("tcp", "localhost:8080")
    if err != nil {
        fmt.Println("监听失败:", err)
        return
    }
    defer listener.Close()
    fmt.Println("服务器启动，监听端口 8080...")

    for {
        // 等待客户端连接
        conn, err := listener.Accept()
        if err != nil {
            fmt.Println("接受连接失败:", err)
            continue
        }

        // 启动协程处理该连接
        go handleConnection(conn)
    }
}

// 处理客户端连接
func handleConnection(conn net.Conn) {
    defer conn.Close()
    scanner := bufio.NewScanner(conn)
    for scanner.Scan() {
        msg := scanner.Text()
        fmt.Printf("收到消息: %s\n", msg)
        // 回显给客户端
        conn.Write([]byte("echo: " + msg + "\n"))
    }
}

2. TCP客户端实现

客户端使用 net.Dial 连接到服务端，获取连接对象后即可发送和接收数据。通过标准输入读取用户输入，并将内容发送给服务端，同时读取服务端返回的数据。

示例代码：

package main

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

func main() {
    // 连接到服务端
    conn, err := net.Dial("tcp", "localhost:8080")
    if err != nil {
        fmt.Println("连接失败:", err)
        return
    }
    defer conn.Close()
    fmt.Println("已连接到服务器")

    // 开启一个协程接收服务端消息
    go func() {
        scanner := bufio.NewScanner(conn)
        for scanner.Scan() {
            fmt.Println("服务端:", scanner.Text())
        }
    }()

    // 从标准输入读取用户输入并发送
    input := bufio.NewScanner(os.Stdin)
    for input.Scan() {
        msg := input.Text()
        conn.Write([]byte(msg + "\n"))
    }
}