如何在Golang中实现WebSocket多客户端通信-Golang-PHP中文网

如何在Golang中实现WebSocket多客户端通信

P粉602998670

发布： 2025-10-01 19:17:02

原创

120人浏览过

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

如何在golang中实现websocket多客户端通信

在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 }

初始化管理器：

v1.1.6若依管理系统

一直想做一款后台管理系统，看了很多优秀的开源项目但是发现没有合适自己的。于是利用空闲休息时间开始自己写一套后台系统。如此有了若依管理系统。她可以用于所有的Web应用程序，如网站管理后台，网站会员中心，CMS，CRM，OA。所有前端后台代码封装过后十分精简易上手，出错效率低。同时支持移动客户端访问。系统会陆续更新一些实用功能。您是否在找一套合适后台管理系统。您是否在找一套代码易读易懂后台

885

查看详情

var clientManager = ClientManager{ clients: make(map[*Client]bool), register: make(chan *Client), broadcast: make(chan []byte), }

启动管理器监听注册与广播：

func (manager *ClientManager) start() { for { select { case client :=

实现消息读写协程

readPump 持续读取客户端消息并广播：

func (c *Client) readPump() { defer func() { clientManager.unregister

writePump 发送消息到客户端：

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 管理连接生命周期和消息分发，避免资源泄漏。实际项目中可扩展身份认证、房间分组、心跳检测等机制。不复杂但容易忽略细节。

以上就是如何在Golang中实现WebSocket多客户端通信的详细内容，更多请关注php中文网其它相关文章！