Golang如何实现基础的聊天室功能-Golang-PHP中文网

Golang如何实现基础的聊天室功能

P粉602998670

发布： 2025-10-24 21:37:02

原创

563人浏览过

答案：基于Golang的TCP聊天室通过net包实现服务端监听与客户端通信，利用goroutine处理并发连接。服务端维护客户端列表与广播通道，新连接触发goroutine读取用户名并监听消息，所有消息通过channel由独立broadcast goroutine分发至各客户端，确保实时通信。代码简洁但需注意连接关闭与错误处理以避免资源泄漏。

golang如何实现基础的聊天室功能

用Golang实现一个基础的聊天室，核心是利用其强大的并发模型和标准库中的net包来处理TCP连接。整个系统由服务端和多个客户端组成，服务端负责接收连接、广播消息，每个客户端通过goroutine独立处理读写。

1. 搭建TCP服务端

服务端监听指定端口，等待客户端接入。每当有新连接到来，启动一个goroutine处理该连接，保证不影响其他客户端。

示例代码：

package main
<p>import (
"bufio"
"fmt"
"log"
"net"
)</p><p>var clients = make(map[net.Conn]string) // 存储连接和用户名
var messages = make(chan string)        // 广播消息通道</p><p>func main() {
listener, err := net.Listen("tcp", ":8080")
if err != nil {
log.Fatal(err)
}
defer listener.Close()</p><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">go broadcast()

fmt.Println("Chat server started on :8080")
for {
    conn, err := listener.Accept()
    if err != nil {
        log.Print(err)
        continue
    }

    go handleClient(conn)
}

登录后复制

}

2. 处理客户端连接

每个客户端连接后，先要求输入用户名，然后将其加入全局客户端列表。之后持续监听该连接的消息，并将内容发送到广播通道。

func handleClient(conn net.Conn) {
    defer conn.Close()
<pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">// 请求用户输入昵称
conn.Write([]byte("Enter your nickname: "))
scanner := bufio.NewScanner(conn)
if !scanner.Scan() {
    return
}
nickname := scanner.Text()
clients[conn] = nickname

messages <- fmt.Sprintf("%s joined the chat", nickname)

// 接收用户消息
for scanner.Scan() {
    text := scanner.Text()
    messages <- fmt.Sprintf("%s: %s", nickname, text)
}

// 断开连接时清理
delete(clients, conn)
messages <- fmt.Sprintf("%s left the chat", nickname)

登录后复制

}

3. 广播消息给所有客户端

使用一个独立的goroutine监听messages通道，一旦有新消息，就遍历所有连接并发送。

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

ViiTor实时翻译

AI实时多语言翻译专家！强大的语音识别、AR翻译功能。

116

查看详情

func broadcast() {
    for msg := range messages {
        for conn := range clients {
            _, err := conn.Write([]byte(msg + "\n"))
            if err != nil {
                log.Printf("Error sending to %s: %v", clients[conn], err)
                delete(clients, conn)
                _ = conn.Close()
            }
        }
    }
}

登录后复制