用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 中转:
立即学习“go语言免费学习笔记(深入)”;
-
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 泄漏。










