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

用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语言免费学习笔记(深入)”;
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的并发原语让这类网络程序写起来非常简洁。


