答案：使用Golang和gorilla/websocket库可实现一个简单的WebSocket聊天室，通过HTTP服务升级连接、管理客户端并广播消息。首先安装gorilla/websocket库，创建/ws路由并用Upgrader升级为WebSocket连接，允许跨域；接着定义clients映射和broadcast通道，用RWMutex保证并发安全，在wsHandler中注册连接并读取消息发送至广播通道；然后在main函数中启动handleBroadcast协程，循环监听broadcast并将消息写入所有活跃连接，出错时关闭连接并从clients中删除；最后编写HTML页面测试，多个浏览器窗口可实时收发消息，完成基础聊天功能。

用Golang实现一个简单的WebSocket聊天室服务，核心在于使用gorilla/websocket库建立长连接，并通过广播机制让所有客户端实时收发消息。整个服务不需要前端框架，后端即可完成连接管理与消息分发。

1. 安装依赖并初始化WebSocket服务

Go语言中操作WebSocket最常用的库是gorilla/websocket。先通过以下命令安装：

go get github.com/gorilla/websocket

然后创建一个HTTP服务，将特定路径（如/ws）升级为WebSocket连接：

代码示例：
创建main.go文件：

package main

import (
  "log"
  "net/http"
  "github.com/gorilla/websocket"
)

var upgrader = websocket.Upgrader{
  CheckOrigin: func(r *http.Request) bool { return true }, // 允许跨域
}

func wsHandler(w http.ResponseWriter, r *http.Request) {
  conn, err := upgrader.Upgrade(w, r, nil)
  if err != nil {
    log.Printf("升级失败: %v", err)
    return
  }
  defer conn.Close()
  log.Println("新客户端已连接")

  // 简单回显测试
  for {
    _, msg, err := conn.ReadMessage()
    if err != nil {
      log.Printf("读取消息错误: %v", err)
      break
    }
    log.Printf("收到消息: %s", msg)
    conn.WriteMessage(websocket.TextMessage, []byte("echo: "+string(msg)))
  }
}

func main() {
  http.HandleFunc("/ws", wsHandler)
  log.Println("服务启动在 :8080")
  log.Fatal(http.ListenAndServe(":8080", nil))
}

2. 实现客户端连接管理

聊天室需要维护多个客户端连接。可以定义一个Client结构体和一个全局的clients集合来管理活跃连接。

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

使用map[*websocket.Conn]bool存储连接，并用互斥锁保护并发安全。

github-repo-analyzer

当用户提及 GitHub URL，或要求分析、审查、探索或理解任意 GitHub 项目、仓库或代码库时，请使用此技能。触发条件包括以下短语：“分析这个项目”、“看看这个仓库”、“analyze this repo”、“what does this project do”，或消息中包含任何 github.com URL。

下载

var (
  clients = make(map[*websocket.Conn]bool)
  broadcast = make(chan Message)
  mu sync.RWMutex
)

type Message struct {
  Data string json:"data"
}

在wsHandler中注册新连接，并将其加入clients：

func wsHandler(w http.ResponseWriter, r *http.Request) {
  conn, err := upgrader.Upgrade(w, r, nil)
  if err != nil {
    return
  }
  defer conn.Close()

  mu.Lock()
  clients[conn] = true
  mu.Unlock()

  for {
    _, msg, err := conn.ReadMessage()
    if err != nil {
      break
    }
    broadcast   }

  mu.Lock()
  delete(clients, conn)
  mu.Unlock()
}

3. 广播消息给所有在线用户

启动一个独立的广播协程，在main函数中监听broadcast通道，把接收到的消息发送给每一个当前连接的客户端。

func main() {
  http.HandleFunc("/ws", wsHandler)
  go handleBroadcast()
  log.Println("聊天室服务运行在 :8080")
  log.Fatal(http.ListenAndServe(":8080", nil))
}

func handleBroadcast() {
  for {
    msg :=     data := []byte(msg.Data)
    mu.RLock()
    for conn := range clients {
      err := conn.WriteMessage(websocket.TextMessage, data)
      if err != nil {
        log.Printf("发送失败: %v", err)
        conn.Close()
        mu.Lock()
        delete(clients, conn)
        mu.Unlock()
      }
    }
    mu.RUnlock()
  }
}

4. 测试聊天室功能

写一个简单的HTML页面测试聊天功能：

发送

<script><br> const ws = new WebSocket("ws://localhost:8080/ws");<br> ws.onmessage = function(event) {<br> const li = document.createElement("li");<br> li.textContent = event.data;<br> document.getElementById("logs").appendChild(li);<br> };<br> function send() {<br> const input = document.getElementById("msg");<br> ws.send(input.value);<br> input.value = "";<br> }<br> </script>

打开多个浏览器窗口，输入消息点击发送，所有客户端都能实时看到内容。

基本上就这些。这个简单聊天室实现了连接管理、消息广播和基础异常处理，适合学习WebSocket通信模型。后续可扩展用户名、房间、私聊等功能。