当前位置：首页 > 文章列表 > Golang > Go教程 > GolangTCP连接建立教程及代码示例

GolangTCP连接建立教程及代码示例

2025-09-10 14:58:56 0浏览收藏

你在学习Golang相关的知识吗？本文《Golang TCP连接建立与代码示例》，主要介绍的内容就涉及到，如果你想提升自己的开发能力，就不要错过这篇文章，大家要知道编程理论基础和实战操作都是不可或缺的哦！

Go语言通过net包实现TCP通信，服务器使用net.Listen监听端口，客户端通过net.Dial建立连接。示例中服务器并发处理多个客户端，利用Goroutine实现连接独立读写，客户端发送消息并接收响应，展示TCP连接建立、数据传输及生命周期管理全过程。

Golang网络编程TCP连接建立与示例

在Go语言中进行网络编程，TCP通信是一个常见且重要的应用场景。Go标准库net包提供了简单而强大的接口来实现TCP客户端与服务器之间的连接建立和数据传输。本文将介绍TCP连接的基本流程，并通过一个简单的示例展示如何使用Golang实现TCP通信。

TCP连接建立过程

TCP是面向连接的协议，通信前必须先建立连接。在Go中，这一过程分为两部分：服务器监听和客户端拨号。

服务器通过net.Listen函数监听指定地址和端口，等待客户端连接请求。当客户端调用net.Dial发起连接时，TCP三次握手完成，连接建立成功，双方即可通过net.Conn接口进行读写操作。

TCP服务器实现

以下是一个简单的TCP服务器示例：

package main

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

func main() {
    // 监听本地8080端口
    listener, err := net.Listen("tcp", ":8080")
    if err != nil {
        log.Fatal("监听失败:", err)
    }
    defer listener.Close()
    fmt.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()
    reader := bufio.NewReader(conn)
    for {
        // 读取客户端消息
        msg, err := reader.ReadString('\n')
        if err != nil {
            log.Println("读取失败:", err)
            return
        }
        fmt.Printf("收到消息: %s", msg)
        // 回应客户端
        conn.Write([]byte("已收到: " + msg))
    }
}

TCP客户端实现

对应的客户端代码如下：

package main

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

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

    // 从标准输入读取用户输入
    inputReader := bufio.NewReader(os.Stdin)
    for {
        fmt.Print("请输入消息: ")
        line, _ := inputReader.ReadString('\n')
        line = strings.TrimSpace(line)

        if line == "quit" {
            break
        }

        // 发送消息到服务器
        conn.Write([]byte(line + "\n"))

        // 读取服务器响应
        response, err := bufio.NewReader(conn).ReadString('\n')
        if err != nil {
            fmt.Println("读取响应失败:", err)
            break
        }
        fmt.Printf("服务器回应: %s", response)
    }
}