Mit der Entwicklung des Internets ist die Verwendung von Webanwendungen immer häufiger geworden, wodurch das WebSocket-Protokoll immer beliebter wird. Andererseits hat das schnelle Wachstum von Golang es zu einer beliebten Sprache der Wahl für WebSockets gemacht. In diesem Artikel stellen wir vor, wie man Golang für die WebSocket-Programmierung verwendet.
Was ist WebSocket?
Das WebSocket-Protokoll ist ein bidirektionales Echtzeit-Kommunikationsprotokoll, das Webanwendungen die Interaktion mit Servern ermöglicht. Im Gegensatz zum HTTP-Protokoll ermöglicht das WebSocket-Protokoll dem Server und dem Client jederzeit das Senden und Empfangen von Nachrichten und ermöglicht so eine Echtzeitkommunikation.
Im Allgemeinen verwenden Webanwendungen das WebSocket-Protokoll für den Datenaustausch in Echtzeit, z. B. Online-Chat, Echtzeit-Hotspots, Multiplayer-Spiele usw. Mit WebSockets können Programmierer mit wenig Code eine effiziente Echtzeitkommunikation erreichen.
WebSocket mit Golang implementieren
Golang ist die perfekte Sprache, da sie integrierte RPC- und Socket-Unterstützung bietet. Mit dem net/http-Paket von Golang können wir ganz einfach einen WebSocket-Server erstellen.
import (
"log" "net/http" "github.com/gorilla/websocket"
)
In diesem Schritt erstellen wir den Server zur Verarbeitung von WebSocket-Anfragen. Für jede WebSocket-Verbindung müssen wir einen Handler zum Lesen und Schreiben von Nachrichten erstellen.
func websocketHandler(w http.ResponseWriter, r *http.Request) {
ws, err := websocket.Upgrade(w, r, nil, 1024, 1024) if err != nil { log.Println(err) return } defer ws.Close() for { messageType, p, err := ws.ReadMessage() if err != nil { log.Println(err) break } log.Println(string(p)) err = ws.WriteMessage(messageType, []byte("Server: got your message")) if err != nil { log.Println(err) break } }
}
In diesem Handler aktualisieren wir zunächst die HTTP-Anfrage auf eine WebSocket-Verbindung. Anschließend durchlaufen wir für jede Verbindung eine Schleife, lesen die vom Client gesendete Nachricht und geben die Nachricht in der Konsole aus. Abschließend schreiben wir die Nachricht noch einmal an den Client zurück, um ihm mitzuteilen, dass wir die Nachricht erfolgreich erhalten haben.
Als nächstes müssen wir das Web Socket-Routing zu unserem Server hinzufügen. In diesem Beispiel verwenden wir die Gorilla WebSocket-Bibliothek. Sie können Standardbibliotheksalternativen verwenden – zum Beispiel:
http.HandleFunc("/echo", websocketHandler)
Erfordert manuellen Import der Gorilla WebSocket-Bibliothek:
var upgrader = websocket.Upgrader{
ReadBufferSize: 1024, WriteBufferSize: 1024,
}
http .HandleFunc ("/ws", func(w http.ResponseWriter, r *http.Request) {
// Upgrade the HTTP server connection to a web socket connection ws, err := upgrader.Upgrade(w, r, nil) if err != nil { log.Println(err) return } // ... WebSocket connection logic ...
})
Sobald Ihre Routen eingerichtet sind, können Sie über auf dem Server starten WebSocket-Verbindung:
func main() {
log.Println("Starting server on :8080") http.HandleFunc("/ws", websocketHandler) err := http.ListenAndServe(":8080", nil) log.Fatal(err)
}
Sie können dann den Server starten und den Client verbinden. Öffnen Sie ein neues Terminalfenster und verwenden Sie den Curl-Befehl, um Text über WebSocket an den Server zu senden:
curl -H "Connection: Upgrade" -H "Upgrade: websocket" -H "Host: localhost:8080" -H "Origin: http://localhost:8080" http://localhost:8080/ws -v
Außerdem können Sie zum Testen Online-Tools wie das Chrome-Plug-in Simple WebSocket Client verwenden.
Zusammenfassung
WebSocket ist eine ausgezeichnete Wahl für die Echtzeitkommunikation. Mit der integrierten RPC- und Socket-Unterstützung von Golang können wir ganz einfach einen WebSocket-Server erstellen. In diesem Artikel beschreiben wir die grundlegenden Schritte zum Erstellen eines WebSocket mit Golang. Nachdem Sie nun die Grundlagen von WebSockets in Golang beherrschen, können Sie mit der Erstellung Ihrer eigenen Echtzeitanwendungen beginnen.
Das obige ist der detaillierte Inhalt vonSo verwenden Sie WebSocket in Golang. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!