So implementieren Sie die bidirektionale WebSocket-Kommunikation in Golang-Golang-php.cn

So implementieren Sie die bidirektionale WebSocket-Kommunikation in Golang

WBOY

Freigeben： 2023-12-18 16:06:42

Original

1307 Leute haben es durchsucht

So implementieren Sie die bidirektionale WebSocket-Kommunikation in Golang

So implementieren Sie die bidirektionale Kommunikation mit WebSocket in Golang

WebSockets ist ein Kommunikationsprotokoll, das eine dauerhafte Verbindung zwischen dem Client und dem Server herstellt. Es ermöglicht eine bidirektionale Kommunikation und zeichnet sich durch hervorragende Echtzeitfähigkeit und Effizienz aus. In Golang können wir die Pakete net/http und gorilla/websocket in der Standardbibliothek verwenden, um die bidirektionale WebSocket-Kommunikation zu implementieren. In diesem Artikel wird die Implementierung der bidirektionalen WebSocket-Kommunikation in Golang vorgestellt und spezifische Codebeispiele bereitgestellt. net/http 和 gorilla/websocket 包来实现 WebSocket 的双向通信。本文将介绍如何在 Golang 中实现 WebSocket 的双向通信，并提供具体的代码示例。

步骤一：导入依赖包

首先，我们需导入 net/http 和 gorilla/websocket 包。net/http 包提供了 HTTP 服务器和客户端的功能，而 gorilla/websocket 包则是一个 WebSocket 实现库。

import (
    "log"
    "net/http"

    "github.com/gorilla/websocket"
)

Nach dem Login kopieren

步骤二：设置 WebSocket 处理函数

接下来，我们需要设置 WebSocket 的处理函数。这个函数将会处理客户端的连接请求，并在连接建立成功后，处理客户端发送的消息。

func websocketHandler(w http.ResponseWriter, r *http.Request) {
    // 将 HTTP 连接升级为 WebSocket 连接
    ws, err := upgrader.Upgrade(w, r, nil)
    if err != nil {
        log.Println("Error upgrading HTTP connection to WebSocket:", err)
        return
    }

    // 在连接结束时关闭 WebSocket
    defer ws.Close()

    // 循环处理客户端发来的消息
    for {
        // 读取客户端发来的消息
        messageType, message, err := ws.ReadMessage()
        if err != nil {
            log.Println("Error reading message from WebSocket:", err)
            break
        }

        // 打印收到的消息
        log.Printf("Received message: %s", message)

        // 回复客户端收到的消息
        if err = ws.WriteMessage(messageType, message); err != nil {
            log.Println("Error writing message to WebSocket:", err)
            break
        }
    }
}

Nach dem Login kopieren

步骤三：设置 WebSocket 升级器

在处理函数中，我们需要使用 gorilla/websocket 包的升级器(upgrader)来将 HTTP 连接升级为 WebSocket 连接。升级器还可以设置一些参数，例如允许的域以及握手超时时间。

var upgrader = websocket.Upgrader{
    // 允许跨域访问
    CheckOrigin: func(r *http.Request) bool {
        return true
    },
}

Nach dem Login kopieren

步骤四：设置 HTTP 服务器

最后，我们需要设置 HTTP 服务器，将处理函数映射到相应的路径上，以便客户端可以通过路径连接到 WebSocket。

func main() {
    // 设置 WebSocket 处理函数
    http.HandleFunc("/", websocketHandler)

    // 启动 HTTP 服务器
    err := http.ListenAndServe(":8080", nil)
    if err != nil {
        log.Fatal("Error starting HTTP server:", err)
    }
}

Nach dem Login kopieren

代码示例中的 :8080

Schritt 1: Abhängigkeitspakete importieren

Zuerst müssen wir die Pakete net/http und gorilla/websocket importieren. Das Paket net/http stellt HTTP-Server- und Client-Funktionalität bereit, während das Paket gorilla/websocket eine WebSocket-Implementierungsbibliothek ist.

const socket = new WebSocket("ws://localhost:8080/");

socket.addEventListener("open", (event) => {
    socket.send("Hello, server!");
});

socket.addEventListener("message", (event) => {
    console.log("Received message from server:", event.data);
});

socket.addEventListener("close", (event) => {
    console.log("Server connection closed:", event);
});

Nach dem Login kopieren

Schritt 2: WebSocket-Verarbeitungsfunktion festlegen🎜🎜Als nächstes müssen wir die WebSocket-Verarbeitungsfunktion festlegen. Diese Funktion verarbeitet die Verbindungsanforderung des Clients und verarbeitet die vom Client gesendete Nachricht, nachdem die Verbindung erfolgreich hergestellt wurde. 🎜rrreee🎜Schritt 3: Richten Sie den WebSocket-Upgrader ein🎜🎜In der Verarbeitungsfunktion müssen wir den Upgrader (upgrader) des Pakets gorilla/websocket verwenden, um das zu aktualisieren HTTP-Verbindung zur WebSocket-Verbindung. Der Upgrader kann auch einige Parameter festlegen, z. B. zulässige Domänen und Handshake-Timeout. 🎜rrreee🎜Schritt 4: HTTP-Server einrichten🎜🎜Abschließend müssen wir den HTTP-Server einrichten und die Verarbeitungsfunktion dem entsprechenden Pfad zuordnen, damit der Client über den Pfad eine Verbindung zu WebSocket herstellen kann. 🎜rrreee🎜:8080 im Codebeispiel ist die Abhöradresse und Portnummer des Servers, Sie können sie nach Bedarf ändern. 🎜🎜Mit dem obigen Code haben wir die Funktion der bidirektionalen Kommunikation über WebSocket in Golang erfolgreich implementiert. Nachdem die Clientverbindung erfolgreich hergestellt wurde, können Sie zum Senden und Empfangen von Nachrichten einen Code wie den folgenden verwenden: 🎜rrreee🎜Zusammenfassend haben wir detailliert beschrieben, wie die bidirektionale WebSocket-Kommunikation in Golang implementiert wird, und spezifische Codebeispiele bereitgestellt. Mit diesen Beispielcodes können Sie schnell loslegen und Echtzeit-Kommunikationsfunktionen basierend auf WebSocket implementieren. 🎜

Das obige ist der detaillierte Inhalt vonSo implementieren Sie die bidirektionale WebSocket-Kommunikation in Golang. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!