答案：通过Goroutine和WebSocket实现私聊功能，需管理用户连接与消息路由。定义Client和Message结构体，用map+互斥锁维护在线用户，接收消息后解析类型，私聊则定向发送给目标用户，确保并发安全。
实现一个简单的聊天室私聊功能，核心在于消息的路由控制和用户连接管理。Golang 凭借其轻量级 Goroutine 和高效的并发模型，非常适合开发这类实时通信应用。下面通过基础架构和关键代码片段，带你一步步实现支持私聊的简易聊天室。
用户连接与消息结构设计
每个客户端通过 WebSocket 与服务器建立长连接，服务端需要维护所有活跃连接，并能根据用户名或 ID 定位特定用户。
定义基本的数据结构：
type Client struct {
conn *websocket.Conn
send chan []byte
username string
}
type Message struct {
Type string json:"type" // "public", "private"
From string json:"from"
To string json:"to,omitempty"
Body string json:"body"
}
Client 代表一个已连接的用户，包含其 WebSocket 连接、发送通道和用户名。Message 结构体区分消息类型，私聊时需指定目标用户 To。
立即学习“go语言免费学习笔记（深入）”；
全局客户端管理器
使用 map 存储所有在线用户，并用互斥锁保护并发访问：
var clients = make(map[*Client]bool) var mutex sync.Mutex var broadcast = make(chan []byte)
注册新用户时加入 map，断开时删除。注意每次操作 clients 都要加锁，避免竞态条件。
示例注册逻辑：
func registerClient(client *Client) {
mutex.Lock()
defer mutex.Unlock()
clients[client] = true
}
消息分发：区分公聊与私聊
收到消息后，解析 JSON 判断类型。如果是私聊，查找目标用户并单独发送：
func handleMessages() {
for message := range broadcast {
var msg Message
if err := json.Unmarshal(message, &msg); err != nil {
continue
}
if msg.Type == "private" {
mutex.Lock()
for client := range clients {
if client.username == msg.To {
select {
case client.send <- message:
default:
close(client.send)
delete(clients, client)
}
}
}
mutex.Unlock()
} else {
// 公聊广播给所有人
mutex.Lock()
for client := range clients {
select {
case client.send <- message:
default:
close(client.send)
delete(clients, client)
}
}
mutex.Unlock()
}
}}
私聊的关键是精准匹配目标用户，而不是广播给所有人。
客户端发送私聊消息格式
前端或测试客户端发送的消息应如下：
{
"type": "private",
"from": "alice",
"to": "bob",
"body": "你好，这是私密消息"
}
服务端据此将消息只推送给用户名为 bob 的连接。
基本上就这些。只要管理好连接状态，明确消息路由规则，Golang 实现私聊并不复杂，但要注意并发安全和连接异常处理。可以在此基础上扩展离线消息、心跳检测等功能。
