Method RunReaper

internal/nodehub/hub.go:156–167

RunReaper 阻塞运行死连接清理：每 ReaperInterval 扫描一次注册表， 关闭超过 DeadConnectionTimeout 没收到任何帧的连接。ctx 取消时返回。 一般由 ListenAndServe 在 goroutine 中调用；外部直接持有 Hub 时也可手动调。

(ctx context.Context)

// 关闭超过 DeadConnectionTimeout 没收到任何帧的连接。ctx 取消时返回。
// 一般由 ListenAndServe 在 goroutine 中调用；外部直接持有 Hub 时也可手动调。
func (h *Hub) RunReaper(ctx context.Context) {
	t := time.NewTicker(h.reaperInterval)
	defer t.Stop()
	for {
		select {
		case <-ctx.Done():
			return
		case now := <-t.C:
			h.reapOnce(now)
		}
	}
}

func (h *Hub) reapOnce(now time.Time) {
	threshold := now.Add(-h.deadConnTimeout)