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

用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
)
type Message struct {
content string
sender net.Conn
}
func handleConn(conn net.Conn) {
defer conn.Close()
// 获取用户名
conn.Write([]byte("请输入用户名:"))
reader := bufio.NewReader(conn)
username, _ := reader.ReadString('\n')
username = strings.TrimSpace(username)
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:一个监听用户输入并发送,另一个持续接收服务端转发的消息。
易优cms包装印刷厂网站源码1.7.1
包装印刷厂网站源码适合印刷公司、图文门店、打印店进行区域业务拓展.通过网站展示业务,如特惠印刷楼书,纸杯,报纸书刊,画册,手提袋,信纸信封,海报,户型单,宣传单,等各种印刷品进行区域业务拓展,方便客户找到厂家。 易优cms包装印刷厂网站源码是基于易优cms开发,包含电脑端及移动端,如果需要小程序的话可以购买易优cms小程序插件,网站安装搭建简单,方便运营维护。
下载
注意点:
- 使用
net.Dial
连接服务端 - 用
bufio.Scanner
读取控制台输入 - 接收循环独立运行,避免阻塞输入
- 检测连接断开并退出
客户端核心逻辑:
conn, _ := net.Dial("tcp", "127.0.0.1:8080")
defer conn.Close()
go func() {
io.Copy(os.Stdout, conn) // 直接输出服务端消息
}()
scanner := bufio.NewScanner(os.Stdin)
for scanner.Scan() {
msg := scanner.Text() + "\n"
conn.Write([]byte(msg))
}
运行与测试
先启动服务端,监听本地8080端口,然后打开多个终端运行客户端程序。输入用户名后即可发送消息,所有人可见。
可改进方向:
- 支持私聊功能(指定用户名发送)
- 添加命令前缀,如/quit退出,/list查看在线用户
- 使用JSON格式化消息体
- 引入WebSocket支持网页客户端
基本上就这些。Golang的并发特性让这种聊天室实现非常简洁,没有复杂的依赖,标准库足够支撑基础功能。调试时注意关闭连接和资源清理,避免goroutine泄漏。









