googollee/go-socket.io设置PingTimeout后无法自动断连问题

针对你遇到的配置Ping参数后仍无法自动关闭异常连接的问题，可以从以下几个方面排查和解决：

1. 确保正确监听Disconnect事件 #

默认情况下，服务端在Ping超时后会触发disconnect事件，但如果没有主动监听并处理该事件，你可能无法感知到连接已关闭，进而导致连接状态记录未更新。

添加连接和断开的监听逻辑：

server.OnConnect("/", func(s socketio.Conn) error {
    log.Println("新连接建立:", s.ID())
    // 监听断开事件，在这里清理连接状态
    s.OnDisconnect(func() {
        log.Println("连接已断开:", s.ID())
        // 例如：从你的在线用户列表中移除该连接ID
    })
    return nil
})

2. 验证Ping参数的实际生效逻辑 #

PingInterval是服务端发送Ping包的间隔，PingTimeout是发送Ping后等待客户端Pong响应的最大时长。当超时后，engine.io底层应该主动关闭连接并触发disconnect。如果未生效，可检查：

• 是否客户端存在异常，无法正常响应Ping（但网络断开时客户端肯定无法响应，所以重点看服务端逻辑）
• 升级go-socket.io和go-engine.io到最新稳定版，避免旧版本的bug：

  go get github.com/googollee/go-socket.io@latest
  go get github.com/googollee/go-engine.io@latest
  

3. 手动添加兜底的连接健康检查 #

如果默认Ping机制仍有遗漏，可以在服务端维护连接的活跃时间，定时清理长时间无响应的连接：

import (
    "sync"
    "time"
    "log"
)

// 存储连接ID与最后活跃时间的映射
var connLastActive = sync.Map{}

func initSocketServer() {
    options := &engineio.Options{
        PingTimeout:  60 * time.Second,
        PingInterval: 30 * time.Second,
    }
    server := socketio.NewServer(options)

    server.OnConnect("/", func(s socketio.Conn) error {
        // 记录连接初始活跃时间
        connLastActive.Store(s.ID(), time.Now())
        
        // 监听所有事件，更新活跃时间
        s.OnAny(func(event string, args ...interface{}) {
            connLastActive.Store(s.ID(), time.Now())
        })

        s.OnDisconnect(func() {
            connLastActive.Delete(s.ID())
            log.Println("连接断开:", s.ID())
        })
        return nil
    })

    // 启动定时检查goroutine，每30秒执行一次
    go func() {
        ticker := time.NewTicker(30 * time.Second)
        defer ticker.Stop()
        for range ticker.C {
            connLastActive.Range(func(key, value interface{}) bool {
                connID := key.(string)
                lastActive := value.(time.Time)
                // 超过PingInterval+PingTimeout的时长（90秒）无活跃，主动关闭
                if time.Since(lastActive) > 90*time.Second {
                    if conn, ok := server.Conn(connID); ok {
                        if err := conn.Close(); err == nil {
                            log.Println("强制关闭无响应连接:", connID)
                        }
                        connLastActive.Delete(connID)
                    }
                }
                return true
            })
        }
    }()

    // 后续的Serve和Close逻辑保持不变
    go func() {
        if err := server.Serve(); err != nil {
            log.Fatalf("socketio listen error: %s", err)
        }
    }()
    defer server.Close()
}

4. 检查TCP层面的连接状态 #

有些极端情况下，TCP连接可能处于半开状态（如客户端断电、网络突然中断），此时依赖应用层的Ping机制可能需要一定时间才能检测到。可以通过调整系统TCP参数辅助检测，但一般应用层的Ping兜底方案足够覆盖大多数场景。

内容的提问来源于stack exchange，提问作者Mevo