当前位置：首页 > 文章列表 > Golang > Go教程 > GolangWebSocket消息订阅广播实现教程

GolangWebSocket消息订阅广播实现教程

2026-02-11 09:16:02 0浏览收藏

哈喽！大家好，很高兴又见面了，我是golang学习网的一名作者，今天由我给大家带来一篇《Golang WebSocket消息订阅广播实现示例》，本文主要会讲到等等知识点，希望大家一起学习进步，也欢迎大家关注、点赞、收藏、转发! 下面就一起来看看吧！

答案：Go通过gorilla/websocket库实现WebSocket订阅与广播，核心为连接升级、客户端管理与消息广播。使用Upgrader将HTTP升级为WebSocket，允许跨域；clients map记录所有活跃连接；broadcast channel接收消息并由handleBroadcast协程向所有客户端推送；handleConnections处理新连接与读取消息，主函数启动广播协程并监听/ws路径；前端用JavaScript创建WebSocket连接，发送和显示消息，实现简单聊天功能；需注意并发安全与异常连接清理。

Golang WebSocket消息订阅与广播示例

用Go实现WebSocket的订阅与广播，核心是管理客户端连接和消息分发。下面是一个简洁实用的示例，基于gorilla/websocket库，能快速搭建一个支持消息广播的基础服务。

基本结构设计

服务端需要几个关键组件：升级HTTP连接的Upgrader、存储所有活跃连接的集合、以及一个广播通道。通过这些，可以实现新用户加入、消息接收和向所有在线用户推送。

Upgrader：负责把普通的HTTP请求“升级”成WebSocket连接，这里设置CheckOrigin: true允许跨域请求。
clients：用map保存所有已连接的客户端，key为*websocket.Conn，value通常设为bool表示是否在线。
broadcast：一个全局channel，用来接收所有客户端发来的消息，并由后台goroutine统一处理广播。

后端实现代码

主逻辑包含三个部分：处理连接、读取消息和广播消息。启动时开启一个独立协程运行广播函数，主线程监听WebSocket路径。

示例代码：

package main
import (
"log"
"net/http"
"github.com/gorilla/websocket"
)
var upgrader = websocket.Upgrader{
CheckOrigin: func(r *http.Request) bool { return true },
}
var clients = make(map[*websocket.Conn]bool)
var broadcast = make(chan []byte)
func handleConnections(w http.ResponseWriter, r *http.Request) {
conn, err := upgrader.Upgrade(w, r, nil)
if err != nil {
log.Fatal(err)
}
defer conn.Close()
clients[conn] = true

for {
    _, msg, err := conn.ReadMessage()
    if err != nil {
        delete(clients, conn)
        break
    }
    broadcast <- msg
}
}
func handleBroadcast() {
for {
msg := <-broadcast
for client := range clients {
err := client.WriteMessage(websocket.TextMessage, msg)
if err != nil {
client.Close()
delete(clients, client)
}
}
}
}
func main() {
go handleBroadcast()
http.HandleFunc("/ws", handleConnections)
http.ListenAndServe(":8080", nil)
}