面试题：Go中网络轮询在简单服务器场景的应用

Go语言代码实现

package main

import (
    "fmt"
    "net"
    "time"
)

func main() {
    ln, err := net.Listen("tcp", ":8080")
    if err != nil {
        fmt.Println("Failed to listen:", err)
        return
    }
    defer ln.Close()

    clientConns := make(map[net.Conn]struct{})
    go func() {
        for {
            // 轮询检查客户端连接状态
            for conn := range clientConns {
                err := conn.SetReadDeadline(time.Now().Add(time.Millisecond))
                if err != nil {
                    fmt.Println("SetReadDeadline error:", err)
                    continue
                }
                buf := make([]byte, 1)
                _, err = conn.Read(buf)
                if err != nil {
                    fmt.Println("Connection error:", err)
                    delete(clientConns, conn)
                    conn.Close()
                }
            }
            time.Sleep(1 * time.Second) // 轮询间隔
        }
    }()

    for {
        conn, err := ln.Accept()
        if err != nil {
            fmt.Println("Failed to accept:", err)
            continue
        }
        clientConns[conn] = struct{}{}
        go func(c net.Conn) {
            defer func() {
                delete(clientConns, c)
                c.Close()
            }()
            // 处理HTTP请求逻辑
            // 这里省略具体的HTTP请求处理代码
        }(conn)
    }
}

轮询机制设计

轮询间隔选择依据：轮询间隔设置为1秒，这个值是一个平衡值。如果间隔过短，会增加系统的CPU负载，因为频繁地检查连接状态会消耗CPU资源；如果间隔过长，那么在连接异常时不能及时发现并处理，可能导致资源浪费（如一直占用已失效的连接资源）。1秒的间隔在大多数情况下能在及时发现异常连接和控制系统开销之间取得较好的平衡。
可能遇到的问题及解决方案：
- 高CPU负载：如上述提到，过短的轮询间隔会导致CPU负载升高。解决方案是适当调大轮询间隔，或者优化检查连接状态的逻辑，尽量减少不必要的系统调用。例如，在实际应用中可以采用多路复用技术（如epoll或select）来高效管理多个连接，而不是简单地遍历所有连接进行检查。
- 连接状态误判：由于设置了较短的读超时（如代码中的1毫秒），可能会因为网络瞬间抖动等原因导致连接状态被误判为异常。解决方案是增加重试机制，当检测到连接可能异常时，进行多次重试读取操作，如果多次重试都失败，再判定连接异常并进行处理。
- 资源泄漏：如果在连接异常处理时没有正确关闭连接或清理相关资源，可能会导致资源泄漏。解决方案是确保在删除连接的记录（如从clientConns map中删除）之前，正确关闭连接（conn.Close()），并清理可能与之相关的其他资源（如临时缓冲区等）。

面试题：Go中网络轮询在简单服务器场景的应用

知识考点

面试题答案

Go语言代码实现

轮询机制设计