WebSocket 是一种全双工通信协议，适合实时数据交互。2. 使用 Go 语言结合 gorilla/websocket 包可实现 WebSocket 服务器与客户端。3. 服务器通过 Upgrader 将 HTTP 升级为 WebSocket，允许跨域并监听 /ws 路径。4. 服务器收到消息后原样回显。5. 客户端使用 websocket.Dial 连接服务器，并循环发送消息。6. 示例展示了完整的双向通信流程。
WebSocket 是一种在单个 TCP 连接上进行全双工通信的协议，相比传统的 HTTP 轮询，它更适合实时数据交互。Golang（Go）标准库提供了对 WebSocket 的良好支持，通常结合 gorilla/websocket 包来实现客户端与服务器之间的实时通信。
服务器端实现
使用 gorilla/websocket 创建一个简单的 WebSocket 服务器：
package main
import (
"log"
"net/http"
"github.com/gorilla/websocket"
)
var upgrader = websocket.Upgrader{
CheckOrigin: func(r *http.Request) bool {
return true // 允许跨域
},
}
func echoHandler(w http.ResponseWriter, r *http.Request) {
conn, err := upgrader.Upgrade(w, r, nil)
if err != nil {
log.Print("升级失败:", err)
return
}
defer conn.Close()
for {
// 读取消息
messageType, message, err := conn.ReadMessage()
if err != nil {
log.Print("读取失败:", err)
break
}
log.Printf("收到: %s", message)
// 回显消息
if err := conn.WriteMessage(messageType, message); err != nil {
log.Print("发送失败:", err)
break
}
}
}
func main() {
http.HandleFunc("/ws", echoHandler)
log.Print("服务器启动在 :8080")
log.Fatal(http.ListenAndServe(":8080", nil))
}
说明：
- 使用 gorilla/websocket 的
Upgrader
将 HTTP 请求升级为 WebSocket 连接。 CheckOrigin: true
允许所有跨域请求，生产环境应做限制。- 服务器启动在
:8080
，监听/ws
路径。 - 收到消息后原样回显给客户端。
客户端实现
编写一个 Go 客户端连接上述服务器并发送消息：
立即学习“go语言免费学习笔记（深入）”；
游戏卡点销售充值程序
下载
可批量生成卡号与密码然后做成实物卡后销售给客户，客户到您的网站来用此卡号密码来提交充值相关游戏卡点、QQ币、其它数字卡等相关信息，(适合做"一卡通")而您在后台可监控客户的提交信息，并手动为客户完成充值后 点击完后重点功能如下：1、卡号、密码批量生成。2、添加和修改游戏名称、区、服务器、充值方法、游戏点卡列隔等充值选择3、开启充值网站和关闭充值网站的功能4、前台用所生成的卡号密
package main
import (
"log"
"net/url"
"time"
"github.com/gorilla/websocket"
)
func main() {
u := url.URL{Scheme: "ws", Host: "localhost:8080", Path: "/ws"}
log.Printf("连接到 %s", u.String())
conn, _, err := websocket.DefaultDialer.Dial(u.String(), nil)
if err != nil {
log.Fatal("连接失败:", err)
}
defer conn.Close()
// 发送消息
for i := 1; i <= 5; i++ {
msg := "Hello, WebSocket " + string(rune('0'+i))
if err := conn.WriteMessage(websocket.TextMessage, []byte(msg)); err != nil {
log.Println("发送失败:", err)
return
}
// 读取回显
_, reply, err := conn.ReadMessage()
if err != nil {
log.Println("接收失败:", err)
return
}
log.Printf("回显: %s", reply)
time.Sleep(time.Second)
}
}
说明：
- 使用
websocket.DefaultDialer.Dial
连接到服务器。 - 通过
WriteMessage
发送文本消息。 - 使用
ReadMessage
接收服务器回显。 - 循环发送 5 条消息，每条间隔 1 秒。
运行步骤
1. 安装依赖：
go mod init websocket-demo go get github.com/gorilla/websocket
2. 分别运行服务器和客户端：
- 终端 1：运行服务器
go run server.go
- 终端 2：运行客户端
go run client.go
3. 观察输出，客户端发送的消息被服务器接收并回显。
基本上就这些。这个例子展示了 Go 中 WebSocket 的基础通信模型，可用于聊天、实时通知等场景。
