如何在Golang中实现WebSocket消息广播

使用gorilla/websocket库升级HTTP连接至WebSocket，允许跨域；2. 创建Hub中心管理客户端连接，通过clients映射维护活跃连接，broadcast通道接收消息；3. 启动goroutine监听broadcast，将消息推送给所有客户端，异常连接则从映射中移除；4. 客户端通过/ws路由接入，前端用JavaScript建立WebSocket连接并收发消息，实现多端实时通信。

在Golang中实现WebSocket消息广播，核心思路是管理所有客户端连接，并在一个中心化的“Hub”里将收到的消息推送给所有在线用户。下面是一个简洁、可运行的实现方案。

建立基础服务和连接升级

使用 gorilla/websocket 库来处理WebSocket协议。首先安装依赖：

创建一个升级器（Upgrader），用于把HTTP请求升级为WebSocket连接，通常需要允许跨域：

定义一个路由，比如 /ws，来处理连接请求。每当有客户端连接，就将其加入全局客户端集合。

立即学习“go语言免费学习笔记（深入）”；

管理客户端与广播消息

使用两个全局变量：一个 clients 映射来存储所有活跃的连接，一个 broadcast 通道用来接收待发送的消息。

来画数字人直播

来画数字人自动化直播，无需请真人主播，即可实现24小时直播，无缝衔接各大直播平台。

0

查看详情

启动一个独立的goroutine来监听 broadcast 通道。一旦有新消息进入，就遍历 clients 映射，将消息写回每个连接。如果某个连接出错或关闭，就从映射中移除它。

在连接处理函数中，开启一个循环读取客户端发来的消息，并将其发送到 broadcast 通道，从而触发广播逻辑。

前端简单接入

前端用原生JavaScript创建WebSocket连接，指向你的Go服务地址，如 ws://localhost:8080/ws。

通过 onmessage 事件接收广播消息并更新页面。发送消息时调用 send() 方法即可。配合一个简单的HTML页面，就能看到多个客户端实时同步消息的效果。

基本上就这些。这个模型轻量且高效，适合聊天室、通知系统等需要实时群发的场景。

以上就是如何在Golang中实现WebSocket消息广播的详细内容，更多请关注php中文网其它相关文章！