本文介绍在 go websocket 服务器中，如何通过 `select` + `default` 实现通道的非阻塞写入，避免因接收方缓慢导致发送方 goroutine 被挂起，从而提升系统并发响应能力。
在构建高并发 WebSocket 服务时，常见模式是为每个客户端维护一个专属的发送通道（如 chan []byte），由独立的写 Goroutine 持续消费该通道并发送数据到网络连接。然而，当客户端网络异常、连接卡顿或读取速率远低于发送速率时，该通道可能迅速填满——若使用普通阻塞式发送 u.send <- msg，调用方（例如 A 客户端触发向 B 发送消息）将被挂起，直至通道有空位。这不仅造成请求延迟，还可能引发级联阻塞，严重损害服务整体吞吐与响应性。
要解决这一问题，核心思路是放弃“必须立即入队”的假设，转而采用非阻塞尝试写入。Go 的 select 语句配合 default 分支正是为此设计的标准方案：
func (u *User) Send(msg []byte) error {
select {
case u.send <- msg:
return nil // 成功入队
default:
// 通道已满，无法立即写入
return errors.New("send channel is full, message dropped")
}
}该写法确保 Send() 方法始终立即返回：成功时消息入队；失败时快速反馈错误，调用方可据此做降级处理（如日志告警、重试调度、或主动断连慢客户端）。
⚠️ 注意事项：
- 通道容量需合理设置：u.send = make(chan []byte, N) 中的 N 是关键参数。过小（如 1）易频繁触发 default；过大则增加内存占用与消息积压风险。建议根据典型消息大小、预期延迟容忍度及内存预算，设为 32–128 的幂次值，并配合监控观察积压率。
- 避免内存泄漏：[]byte 若来自 []byte(string) 或未复用的缓冲区，频繁分配可能引发 GC 压力。生产环境应结合 sync.Pool 复用消息缓冲区。
- 错误处理不可忽略：仅返回错误不够，应在上层逻辑中决策——例如对持续满载的客户端启动健康检查，或启用背压机制（如限流、退订广播）。
- 替代方案考量：若需更高可靠性，可改用带超时的 select（case <-time.After(timeout)），或引入带优先级/持久化能力的消息队列（如基于 ring buffer 的无锁队列），但会增加复杂度。
总结而言，select { case ch <- v: ... default: ... } 是 Go 中实现通道非阻塞写入最简洁、高效且符合语言惯用法的方式。它不依赖外部同步原语，零额外开销，是构建健壮实时通信服务的必备实践。
