Golang简单聊天室客户端服务端开发-Golang-PHP中文网

Golang简单聊天室客户端服务端开发

P粉602998670

发布： 2025-09-13 08:45:01

原创

542人浏览过

答案：使用Golang的net包和goroutine实现TCP聊天室，服务端通过map管理连接并广播消息，客户端并发处理输入与接收。

golang简单聊天室客户端服务端开发

用Golang开发一个简单的聊天室，核心是利用其强大的并发模型和标准库中的

net

登录后复制

包实现TCP通信。服务端负责管理客户端连接、消息广播，客户端则用于发送和接收消息。整个结构清晰，适合初学者理解网络编程和并发控制。

服务端设计与实现

服务端需要监听指定端口，接受多个客户端的连接，并维护当前在线的用户列表。每个连接启动一个goroutine处理读写，同时通过全局map记录连接信息，实现消息广播。

关键点：

使用
```
net.Listen
```
登录后复制
创建TCP监听
为每个
```
Accept
```
登录后复制
的连接启动独立goroutine
用map存储
```
conn -> username
```
登录后复制
映射
加锁保护共享数据（如用户列表）
收到消息后转发给其他所有客户端

示例代码片段：

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

var (
    clients   = make(map[net.Conn]string)
    broadcast = make(chan Message)
    mu        sync.Mutex
)
<p>type Message struct {
content  string
sender   net.Conn
}</p><p>func handleConn(conn net.Conn) {
defer conn.Close()
// 获取用户名
conn.Write([]byte("请输入用户名："))
reader := bufio.NewReader(conn)
username, _ := reader.ReadString('\n')
username = strings.TrimSpace(username)</p><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">mu.Lock()
clients[conn] = username
mu.Unlock()

// 广播上线消息
broadcast <- Message{fmt.Sprintf("%s 加入聊天室\n", username), nil}

// 读取消息
for {
    msg, err := reader.ReadString('\n')
    if err != nil { break }
    broadcast <- Message{username + ": " + msg, conn}
}

// 处理断开
mu.Lock()
delete(clients, conn)
mu.Unlock()
broadcast <- Message{fmt.Sprintf("%s 离开了\n", username), nil}

登录后复制

}

// 广播循环 go func() { for msg := range broadcast { mu.Lock() for conn, name := range clients { if conn != msg.sender { conn.Write([]byte(msg.content)) } } mu.Unlock() } }()

客户端实现要点

客户端相对简单，只需连接服务端，启动两个goroutine：一个监听用户输入并发送，另一个持续接收服务端转发的消息。

JoinMC智能客服

JoinMC智能客服，帮您熬夜加班，7X24小时全天候智能回复用户消息，自动维护媒体主页，全平台渠道集成管理，电商物流平台一键绑定，让您出海轻松无忧！

查看详情

注意点：

使用
```
net.Dial
```
登录后复制
连接服务端
用
```
bufio.Scanner
```
登录后复制
读取控制台输入
接收循环独立运行，避免阻塞输入
检测连接断开并退出

客户端核心逻辑：

conn, _ := net.Dial("tcp", "127.0.0.1:8080")
defer conn.Close()
<p>go func() {
io.Copy(os.Stdout, conn) // 直接输出服务端消息
}()</p><p>scanner := bufio.NewScanner(os.Stdin)
for scanner.Scan() {
msg := scanner.Text() + "\n"
conn.Write([]byte(msg))
}

登录后复制