在Golang中通过gorilla/websocket实现WebSocket多客户端通信,需维护连接的客户端并进行消息广播。2. 使用upgrader升级HTTP连接,创建wsHandler处理连接请求,将新客户端注册到管理器。3. 定义Client和ClientManager结构体,用chan实现读写协程,start方法监听注册与广播,实现全局客户端管理与消息分发。

在Golang中实现WebSocket多客户端通信,关键在于维护所有连接的客户端,并通过中心化的管理机制进行消息广播。Go语言标准库虽不直接提供WebSocket支持,但可借助第三方库如 gorilla/websocket 快速搭建高效服务。
使用 gorilla/websocket 建立基础连接
安装依赖:
go get github.com/gorilla/websocket创建一个简单的HTTP处理器来升级WebSocket连接:
var upgrader = websocket.Upgrader{ CheckOrigin: func(r *http.Request) bool { return true // 允许跨域(生产环境应限制) }, }处理连接请求:
立即学习“go语言免费学习笔记(深入)”;
func wsHandler(w http.ResponseWriter, r *http.Request) { conn, err := upgrader.Upgrade(w, r, nil) if err != nil { log.Println("升级失败:", err) return } defer conn.Close()// 连接成功后加入客户端管理器
client := &Client{conn: conn, send: make(chan []byte, 256)}
clientManager.register <- client
// 启动读写协程
go client.writePump()
client.readPump()}
管理多个客户端连接
定义客户端结构体和全局管理器:
type Client struct { conn *websocket.Conn send chan []byte }type ClientManager struct { clients map[Client]bool register chan Client broadcast chan []byte }
初始化管理器:
dmSOBC SHOP网店系统由北京时代胜腾信息技术有限公司(http://www.webzhan.com)历时6个月开发完成,本着简单实用的理念,商城在功能上摒弃了外在装饰的一些辅助功能,尽可能的精简各项模块开发,做到有用的才开发,网店V1.0.0版本开发完成后得到了很多用户的使用并获得了好评,公司立即对网店进行升级,其中包括修正客户提出的一些意见和建议,现对广大用户提供免费试用版本,如您在使用
启动管理器监听注册与广播:
func (manager *ClientManager) start() { for { select { case client :=实现消息读写协程
readPump 持续读取客户端消息并广播:
func (c *Client) readPump() { defer func() { clientManager.unregisterwritePump 发送消息到客户端:
func (c *Client) writePump() { defer c.conn.Close() for message := range c.send { err := c.conn.WriteMessage(websocket.TextMessage, message) if err != nil { break } } }启动服务并运行
在 main 函数中启动管理器和HTTP服务:
func main() { go clientManager.start()http.HandleFunc("/ws", wsHandler)
log.Println("服务启动在 :8080")
err := http.ListenAndServe(":8080", nil)
if err != nil {
log.Fatal("启动失败:", err)
}}
前端可通过JavaScript连接测试:
const ws = new WebSocket("ws://localhost:8080/ws"); ws.onmessage = (event) => console.log("收到:", event.data); ws.onopen = () => ws.send("Hello Server!");基本上就这些。通过 gorilla/websocket 结合 channel 和 goroutine,可以轻松实现高效的WebSocket多客户端通信。重点是用统一的 manager 管理连接生命周期和消息分发,避免资源泄漏。实际项目中可扩展身份认证、房间分组、心跳检测等机制。不复杂但容易忽略细节。









