17370845950

用Golang实现简易聊天室需三步：1. HTTP服务器注册/ws路由，用gorilla/websocket升级连接并封装Client；2. 用sync.RWMutex保护全局client映射表，配合心跳与超时清理；3. Hub中心广播，通过channel协调注册、注销与消息分发，前端HTML+JS直连。

用 Golang 实现一个简易聊天室，核心在于并发处理、连接管理与消息广播。不需要复杂框架，靠 net/http + gorilla/websocket 就能跑起来，重点是理清客户端连接、服务端路由、消息分发这三层关系。

服务端基础搭建：HTTP 服务 + WebSocket 升级

先起一个 HTTP 服务器，把 /ws 路径交给 WebSocket 处理：

• 用 http.HandleFunc("/ws", wsHandler) 注册路由
• 在 wsHandler 中调用 upgrader.Upgrade(w, r, nil) 完成协议升级
• 每个成功升级的连接，对应一个独立的 *websocket.Conn，建议封装为 Client 结构体，带 ID、昵称、连接句柄等字段

连接与用户管理：注册、心跳、退出清理

客户端连上后不是“一劳永逸”，得主动维护生命周期：

• 新连接时分配唯一 ID，存入全局 map[string]*Client（注意加 sync.RWMutex 保护）
• 启动 goroutine 读消息，同时启用 SetReadDeadline 配合 conn.SetPongHandler 做心跳检测
• 读到 io.EOF 或超时断开时，从 map 中删除该 client，并向其他用户广播 “xxx 离开了”

消息广播机制：中心化 Hub 与并发安全

所有消息不直接点对点转发，而是统一经由一个 Hub 中转：

• Hub 包含 clients map[*Client]bool、broacast chan Message、register/unregister chan *Client
• 单独起一个 goroutine 运行 hub.run()，监听 register/unregister/broadcast 三个 channel
• 客户端读到消息后，不做任何处理，直接发给 hub.broadcast ；hub 收到后遍历所有在线 client，调用 conn.WriteJSON(msg)
• 发送失败（如 write deadline exceeded）就触发 unregister，自动下线异常连接

前端简单对接：HTML + JS WebSocket

不需要 React/Vue，纯 HTML 就够：

• 页面放一个 和
• JS 里 const ws = new WebSocket("ws://localhost:8080/ws")
• ws.onmessage = e => { appendToChat(JSON.parse(e.data)) }
• 输入昵称可放在 URL 参数（如 /?name=Tom），服务端从 r.URL.Query().Get("name") 拿

基本上就这些。没有数据库、不依赖 Redis，所有状态存在内存里，适合学习原理和快速验证逻辑。上线前记得加日志、设好 WriteDeadline/ReadDeadline，避免 goroutine 泄漏。