如何使用Golang的net包实现一个支持多用户的TCP聊天室服务器-Golang-PHP中文网

如何使用Golang的net包实现一个支持多用户的TCP聊天室服务器

P粉602998670

发布： 2025-08-30 12:16:01

原创

295人浏览过

使用Golang的net包实现TCP聊天室需监听端口、管理连接、广播消息；2. 每个客户端连接由独立goroutine处理，通过channel广播消息；3. clients map用sync.Mutex保护，确保并发安全；4. handleBroadcast持续监听broadcast channel，将消息发送给所有在线客户端。

如何使用golang的net包实现一个支持多用户的tcp聊天室服务器

要使用Golang的

net

登录后复制

包实现一个支持多用户的TCP聊天室服务器，核心在于监听客户端连接、管理多个连接、广播消息。Golang的并发模型（goroutine + channel）非常适合这类网络服务。下面是一个简洁但完整的实现思路和代码示例。

1. 基本架构设计

服务器需要做几件事：

监听TCP端口，接受客户端连接
为每个连接启动一个goroutine处理读写
维护所有活跃的客户端连接
当某个客户端发送消息时，广播给其他所有客户端

2. 客户端连接管理

使用一个

map

登录后复制

来保存所有连接，并用

channel

登录后复制

进行消息广播。由于

map

登录后复制

不是并发安全的，需要用

sync.Mutex

登录后复制

保护。

示例代码：

package main
<p>import (
"bufio"
"fmt"
"net"
"strings"
"sync"
)</p><p>type Client struct {
conn net.Conn
name string
}</p><p>var (
clients = make(map[net.Conn]*Client)
mu      sync.Mutex
broadcast = make(chan string)
)

登录后复制

3. 广播消息处理

启动一个独立的goroutine监听广播channel，并将消息发送给所有客户端。

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

AppMall应用商店

AI应用商店，提供即时交付、按需付费的人工智能应用服务

查看详情

func handleBroadcast() {
    for {
        msg := <-broadcast
        mu.Lock()
        for _, client := range clients {
            go func(c *Client) {
                _, _ = c.conn.Write([]byte(msg + "\n"))
            }(client)
        }
        mu.Unlock()
    }
}

登录后复制

4. 处理单个客户端

每个客户端连接启动一个goroutine，读取输入并发送到广播channel。首次输入作为用户名。

func handleClient(conn net.Conn) {
    defer conn.Close()
<pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">scanner := bufio.NewScanner(conn)

// 第一条消息作为用户名
if !scanner.Scan() {
    return
}
username := strings.TrimSpace(scanner.Text())
if username == "" {
    username = conn.RemoteAddr().String()
}

mu.Lock()
clients[conn] = &Client{conn: conn, name: username}
mu.Unlock()

// 通知所有人有新用户加入
broadcast <- fmt.Sprintf("[系统] %s 加入了聊天室", username)

// 读取消息并广播
for scanner.Scan() {
    text := strings.TrimSpace(scanner.Text())
    if text == "" {
        continue
    }
    broadcast <- fmt.Sprintf("%s: %s", username, text)
}

// 用户离开
mu.Lock()
delete(clients, conn)
mu.Unlock()
broadcast <- fmt.Sprintf("[系统] %s 离开了聊天室", username)

登录后复制

}

5. 启动服务器

主函数中监听端口，接受连接，并启动广播处理器。

func main() {
    listener, err := net.Listen("tcp", ":8080")
    if err != nil {
        panic(err)
    }
    defer listener.Close()
<pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">fmt.Println("聊天服务器启动，监听 :8080")

// 启动广播goroutine
go handleBroadcast()

for {
    conn, err := listener.Accept()
    if err != nil {
        continue
    }
    go handleClient(conn)
}

登录后复制

}

运行这个程序后，可以用