Go语言通过Goroutine和标准库高效处理网络并发，示例包括：1. 使用net.Listen启动TCP服务，并为每个连接启动Goroutine；2. 用带缓冲channel限制最大100个并发连接，防止资源耗尽；3. 设置读写超时避免僵尸连接；4. 利用sync.Pool复用bufio.Scanner减少GC开销。合理运用这些技巧可提升服务性能与稳定性。
Go语言凭借其轻量级的Goroutine和强大的标准库，在网络编程领域表现出色。处理高并发连接时，合理的设计和技巧能显著提升服务性能与稳定性。以下是几个实用的Golang网络并发连接处理技巧及示例。
使用net.Listen启动TCP服务并并发处理连接
每个新连接启动一个Goroutine是最基础也是最常用的模式。Go的Goroutine开销小，适合这种“每连接一线程”模型。
示例如下：
package mainimport ( "bufio" "fmt" "log" "net" )
func handleConn(conn net.Conn) { defer conn.Close() scanner := bufio.NewScanner(conn) for scanner.Scan() { line := scanner.Text() fmt.Fprintf(conn, "echo: %s\n", line) } }
func main() { listener, err := net.Listen("tcp", ":8080") if err != nil { log.Fatal(err) } defer listener.Close()
fmt.Println("Server started on :8080") for { conn, err := listener.Accept() if err != nil { log.Println("Accept error:", err) continue } go handleConn(conn) }}
每次Accept到连接后，立即交给新的Goroutine处理，主线程继续监听，实现并发。
立即学习“go语言免费学习笔记（深入）”；
限制最大并发连接数防止资源耗尽
无限制地创建Goroutine可能导致内存暴涨或文件描述符耗尽。可通过带缓冲的channel控制并发数量。
示例：限制最多100个并发连接
var sem = make(chan struct{}, 100)
func handleConn(conn net.Conn) {
defer conn.Close()
// 获取信号量
sem <- struct{}{}
defer func() { <-sem }() // 释放
scanner := bufio.NewScanner(conn)
for scanner.Scan() {
line := scanner.Text()
fmt.Fprintf(conn, "echo: %s\n", line)
}}
利用容量为100的channel作为信号量，超过100个连接时，后续handleConn会阻塞直到有空位，有效保护系统资源。
设置连接超时避免长时间空闲占用
客户端异常断开或不发送数据会导致连接长期挂起。通过设置读写超时可及时清理无效连接。
在handleConn中添加：
conn.SetReadDeadline(time.Now().Add(30 * time.Second))
scanner := bufio.NewScanner(conn)
for scanner.Scan() {
conn.SetReadDeadline(time.Now().Add(30 * time.Second)) // 重置超时
line := scanner.Text()
fmt.Fprintf(conn, "echo: %s\n", line)
}
每次读取前更新超时时间，若30秒内无数据则自动断开，避免僵尸连接堆积。
使用sync.Pool减少频繁对象分配开销
高频收发数据时，频繁创建bufio.Scanner或bytes.Buffer会增加GC压力。可用sync.Pool复用对象。
示例：
var scannerPool = sync.Pool{
New: func() interface{} {
return bufio.NewScanner(bytes.NewReader([]byte{}))
},
}
func handleConn(conn net.Conn) {
defer conn.Close()
scanner := scannerPool.Get().(*bufio.Scanner)
scanner.R = bufio.NewReader(conn)
for scanner.Scan() {
line := scanner.Text()
fmt.Fprintf(conn, "echo: %s\n", line)
}
// 扫描器使用完毕归还
scanner.R = nil
scannerPool.Put(scanner)}
注意：需手动管理Reader的替换与归还，确保下次复用时状态干净。
基本上就这些。合理使用Goroutine、控制并发规模、设置超时、复用资源，能让Go网络服务稳定应对高并发场景。不复杂但容易忽略细节。
