首页 > Golang > Go教程

GolangWebSocket实战：客户端与服务器示例

时间：2025-11-16 16:26:33 213浏览收藏

想要构建实时应用？Golang WebSocket 是你的理想选择！本文以实战示例深入讲解如何使用 Golang 结合强大的 `gorilla/websocket` 包，轻松搭建 WebSocket 客户端与服务器。文章详细介绍了服务器端的实现，包括如何利用 Upgrader 将 HTTP 连接升级为 WebSocket，允许跨域请求，并监听 `/ws` 路径，实现消息的原样回显。同时，也提供了客户端的实现，展示了如何连接服务器并循环发送消息，完整呈现了双向通信的流程。通过本文，你将掌握 Golang WebSocket 的核心技术，为你的实时应用开发打下坚实基础。

WebSocket 是一种全双工通信协议，适合实时数据交互。2. 使用 Go 语言结合 gorilla/websocket 包可实现 WebSocket 服务器与客户端。3. 服务器通过 Upgrader 将 HTTP 升级为 WebSocket，允许跨域并监听 /ws 路径。4. 服务器收到消息后原样回显。5. 客户端使用 websocket.Dial 连接服务器，并循环发送消息。6. 示例展示了完整的双向通信流程。

GolangWebSocket客户端与服务器实例

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 客户端连接上述服务器并发送消息：

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

说明：

使用 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 的基础通信模型，可用于聊天、实时通知等场景。

理论要掌握，实操不能落！以上关于《GolangWebSocket实战：客户端与服务器示例》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！