Go并发tcp服务示例：构建高效网络服务的实用方法

发布时间：2025-12-10 02:05:11 阅读：504 次

在现代网络应用中，处理大量并发连接是常见需求。比如一个聊天服务器需要同时响应成百上千用户的发消息请求，或者一个监控系统要持续接收来自多个设备的数据上报。使用 Go 语言编写 TCP 服务，凭借其轻量级 Goroutine 和强大的标准库，能轻松应对这类场景。

为什么选择 Go 做并发 TCP 服务

Go 的 Goroutine 开销极小，启动成千上万个几乎不占资源。配合 channel 可以实现安全的通信，这让编写高并发服务变得简单直观。相比传统线程模型，Go 不仅代码更简洁，维护成本也更低。

一个简单的并发 TCP 服务器示例

下面是一个基于 Go 实现的并发 TCP 服务，它监听本地 8080 端口，每个连接到来时都会启动一个独立的协程来处理数据读取。

package main

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

func handleConnection(conn net.Conn) {
	defer conn.Close()
	scanner := bufio.NewScanner(conn)
	for scanner.Scan() {
		text := scanner.Text()
		fmt.Printf("收到消息: %s\n", text)
		// 回显客户端
		conn.Write([]byte("已收到: " + text + "\n"))
	}
	if err := scanner.Err(); err != nil {
		log.Printf("读取错误: %v", err)
	}
}

func main() {
	listener, err := net.Listen("tcp", ":8080")
	if err != nil {
		log.Fatalf("监听失败: %v", err)
	}
	fmt.Println("TCP 服务器启动，监听 8080 端口...")
	defer listener.Close()

	for {
		conn, err := listener.Accept()
		if err != nil {
			log.Printf("接受连接失败: %v", err)
			continue
		}
		// 每个连接启动一个协程处理
		go handleConnection(conn)
	}
}

将上述代码保存为 server.go 并运行，就能启动服务。用 telnet 或 nc 测试：

telnet localhost 8080

输入任意内容，服务器会原样返回，并在终端打印日志。每一个新连接都互不影响，彼此独立运行。

实际应用场景中的优化思路

在真实项目中，可能还需要加入超时控制、连接数限制、心跳检测等机制。例如防止恶意长连接占用资源，可以设置读写超时：

conn.SetReadDeadline(time.Now().Add(30 * time.Second))

也可以结合 TLS 实现加密通信，提升传输安全性，适用于敏感数据的传输环境。