如何在Golang中实现简单的TCP客户端和服务器

首先实现TCP服务器监听8080端口，接受连接并并发处理客户端消息，回显收到的内容；然后实现TCP客户端连接服务器，发送用户输入的消息并接收响应；通过bufio按行读取数据，确保每次发送以换行符结尾；最后运行服务端和客户端程序进行测试，输入quit退出。

在Golang中实现TCP客户端和服务器非常直接，得益于标准库net包的强大支持。下面通过一个简单的例子展示如何创建一个基础的TCP服务器和客户端，实现消息的发送与接收。

1. 实现TCP服务器

一个基本的TCP服务器需要监听某个端口，接受客户端连接，并处理来自客户端的数据。

以下是一个简单TCP服务器的实现：

package main

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

PHPShops多用户商城系统

随着电子商务模式更加多样化，企业和个人的迫切需求，PHPShops多用户商城系统正可以为其提供专业的电子商务解决方案。社区化电子商务，主要面向行业类和地方门户类站点。 PHPShops多用户商城系统（简称PHPShops）是基于电子商务的一套平台交易系统，它采用目前最流行网站建设工具PHP＋MYSQL，实现模版分离技术，通过HTML交互式网页技术来实行客户端与服务器端的交流。无论在

0

查看详情

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

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
        }
        fmt.Printf("客户端 %s 已连接\n", conn.RemoteAddr())

        // 处理每个连接（使用 goroutine 支持并发）
        go handleConnection(conn)
    }
}

func handleConnection(conn net.Conn) {
    defer conn.Close()

    scanner := bufio.NewScanner(conn)
    for scanner.Scan() {
        message := scanner.Text()
        fmt.Printf("收到消息: %s\n", message)

        // 回显消息给客户端
        conn.Write([]byte("echo: " + message + "\n"))
    }

    if err := scanner.Err(); err != nil {
        log.Println("读取数据出错:", err)
    }
    fmt.Printf("客户端 %s 已断开\n", conn.RemoteAddr())
}

2. 实现TCP客户端

客户端负责连接到服务器，发送消息，并接收服务器的响应。

package main

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

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

    scanner := bufio.NewScanner(os.Stdin)
    fmt.Println("输入消息（回车发送），输入 'quit' 退出：")

    for scanner.Scan() {
        input := scanner.Text()
        if input == "quit" {
            break
        }

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

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

    if err := scanner.Err(); err != nil {
        log.Println("读取输入失败:", err)
    }
    fmt.Println("客户端退出")
}

3. 运行示例

打开两个终端窗口：

• 在第一个终端运行服务器：
  go run server.go
• 在第二个终端运行客户端：
  go run client.go

在客户端输入任意文本并回车，服务器会打印收到的消息并返回“echo: xxx”，客户端将显示该响应。输入 quit 可退出客户端。

4. 关键点说明

• 并发处理：服务器使用 go handleConnection(conn) 为每个连接启动一个 goroutine，实现并发处理多个客户端。
• 数据读取方式：使用 bufio.Scanner 按行读取数据，适合文本协议。注意每次发送需换行符分隔消息。
• 连接关闭：确保调用 conn.Close() 释放资源，避免连接泄漏。
• 错误处理：网络操作容易出错，应始终检查返回的 error 值。

以上就是如何在Golang中实现简单的TCP客户端和服务器的详细内容，更多请关注php中文网其它相关文章！