答案：通过共享channel实现消息广播，使用sync.RWMutex保护在线用户map，结合WebSocket实现实时通信。
用Golang实现多协程消息广播，核心思路是通过一个共享的channel接收消息，再由多个协程监听并处理这些消息。关键在于合理管理并发安全和资源释放。
使用全局广播channel
定义一个全局的channel用于接收所有需要广播的消息。启动一个专门的监听协程，持续从该channel读取消息，并将消息发送给所有当前在线的客户端连接。
每个客户端连接对应一个结构体，里面包含其专属的发送管道（chan）。当有新消息时，遍历所有在线用户的管道，把消息写入。注意遍历时要加读写锁，防止在广播过程中用户上下线导致map操作冲突。
- 创建message channel作为消息中枢
- 维护一个onlineMap存储在线用户及其通信管道
- 用sync.RWMutex保护map的并发访问
客户端连接与消息分发
每当有新客户端接入，服务端为其创建一个User实例，分配独立的接收和发送管道，并将其注册到全局在线列表中。同时启动两个协程：一个负责向客户端写数据，另一个读取客户端发来的消息并投递到广播channel。
立即学习“go语言免费学习笔记（深入）”；
客户端断开时，需及时清理对应的资源，关闭管道，从在线列表中移除记录，避免内存泄漏和无效写入。
- 新连接到来时，注册用户并启动收发协程
- 发送协程循环监听用户的C管道，把内容推送出去
- 接收协程把用户输入送入全局Message channel
集成WebSocket支持实时通信
结合gorilla/websocket库可以实现Web端的实时聊天室。HTTP处理器将连接升级为WebSocket后，为每个连接启动读写协程。
读协程接收客户端消息并转发到广播channel，写协程则监听个人的消息队列，把广播内容推送到前端。心跳机制可用来检测连接状态，超时未响应则主动断开。
- 使用websocket.Upgrader处理协议升级
- 每个连接维护自己的DataQueue
- 通过定时器实现心跳检测和超时控制
