本文介绍在 go websocket 服务器中，如何通过 select + default 实现通道的非阻塞写入，避免因接收方缓慢导致的 goroutine 阻塞，提升服务整体响应性和稳定性。
在构建高并发 WebSocket 服务器时，常见的模式是为每个客户端（如 User）分配独立的发送通道（chan []byte），由专属的写协程从该通道读取消息并发送到网络连接。然而，当客户端网络异常、连接卡顿或写协程处理滞后时，该通道可能迅速填满——此时若直接执行 u.send <- msg，调用方（例如来自其他客户端的广播逻辑）将被永久阻塞，进而引发级联延迟，甚至拖垮整个请求链路。
Go 语言本身不支持“带超时/错误返回的通道发送”，但可通过 select 语句配合 default 分支优雅实现非阻塞发送：
func (u *User) Send(msg []byte) error {
select {
case u.send <- msg:
return nil // 发送成功
default:
// 通道已满，无法立即发送
return errors.New("send channel full: message dropped or backpressure required")
}
}该写法的核心在于：select 会尝试执行所有可用的 case；若 u.send 通道未满，则立即执行发送；若通道已满（即无 goroutine 正在接收），则跳过该 case，进入 default 分支——整个过程零阻塞、毫秒级完成。
⚠️ 注意事项：
- 缓冲区大小需合理设定：通道容量（如 make(chan []byte, 64)）应权衡内存占用与容错能力。过小易频繁触发 default；过大则掩盖真实背压问题。
-
错误处理不可忽略：default 分支不应静默丢弃消息。建议结合以下策略之一：
- 记录日志并触发告警；
- 将消息暂存至带限流的队列（如 github.com/robfig/cron/v3 或自定义环形缓冲）；
- 主动关闭慢连接（如检测连续 N 次发送失败后调用 u.conn.Close()）；
- 避免内存泄漏：若选择缓存待发消息，务必限制总长度，并在写协程恢复后及时消费，防止积压过多 []byte 占用堆内存。
- 考虑上下文取消：在更严格的场景下，可扩展为带 context.Context 的版本，支持超时或主动取消：
func (u *User) SendCtx(ctx context.Context, msg []byte) error {
select {
case u.send <- msg:
return nil
default:
select {
case u.send <- msg:
return nil
case <-ctx.Done():
return ctx.Err()
}
}
}总结：select { case ch <- v: ... default: ... } 是 Go 中实现通道非阻塞操作的标准范式，轻量、高效且符合语言哲学。它不依赖外部库，无需复杂同步原语，是构建健壮实时通信服务的关键基础技术之一。
