答案:通过Golang和WebSocket实现在线聊天室,掌握HTTP服务、并发控制与实时通信。1. 使用net/http搭建基础服务器并提供网页入口;2. 引入gorilla/websocket处理连接升级与客户端通信;3. 利用channel和goroutine实现消息广播,所有客户端实时接收信息。

开发一个在线聊天室是学习 Golang 和 WebSocket 的绝佳实践项目。通过这个项目,你能掌握 HTTP 服务、WebSocket 协议、并发控制和实时通信等核心技能。下面是一个简洁实用的 Golang WebSocket 聊天室实战教程,带你从零搭建一个支持多用户实时通信的聊天系统。
首先创建一个基本的 HTTP 服务器,用于提供网页入口和处理 WebSocket 升级请求。
使用标准库 net/http 启动服务,并注册静态资源和 WebSocket 处理函数。
package main
<p>import (
"log"
"net/http"
)</p><p>func main() {
http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
http.ServeFile(w, r, "index.html")
})</p><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">log.Println("Server started on :8080")
log.Fatal(http.ListenAndServe(":8080", nil))}
确保项目根目录下有一个 index.html 页面,作为聊天界面入口。
立即学习“go语言免费学习笔记(深入)”;
Golang 标准库不直接支持 WebSocket,推荐使用 gorilla/websocket 这个成熟第三方库。
安装依赖:
go mod init chatroom go get github.com/gorilla/websocket
编写 WebSocket 处理函数,完成协议升级并管理连接。
var upgrader = websocket.Upgrader{
CheckOrigin: func(r *http.Request) bool {
return true // 允许跨域连接(生产环境应限制)
},
}
<p>var clients = make(map[*websocket.Conn]bool)
var broadcast = make(chan Message)</p><p>type Message struct {
Username string <code>json:"username"</code>
Text string <code>json:"text"</code>
}</p><p>func handleConnections(w http.ResponseWriter, r *http.Request) {
ws, err := upgrader.Upgrade(w, r, nil)
if err != nil {
log.Fatal(err)
}
defer ws.Close()</p><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">clients[ws] = true
for {
var msg Message
err := ws.ReadJSON(&msg)
if err != nil {
delete(clients[ws])
break
}
broadcast <- msg
}}
使用 Go 的并发特性,通过 goroutine 和 channel 实现消息广播。
启动一个后台监听协程,将接收到的消息推送给所有已连接的客户端。
func handleMessages() {
for {
msg := <-broadcast
for client := range clients {
err := client.WriteJSON(msg)
if err != nil {
client.Close()
delete(clients, client)
}
}
}
}
在 main 函数中启动该协程:
go handleMessages()
创建简单的 HTML + JavaScript 页面,连接 WebSocket 并发送/接收消息。
<!DOCTYPE html>
<html>
<head>
<title>Golang 聊天室</title>
</head>
<body>
<input type="text" id="username" placeholder="用户名" />
<input type="text" id="message" placeholder="输入消息" />
<button onclick="sendMessage()">发送</button>
<ul id="chat"></ul>
<pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;"><script>
const conn = new WebSocket("ws://localhost:8080/ws");
conn.onmessage = function(event) {
const data = JSON.parse(event.data);
const li = document.createElement("li");
li.textContent = data.username + ": " + data.text;
document.getElementById("chat").appendChild(li);
};
function sendMessage() {
const username = document.getElementById("username").value;
const text = document.getElementById("message").value;
conn.send(JSON.stringify({ username, text }));
document.getElementById("message").value = "";
}
</script></body> </html>
同时修改路由注册 WebSocket 处理函数:
http.HandleFunc("/ws", handleConnections)
基本上就这些。运行程序后,打开多个浏览器窗口即可看到实时聊天效果。这个基础版本支持多用户连接、消息广播和自动清理断开连接。
你可以在此基础上扩展:添加房间功能、用户认证、消息存储、离线消息提醒等。Golang 的高并发能力让这种实时系统非常高效稳定。
以上就是Golang 如何开发一个在线聊天室_Golang WebSocket 聊天室实战教程的详细内容,更多请关注php中文网其它相关文章!
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号