Tipps zur Behebung der häufigen Unterbrechung der Websocket-Verbindung in der Go-Sprache

Mit der Popularität von Webanwendungen wird WebSocket als eines der am häufigsten verwendeten Kommunikationsprotokolle häufig für die Echtzeitkommunikation zwischen Clients und Servern verwendet. In der Go-Sprache ist gorilla/websocket eine der beliebtesten Bibliotheken von Drittanbietern für die Verwendung von WebSocket. Bei der Verwendung von WebSocket tritt jedoch häufig das Problem häufiger Verbindungsabbrüche auf. Nachfolgend finden Sie einige Tipps zur Lösung dieses Problems sowie zugehörige Go-Codebeispiele. gorilla/websocket 是使用WebSocket的最受欢迎的第三方库之一。但是，通过使用WebSocket时经常会遇到连接频繁断开的问题。解决这个问题的一些技巧，与相关的Go代码示例如下。

1.连接心跳

在WebSocket的使用中，一些因素可能导致连接断开，例如浏览器/客户端网络连接的丢失或服务器端假死。为了解决这些问题，可以使用心跳操作来保持连接。心跳操作专门发送ping消息，以保持WebSocket连接活动状态，并启动goroutine以检测响应。

下面是一个示例代码：

package main

import (
    "log"
    "net/http"
    "time"

    "github.com/gorilla/websocket"
)

var (
    upgrader = websocket.Upgrader{
        ReadBufferSize:  1024,
        WriteBufferSize: 1024,
        CheckOrigin:     func(r *http.Request) bool { return true },
    }
)

func main() {
    http.HandleFunc("/ws", wsHandler)
    log.Fatal(http.ListenAndServe(":8080", nil))
}

func wsHandler(w http.ResponseWriter, r *http.Request) {
    conn, err := upgrader.Upgrade(w, r, nil)
    if err != nil {
        log.Println("upgrade error:", err)
        return
    }
    defer conn.Close()

    heartbeat(conn)
}

func heartbeat(conn *websocket.Conn) {
    ticker := time.NewTicker(10 * time.Second)

    defer ticker.Stop()

    for {
        select {
        case <-ticker.C:
            if err := conn.WriteMessage(websocket.PingMessage, []byte{}); err != nil {
                log.Println("write ping error:", err)
                return
            }
        }
    }
}

在上面的代码中，heartbeat函数启动了一个goroutine，该goroutine每10秒发送ping消息。当一个ping消息发送时，select语句等待500毫秒来接收pong消息。如果未收到pong消息，则断开连接或返回错误。这个例子展示了如何利用心跳来维持WebSocket连接。

2.降低客户端ping请求频率

在某些情况下，频繁发送ping请求也可能会中断WebSocket连接。例如，当WebSocket与公司网络代理一起使用时，代理可能会阻止连续的ping请求。

为了避免这种情况，可以降低ping消息的频率。例如，在下面的代码段中，心跳以10秒为间隔发送ping请求。控制ping频率并适当地调整它可以改善WebSocket连接的稳定性。

func heartbeat(conn *websocket.Conn) {
    ticker := time.NewTicker(10 * time.Second)

    defer ticker.Stop()

    for {
        select {
        case <-ticker.C:
            if err := conn.WriteMessage(websocket.PingMessage, []byte{}); err != nil {
                log.Println("write ping error:", err)
                return
            }
        }
    }
}

3.处理WebSocket关闭

定期检查WebSocket连接是否关闭，可以避免连接断开的情况。可以添加一个defer函数来关闭WebSocket连接，以确保在函数退出之前 WebSocket连接已经被完全关闭。

func wsHandler(w http.ResponseWriter, r *http.Request) {
    conn, err := upgrader.Upgrade(w, r, nil)
    if err != nil {
        log.Println("upgrade error:", err)
        return
    }
    defer conn.Close()

    ticker := time.NewTicker(10 * time.Second)
    defer ticker.Stop()

    for {
        _, _, err := conn.ReadMessage()
        if err != nil {
            log.Println("read error:", err)
            return
        }
    }
}

在上面的代码中，错误检查与conn.ReadMessage()的调用并置。在WebSocket连接中，ReadMessage()会阻塞等待收到的消息，所以我们可以利用无限循环来实现定期检查WebSocket是否已经关闭，以防止进入 错误检查-调用-错误检查-调用

1. Verbindungs-Heartbeat

Bei der Verwendung von WebSocket können einige Faktoren dazu führen, dass die Verbindung getrennt wird, wie z. B. der Verlust der Browser-/Client-Netzwerkverbindung oder die serverseitige angehaltene Animation. Um diese Probleme zu lösen, können Heartbeat-Operationen verwendet werden, um die Verbindung aufrechtzuerhalten. Die Heartbeat-Operation sendet speziell eine Ping-Nachricht, um die WebSocket-Verbindung aufrechtzuerhalten, und startet eine goroutine, um Antworten zu erkennen.

Hier ist ein Beispielcode: 🎜rrreee🎜Im obigen Code startet die Funktion heartbeat alle 10 Sekunden eine Goroutine. Senden Sie eine Ping-Nachricht. Wenn eine Ping-Nachricht gesendet wird, wartet die select-Anweisung 500 Millisekunden auf den Empfang der Pong-Nachricht. Wenn keine Pong-Nachricht empfangen wird, wird die Verbindung getrennt oder ein Fehler zurückgegeben. Dieses Beispiel zeigt, wie Heartbeats verwendet werden, um eine WebSocket-Verbindung aufrechtzuerhalten. 🎜🎜2. Reduzieren Sie die Häufigkeit von Client-Ping-Anfragen🎜🎜In einigen Fällen kann das Senden häufiger Ping-Anfragen auch die WebSocket-Verbindung unterbrechen. Wenn WebSocket beispielsweise mit einem Unternehmensnetzwerk-Proxy verwendet wird, blockiert der Proxy möglicherweise fortlaufende Ping-Anfragen. 🎜🎜Um diese Situation zu vermeiden, können Sie die Häufigkeit von Ping-Nachrichten reduzieren. Im folgenden Snippet sendet Heartbeat beispielsweise Ping-Anfragen in 10-Sekunden-Intervallen. Durch die Steuerung und entsprechende Anpassung der Ping-Frequenz kann die Stabilität von WebSocket-Verbindungen verbessert werden. 🎜rrreee🎜3. WebSocket-Schließung behandeln🎜🎜Überprüfen Sie regelmäßig, ob die WebSocket-Verbindung geschlossen ist, um eine Verbindungsunterbrechung zu vermeiden. Sie können eine defer-Funktion zum Schließen der WebSocket-Verbindung hinzufügen, um sicherzustellen, dass die WebSocket-Verbindung vollständig geschlossen wurde, bevor die Funktion beendet wird. 🎜rrreee🎜Im obigen Code ist die Fehlerprüfung mit dem Aufruf von conn.ReadMessage() verbunden. In einer WebSocket-Verbindung blockiert ReadMessage() das Warten auf empfangene Nachrichten, sodass wir mithilfe einer Endlosschleife regelmäßig prüfen können, ob der WebSocket geschlossen wurde, um die Eingabe des -Fehlers check-call- zu verhindern. Fehler Check-calls Endlosschleife. 🎜🎜Fazit🎜🎜Die oben genannten Tipps können Ihnen helfen, das Problem der häufigen Trennung von WebSocket-Verbindungen zu lösen. Durch die Verwendung des Heartbeat-Mechanismus, die Reduzierung der Ping-Frequenz und die Handhabung des Herunterfahrens von WebSocket kann die Stabilität der WebSocket-Verbindung erheblich verbessert werden, wodurch eine reibungslosere Echtzeitkommunikation mit dem Client gewährleistet wird. 🎜

Das obige ist der detaillierte Inhalt vonTipps zur Behebung der häufigen Unterbrechung der Websocket-Verbindung in der Go-Sprache. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!