GolangWebSocket广播实现教程详解

一分耕耘，一分收获！既然都打开这篇《Golang WebSocket广播功能实现教程》，就坚持看下去，学下去吧！本文主要会给大家讲到等等知识点，如果大家对本文有好的建议或者看到有不足之处，非常欢迎大家积极提出！在后续文章我会继续更新Golang相关的内容，希望对大家都有所帮助！

使用Go和Gorilla WebSocket实现广播系统，核心是维护客户端连接集合与消息广播通道；02. 服务端通过upgrade处理WebSocket连接，将新连接加入clients map，并启动handleMessages协程监听broadcast通道；03. 每个连接读取消息后推送到broadcast，由广播协程转发给所有在线client；04. 前端通过WebSocket API连接，发送消息并实时接收显示他人消息，形成简单聊天室。

用Go语言实现WebSocket消息广播，核心是管理客户端连接，并把收到的消息发给所有在线用户。下面是一个简单实用的示例，使用Gorilla WebSocket库，适合做聊天室、通知系统等实时应用。

基本结构设计

服务端需要两个主要部分：一个全局的客户端集合，用来保存所有活跃的连接；一个广播通道，用来中转消息。

• clients：用map存储每个WebSocket连接，方便动态增删
• broadcast：一个channel，接收来自任一客户端的消息，等待分发

后端代码实现

使用gorilla/websocket库处理协议升级和通信。启动一个goroutine专门负责广播，避免阻塞主流程。

package main
<p>import (
"log"
"net/http"
"github.com/gorilla/websocket"
)</p><p>var upgrader = websocket.Upgrader{CheckOrigin: func(r <em>http.Request) bool { return true }}
var clients = make(map[</em>websocket.Conn]bool)
var broadcast = make(chan string)</p><p>func handleConnections(w http.ResponseWriter, r *http.Request) {
ws, err := upgrader.Upgrade(w, r, nil)
if err != nil { log.Fatal(err) }
defer ws.Close()
clients[ws] = true</p><pre class="brush:php;toolbar:false"><code>for {
    var msg string
    err := ws.ReadJSON(&msg)
    if err != nil { delete(clients, ws); break }
    broadcast <- msg
}</code>

}

func handleMessages() { for { msg := <-broadcast for client := range clients { err := client.WriteJSON(msg) if err != nil { client.Close(); delete(clients, client) } } } }

func main() { http.HandleFunc("/ws", handleConnections) go handleMessages() log.Println("服务器启动在 :8080") err := http.ListenAndServe(":8080", nil) if err != nil { log.Fatal("启动失败:", err) } }

前端页面配合

写一个简单的HTML页面，通过浏览器原生WebSocket API连接服务端，输入内容后发送，并能实时看到别人的消息。

<script>
const ws = new WebSocket("ws://localhost:8080/ws");
ws.onmessage = function(event) {
  const div = document.createElement("div");
  div.textContent = event.data;
  document.getElementById("chat").appendChild(div);
};
function send() {
  const input = document.getElementById("msg");
  ws.send(input.value);
  input.value = "";
}
</script>
&lt;input type=&quot;text&quot; id=&quot;msg&quot; /&gt;<button onclick="send()">发送</button>
<div id="chat"></div>

基本上就这些，不复杂但容易忽略错误处理和连接清理。

好了，本文到此结束，带大家了解了《GolangWebSocket广播实现教程详解》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！