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

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

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

1. 搭建TCP服务端

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

package main
import (
"bufio"
"fmt"
"log"
"net"
)
var clients = make(map[net.Conn]string) // 存储连接和用户名
var messages = make(chan string)        // 广播消息通道
func main() {
listener, err := net.Listen("tcp", ":8080")
if err != nil {
log.Fatal(err)
}
defer listener.Close()
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()
// 请求用户输入昵称
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语言免费学习笔记（深入）”；

							

								
								

									Latent Labs
									

								
								下载 
							
						
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()
            }
        }
    }
}

4. 简单的客户端连接测试
可以使用telnet或nc命令快速测试：

telnet localhost 8080
输入昵称，如Alice

发送消息，其他连接的客户端都能看到

如果想写Go客户端，只需用net.Dial连接服务器，然后起两个goroutine分别处理输入和输出即可。
基本上就这些。不复杂但容易忽略的是错误处理和连接关闭后的资源清理。Golang的并发原语让这类网络程序写起来非常简洁。