Golang网络编程TCP连接建立与示例-Golang-PHP中文网

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

P粉602998670

发布： 2025-09-05 11:32:02

原创

185人浏览过

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服务器示例：

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

豆包AI编程

豆包推出的AI编程助手

483

查看详情

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)
    }
}

登录后复制