在 Go 中使用 WebSocket 进行实时通信

现在，每当收到消息时，都会将其广播到所有连接的客户端。这是聊天应用程序或实时更新的常见方法。

优雅地处理断开连接

要处理客户端断开连接，请使用 defer ws.Close() 并在读取操作失败时从客户端映射中删除客户端。

Ping/Pong 用于连接健康

WebSockets 支持 ping/pong 帧以保持连接活动并检查客户端是否仍处于连接状态。

WebSocket 的最佳实践

最后的想法

WebSockets 使得构建超越传统请求/响应周期的交互式实时应用程序成为可能。通过在 Go 中设置 WebSocket 服务器，您现在可以轻松处理实时数据。无论您是构建聊天应用程序、实时仪表板还是协作工具，WebSockets 都可以让您创建无缝的交互式体验。

尝试一下：设置 WebSocket 服务器并开始实验！一旦掌握了窍门，您就会明白为什么 WebSocket 对于实时应用程序至关重要。

您最喜欢的 WebSocket 用例是什么？ 请在评论中告诉我，或分享您构建实时应用程序的任何技巧！

首页 > 编程 > 在 Go 中使用 WebSocket 进行实时通信

在 Go 中使用 WebSocket 进行实时通信

发布于2024-11-06

Using WebSockets in Go for Real-Time Communication

构建需要实时更新的应用程序（例如聊天应用程序、实时通知或协作工具）需要一种比传统 HTTP 更快、更具交互性的通信方法。这就是 WebSockets 发挥作用的地方！今天，我们将探讨如何在 Go 中使用 WebSocket，以便您可以向应用程序添加实时功能。

在这篇文章中，我们将介绍：

WebSocket 是什么以及它们如何工作。
在 Go 中设置 WebSocket 服务器。
创建一个简单的 WebSocket 客户端。
处理事件并维护连接。

让我们变得实时！？

什么是 WebSocket？？

WebSockets 通过单个长期连接提供全双工通信通道。与遵循请求-响应周期的传统 HTTP 请求不同，WebSocket 允许服务器和客户端独立发送和接收消息，使其成为实时应用程序的理想选择。

主要特点：

全双工通信：客户端和服务器端都可以独立发送消息，无需等待响应。
低延迟：WebSocket 保持持久连接打开，减少消息之间的延迟。
事件驱动：WebSocket 将数据作为事件处理，使您能够立即对传入消息做出反应。

在 Go 中设置 WebSocket 服务器

要创建 WebSocket 服务器，我们将使用 Gorilla WebSocket 包，这使得在 Go 中使用 WebSocket 变得容易。

第 1 步：安装 Gorilla WebSocket

使用 go get 安装包：

go get -u github.com/gorilla/websocket

第 2 步：创建 WebSocket 服务器

现在，让我们设置一个简单的 WebSocket 服务器来侦听传入连接并回显它收到的任何消息：

package main

import (
    "fmt"
    "net/http"
    "github.com/gorilla/websocket"
)

var upgrader = websocket.Upgrader{
    CheckOrigin: func(r *http.Request) bool { return true }, // Allow all connections
}

func handleConnections(w http.ResponseWriter, r *http.Request) {
    // Upgrade initial GET request to a WebSocket
    ws, err := upgrader.Upgrade(w, r, nil)
    if err != nil {
        fmt.Println(err)
        return
    }
    defer ws.Close()

    for {
        // Read message from browser
        _, msg, err := ws.ReadMessage()
        if err != nil {
            fmt.Println("read error:", err)
            break
        }
        fmt.Printf("Received: %s\n", msg)

        // Write message back to browser
        if err := ws.WriteMessage(websocket.TextMessage, msg); err != nil {
            fmt.Println("write error:", err)
            break
        }
    }
}

func main() {
    http.HandleFunc("/ws", handleConnections)

    fmt.Println("WebSocket server started on :8080")
    err := http.ListenAndServe(":8080", nil)
    if err != nil {
        fmt.Println("ListenAndServe:", err)
    }
}

在此示例中：

升级：我们使用 Upgrader 将 HTTP 连接升级为 WebSocket 连接。
读/写循环：我们进入一个循环，从客户端读取消息并回显它们。

注意：Upgrader中的CheckOrigin允许所有连接。在生产环境中，请确保验证来源以避免跨站点 WebSocket 劫持。

设置简单的 WebSocket 客户端

要测试您的 WebSocket 服务器，您可以使用带有 JavaScript 的 HTML 客户端，该客户端连接到 WebSocket 服务器并发送/接收消息。

HTML 客户端示例：



    WebSocket ClientWebSocket Client

让套接字 = new WebSocket("ws://localhost:8080/ws"); socket.onopen = 函数(事件) { document.getElementById("messages").textContent = "已连接到 WebSocket 服务器\n"; }; socket.onmessage = 函数(事件) { document.getElementById("messages").textContent = "已收到：" event.data "\n"; }; socket.onclose = 函数（事件）{ document.getElementById("messages").textContent = "已与 WebSocket 服务器断开连接\n"; }; 函数发送消息（）{ let message = document.getElementById("messageInput").value; 套接字.发送(消息); document.getElementById("messageInput").value = ""; } 脚本> 正文>

版本声明本文转载于：https://dev.to/neelp03/using-websockets-in-go-for-real-time-communication-4b3l?1如有侵犯，请联系[email protected]删除