Heim Backend-Entwicklung Golang Wie kann ich WebSocket-Verbindungen in Go aufrechterhalten?

Wie kann ich WebSocket-Verbindungen in Go aufrechterhalten?

Nov 02, 2024 pm 01:26 PM

How can I keep WebSocket connections alive in Go?

Aufrechterhaltung von WebSocket-Verbindungen in Go

In Webanwendungen, bei denen Echtzeitkommunikation unerlässlich ist, ist es von entscheidender Bedeutung, sicherzustellen, dass die Verbindung zwischen Der Client und der Server bleiben auch in Zeiten der Inaktivität aktiv. Im Zusammenhang mit dem Websocket-Paket von Go (code.google.com/p/go.net/websocket) kann dieser Mangel an Aktivität dazu führen, dass der Server einen EOF-Fehler zurückgibt und die Verbindung unterbricht.

WebSocket Heartbeat (Ping-Pong)

Das WebSocket-Protokoll enthält einen Heartbeat-Mechanismus, der als Ping-Pong bekannt ist. Dabei wird eine Ping-Nachricht vom Client an den Server gesendet und im Gegenzug eine Pong-Antwort vom Server empfangen. Durch den regelmäßigen Austausch dieser Nachrichten bleibt die Verbindung auch dann bestehen, wenn keine anderen Daten übertragen werden.

Unterstützung im Websocket-Paket von Go

Leider ist der code.google.com Das /p/go.net/websocket-Paket unterstützt den Ping-Pong-Heartbeat-Mechanismus nicht nativ. Daher ist eine alternative Lösung erforderlich, um die Verbindung aufrechtzuerhalten.

Benutzerdefinierte Implementierung

Ein Ansatz besteht darin, einen benutzerdefinierten Heartbeat mithilfe der Kanäle und Timer von Go zu implementieren. Bei dieser Lösung sendet der Client in regelmäßigen Abständen (z. B. alle 5 Sekunden) eine Heartbeat-Nachricht an den Server. Der Server wartet auf diese Heartbeat-Nachrichten und antwortet mit einer Bestätigung. Wenn der Server innerhalb eines bestimmten Timeout-Zeitraums (z. B. 10 Sekunden) keinen Heartbeat empfängt, schließt er die Verbindung.

Hier ist ein Beispiel, wie eine solche benutzerdefinierte Heartbeat-Implementierung mithilfe von Goroutinen erreicht werden könnte:

<code class="go">func startHeartbeat(ws *websocket.Conn, timeout time.Duration) {
    heartbeatTicker := time.NewTicker(timeout)
    defer heartbeatTicker.Stop()

    go func() {
        for {
            select {
            case &lt;-heartbeatTicker.C:
                ws.WriteMessage(websocket.PingMessage, []byte("heartbeat"))
            }
        }
    }()
}

// Server-side:
func handleConnection(ws *websocket.Conn) {
    startHeartbeat(ws, time.Second*10)
    for {
        _, _, err := ws.ReadMessage()
        if err != nil {
            ws.Close()
            break
        }
        // Handle incoming data ...
    }
}</code>
Nach dem Login kopieren

Diese benutzerdefinierte Implementierung stellt sicher, dass ein regelmäßiger Heartbeat zwischen Client und Server aufrechterhalten wird, wodurch verhindert wird, dass die Verbindung abläuft. Alternativ stehen für Go Bibliotheken von Drittanbietern zur Verfügung, die erweiterte Unterstützung für Websocket-Heartbeats bieten, einschließlich der Möglichkeit, automatische Wiederverbindungen und ordnungsgemäße Abschaltungen zu handhaben.

Das obige ist der detaillierte Inhalt vonWie kann ich WebSocket-Verbindungen in Go aufrechterhalten?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Erklärung dieser Website
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn

Heiße Artikel -Tags

Notepad++7.3.1

Notepad++7.3.1

Einfach zu bedienender und kostenloser Code-Editor

SublimeText3 chinesische Version

SublimeText3 chinesische Version

Chinesische Version, sehr einfach zu bedienen

Senden Sie Studio 13.0.1

Senden Sie Studio 13.0.1

Leistungsstarke integrierte PHP-Entwicklungsumgebung

Dreamweaver CS6

Dreamweaver CS6

Visuelle Webentwicklungstools

SublimeText3 Mac-Version

SublimeText3 Mac-Version

Codebearbeitungssoftware auf Gottesniveau (SublimeText3)

GO Language Pack Import: Was ist der Unterschied zwischen Unterstrich und ohne Unterstrich? GO Language Pack Import: Was ist der Unterschied zwischen Unterstrich und ohne Unterstrich? Mar 03, 2025 pm 05:17 PM

GO Language Pack Import: Was ist der Unterschied zwischen Unterstrich und ohne Unterstrich?

Wie schreibe ich Scheinobjekte und Stubs zum Testen in Go? Wie schreibe ich Scheinobjekte und Stubs zum Testen in Go? Mar 10, 2025 pm 05:38 PM

Wie schreibe ich Scheinobjekte und Stubs zum Testen in Go?

Wie kann ich kurzfristige Informationsübertragung zwischen Seiten im BeEGO-Framework implementieren? Wie kann ich kurzfristige Informationsübertragung zwischen Seiten im BeEGO-Framework implementieren? Mar 03, 2025 pm 05:22 PM

Wie kann ich kurzfristige Informationsübertragung zwischen Seiten im BeEGO-Framework implementieren?

Wie kann ich benutzerdefinierte Typ -Einschränkungen für Generika in Go definieren? Wie kann ich benutzerdefinierte Typ -Einschränkungen für Generika in Go definieren? Mar 10, 2025 pm 03:20 PM

Wie kann ich benutzerdefinierte Typ -Einschränkungen für Generika in Go definieren?

Wie kann ich Tracing -Tools verwenden, um den Ausführungsfluss meiner GO -Anwendungen zu verstehen? Wie kann ich Tracing -Tools verwenden, um den Ausführungsfluss meiner GO -Anwendungen zu verstehen? Mar 10, 2025 pm 05:36 PM

Wie kann ich Tracing -Tools verwenden, um den Ausführungsfluss meiner GO -Anwendungen zu verstehen?

Wie schreibe ich Dateien in Go Language bequem? Wie schreibe ich Dateien in Go Language bequem? Mar 03, 2025 pm 05:15 PM

Wie schreibe ich Dateien in Go Language bequem?

Wie kann ich Linter und statische Analyse -Tools verwenden, um die Qualität und Wartbarkeit meines GO -Codes zu verbessern? Wie kann ich Linter und statische Analyse -Tools verwenden, um die Qualität und Wartbarkeit meines GO -Codes zu verbessern? Mar 10, 2025 pm 05:38 PM

Wie kann ich Linter und statische Analyse -Tools verwenden, um die Qualität und Wartbarkeit meines GO -Codes zu verbessern?

Wie konvertieren Sie die Liste der MySQL -Abfrageergebnisse in eine benutzerdefinierte Struktur -Slice in Go -Sprache? Wie konvertieren Sie die Liste der MySQL -Abfrageergebnisse in eine benutzerdefinierte Struktur -Slice in Go -Sprache? Mar 03, 2025 pm 05:18 PM

Wie konvertieren Sie die Liste der MySQL -Abfrageergebnisse in eine benutzerdefinierte Struktur -Slice in Go -Sprache?

See all articles