Dieser HTML-Client:

• Verbindet mit dem WebSocket-Server unter ws://localhost:8080/ws.
• Sendet Nachrichten, die in das Eingabefeld eingegeben wurden.
• Zeigt eingehende Nachrichten in einem

  var clients = make(map[*websocket.Conn]bool) // Track active clientsfunc handleConnections(w http.ResponseWriter, r *http.Request) {    ws, err := upgrader.Upgrade(w, r, nil)    if err != nil {        fmt.Println(err)        return    }    defer ws.Close()    clients[ws] = true    for {        _, msg, err := ws.ReadMessage()        if err != nil {            fmt.Println(\\\"read error:\\\", err)            delete(clients, ws)            break        }        // Broadcast message to all clients        for client := range clients {            if err := client.WriteMessage(websocket.TextMessage, msg); err != nil {                fmt.Println(\\\"broadcast error:\\\", err)                client.Close()                delete(clients, client)            }        }    }}

  Jetzt wird jede empfangene Nachricht an alle verbundenen Clients gesendet. Dies ist ein gängiger Ansatz für Chat-Anwendungen oder Echtzeit-Updates.

  Mit Verbindungsabbrüchen elegant umgehen

  Um Client-Trennungen zu verarbeiten, verwenden Sie defer ws.Close() und entfernen Sie den Client aus der Client-Zuordnung, wenn der Lesevorgang fehlschlägt.
  

  defer func() {    delete(clients, ws)    ws.Close()}()

  Ping/Pong für Verbindungsgesundheit

  WebSockets unterstützen Ping/Pong-Frames, um die Verbindung aufrechtzuerhalten und zu prüfen, ob der Client noch verbunden ist.
  

  ws.SetPongHandler(func(appData string) error {    fmt.Println(\\\"pong received\\\")    return nil})

  ---

  Best Practices für WebSockets

  1. Verbindungen begrenzen: Schützen Sie Ihren Server vor Überlastung, indem Sie die Anzahl der aktiven Verbindungen begrenzen.
  2. Inaktive Verbindungen schließen: Verwenden Sie Timeouts oder Ping/Pong-Frames, um inaktive Verbindungen zu schließen.
  3. TLS (wss) verwenden: Aus Sicherheitsgründen verwenden Sie in der Produktion immer wss (WebSocket Secure), um die Verbindung zu verschlüsseln.
  4. Fehler ordnungsgemäß behandeln: Überprüfen Sie beim Lesen oder Schreiben in WebSockets stets auf Fehler und protokollieren Sie diese entsprechend.

  ---

  Letzte Gedanken

  WebSockets ermöglichen die Erstellung interaktiver Echtzeitanwendungen, die über herkömmliche Anfrage-/Antwortzyklen hinausgehen. Durch die Einrichtung eines WebSocket-Servers in Go sind Sie jetzt für die problemlose Verarbeitung von Echtzeitdaten gerüstet. Ganz gleich, ob Sie eine Chat-App, ein Live-Dashboard oder ein Tool für die Zusammenarbeit erstellen: Mit WebSockets können Sie nahtlose, interaktive Erlebnisse schaffen.

  Probieren Sie es aus: Richten Sie einen WebSocket-Server ein und beginnen Sie zu experimentieren! Sobald Sie den Dreh raus haben, werden Sie verstehen, warum WebSockets für Echtzeitanwendungen unerlässlich sind.

  ---

  Was ist Ihr Lieblingsanwendungsfall für WebSockets? Lassen Sie es mich in den Kommentaren wissen oder teilen Sie mir Ihre Tipps zum Erstellen von Echtzeitanwendungen mit!

  ","image":"http://www.luping.net/uploads/20241013/1728810388670b8d9479c1a.jpg","datePublished":"2025-01-18T08:50:34+08:00","dateModified":"2025-01-18T08:50:34+08:00","author":{"@type":"Person","name":"luping.net","url":"https://www.luping.net/articlelist/0_1.html"}}
  „Wenn ein Arbeiter seine Arbeit gut machen will, muss er zuerst seine Werkzeuge schärfen.“ – Konfuzius, „Die Gespräche des Konfuzius. Lu Linggong“

  Online-Tools

  Software-Tutorial

  Seitennavigation

  Programmierung
  Titelseite > Programmierung > Verwendung von WebSockets in Go für Echtzeitkommunikation

  Verwendung von WebSockets in Go für Echtzeitkommunikation

  Veröffentlicht am 18.01.2025

  Durchsuche:215

  

  Das Erstellen von Apps, die Echtzeitaktualisierungen erfordern – wie Chat-Anwendungen, Live-Benachrichtigungen oder Tools für die Zusammenarbeit – erfordert eine schnellere und interaktivere Kommunikationsmethode als herkömmliches HTTP. Hier kommen WebSockets ins Spiel! Heute untersuchen wir, wie Sie WebSockets in Go verwenden, damit Sie Ihren Anwendungen Echtzeitfunktionen hinzufügen können.

  In diesem Beitrag behandeln wir:

  • Was WebSockets sind und wie sie funktionieren.
  • Einrichten eines WebSocket-Servers in Go.
  • Einen einfachen WebSocket-Client erstellen.
  • Verwaltung von Ereignissen und Aufrechterhaltung von Verbindungen.

  Lass uns in Echtzeit arbeiten! ?

  ---

  Was sind WebSockets? ?

  WebSockets bieten einen Vollduplex-Kommunikationskanal über eine einzige, langlebige Verbindung. Im Gegensatz zu herkömmlichen HTTP-Anfragen, die einem Anfrage-Antwort-Zyklus folgen, ermöglichen WebSockets dem Server und dem Client, Nachrichten unabhängig voneinander zu senden und zu empfangen, was es ideal für Echtzeitanwendungen macht.

  Hauptmerkmale:

  • Vollduplex-Kommunikation: Sowohl der Client als auch der Server können unabhängig voneinander Nachrichten senden, ohne auf eine Antwort warten zu müssen.
  • Geringe Latenz: WebSockets halten eine dauerhafte Verbindung offen und reduzieren so die Verzögerung zwischen Nachrichten.
  • Ereignisgesteuert: WebSockets verarbeiten Daten als Ereignisse, sodass Sie sofort auf eingehende Nachrichten reagieren können.

  ---

  Einrichten eines WebSocket-Servers in Go

  Um einen WebSocket-Server zu erstellen, verwenden wir das Paket Gorilla WebSocket, das die Arbeit mit WebSockets in Go vereinfacht.

  Schritt 1: Gorilla WebSocket installieren

  Installieren Sie das Paket mit go get:
  

  go get -u github.com/gorilla/websocket
  

  Schritt 2: Erstellen Sie den WebSocket-Server

  Jetzt richten wir einen einfachen WebSocket-Server ein, der auf eingehende Verbindungen lauscht und alle empfangenen Nachrichten zurückgibt:
  

  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)
      }
  }
  

  In diesem Beispiel:

  • Aktualisierung: Wir aktualisieren eine HTTP-Verbindung mithilfe des Upgraders auf eine WebSocket-Verbindung.
  • Lese-/Schreibschleife: Wir treten in eine Schleife ein, in der wir Nachrichten vom Client lesen und sie zurückgeben.

  Hinweis: CheckOrigin im Upgrader lässt alle Verbindungen zu. Stellen Sie in einer Produktionsumgebung sicher, dass Sie den Ursprung validieren, um Cross-Site WebSocket Hijacking zu vermeiden.

  ---

  Einrichten eines einfachen WebSocket-Clients

  Um Ihren WebSocket-Server zu testen, können Sie einen HTML-Client mit JavaScript verwenden, der eine Verbindung zum WebSocket-Server herstellt und Nachrichten sendet/empfängt.

  Beispiel für einen HTML-Client:

  
  
      
      
  
  
      
  WebSocket Client
      
      Send
      
  
  
      
  
  
  

  let socket = new WebSocket("ws://localhost:8080/ws"); socket.onopen = Funktion(Ereignis) { document.getElementById("messages").textContent = "Mit WebSocket-Server verbunden\n"; }; socket.onmessage = Funktion(Ereignis) { document.getElementById("messages").textContent = "Received: " event.data "\n"; }; socket.onclose = Funktion(Ereignis) { document.getElementById("messages").textContent = "Vom WebSocket-Server getrennt\n"; }; Funktion sendMessage() { let message = document.getElementById("messageInput").value; socket.send(message); document.getElementById("messageInput").value = ""; }

  Freigabeerklärung Dieser Artikel ist abgedruckt unter: https://dev.to/neelp03/using-websockets-in-go-for-real-time-communication-4b3l?1 Bei Verstößen wenden Sie sich zum Löschen bitte an [email protected] Es

  Neuestes Tutorial Mehr>

  • 

    Welche Methode ist effizienter für die Erkennung von Punkt-in-Polygon: Strahlenverfolgung oder Matplotlib \ 's path.contains_points?

    effiziente Punkt-in-Polygon-Erkennung in Python festlegen, ob ein Punkt innerhalb eines Polygons eine häufige Aufgabe in der Computergeometrie i...

    Programmierung Gepostet am 2025-03-12
  • 

    Können mehrere klebrige Elemente in reinem CSS übereinander gestapelt werden?

    Ist es möglich, in reinem CSS mehrere klebrige Elemente gestapelt zu haben? Hier: https://webthemez.com/demo/sticky-multi-header-scroll/index.ht...

    Programmierung Gepostet am 2025-03-12
  • 

    Wie setze ich Tasten in JavaScript -Objekten dynamisch ein?

    wie man einen dynamischen Schlüssel für eine JavaScript -Objektvariable erstellt beim Versuch, einen dynamischen Schlüssel für ein JavaScript -O...

    Programmierung Gepostet am 2025-03-12
  • 

    Warum zeigt keine Firefox -Bilder mithilfe der CSS `Content` -Eigenschaft an?

    Bilder mit Inhalts -URL in Firefox Es wurde ein Problem aufgenommen, an dem bestimmte Browser, speziell Firefox, nicht die Bilder mit der Inha...

    Programmierung Gepostet am 2025-03-12
  • 

    Gibt es einen Leistungsunterschied zwischen der Verwendung einer For-Each-Schleife und einem Iterator für die Sammlung durchquert in Java?

    für jede Schleife vs. Iterator: Effizienz in der Sammlung traversal Einführung beim Durchlaufen einer Sammlung in Java, die Auswahl an der...

    Programmierung Gepostet am 2025-03-12
  • 

    Wie beheben Sie die Diskrepanzen für Modulpfade in Go -Mod mithilfe der Richtlinie Ersetzen?

    überwinden Modulpfad -Diskrepanz in go mod Wenn GO mod verwendet wird, ist es möglich, auf einen Konflikt zu begegnen, bei dem ein Drittanbiet...

    Programmierung Gepostet am 2025-03-12
  • 

    \ "während (1) gegen (;;): Beseitigt die Compiler -Optimierung Leistungsunterschiede? \"

    wob führt die Verwendung von (1) statt für (;;) zu einem Leistungsunterschied in Infinite führt Loops? Antwort: In den meisten modernen C...

    Programmierung Gepostet am 2025-03-12
  • 

    Python Read CSV -Datei UnicodEdeCodeError Ultimate Lösung

    unicode dekodieren Fehler in der CSV-Datei Reading Wenn versucht wird, eine CSV-Datei mit dem integrierten CSV-Modul zu lesen, können Sie eine...

    Programmierung Gepostet am 2025-03-12
  • 

    Wie entferte ich anonyme JavaScript -Ereignishandler sauber?

    entfernen anonymer Ereignis -Hörer Hinzufügen von anonymen Ereignishörern zu Elementen bieten Flexibilität und Einfachheit, aber wenn es Zeit is...

    Programmierung Gepostet am 2025-03-12
  • 

    Wie rufe ich die neueste JQuery -Bibliothek von Google APIs ab?

    abrufen die neueste jQuery -Bibliothek von Google apis Die bereitgestellte jQuery -URL in der Frage ist für Version 1.2.6. Für das Abrufen der...

    Programmierung Gepostet am 2025-03-12
  • 

    Warum kann Microsoft Visual C ++ keine zweiphasige Vorlage-Instanziierung korrekt implementieren?

    Das Geheimnis von "kaputte" Two-Phase-Vorlage Instantiation in Microsoft visual c Problemanweisung: Benutzer werden häufig besorgt...

    Programmierung Gepostet am 2025-03-12
  • 

    Was waren die Einschränkungen bei der Verwendung von Current_Timestamp mit Zeitstempelspalten in MySQL vor Version 5.6.5?

    Einschränkungen für Zeitstempelspalten mit Current_Timestamp in Standard- oder Aktualisierungsklauseln in MySQL -Versionen vor 5.6.5 Historisch ...

    Programmierung Gepostet am 2025-03-12
  • 

    Wie überprüfe ich, ob ein Objekt ein spezifisches Attribut in Python hat?

    Methode zur Bestimmung von Objektattribut -Existenz Diese Anfrage befriedigt eine Methode, um das Vorhandensein eines bestimmten Attributs in ...

    Programmierung Gepostet am 2025-03-12
  • 

    Array

    Methoden sind fns, die auf Objekte aufgerufen werden können Arrays sind Objekte, daher haben sie auch Methoden in js. Slice (Beginn): Ex...

    Programmierung Gepostet am 2025-03-12
  • 

    So laden Sie Dateien mit zusätzlichen Parametern mit java.net.urlconnection und Multipart/Form-Data-Codierung hoch?

    Dateien mit Http-Anfragen hochladen , um Dateien auf einen HTTP-Server hochzuladen und gleichzeitig zusätzliche Parameter zu senden. Hier ist e...

    Programmierung Gepostet am 2025-03-12

  EinstufungMehr>

  Japanisch lernen Koreanisch lernen Chinesisch lernen Fremdsprache lernen Spiel Häufiges Problem Technologie-Peripheriegeräte KI Software-Tutorial Programmierung Artikel

  Chinesisch lernen

  • 1 Wie sagt man „gehen“ auf Chinesisch? 走路 Chinesische Aussprache, 走路 Chinesisch lernen
  • 2 Wie sagt man auf Chinesisch „Flugzeug nehmen“? 坐飞机 Chinesische Aussprache, 坐飞机 Chinesisch lernen
  • 3 Wie sagt man auf Chinesisch „einen Zug nehmen“? 坐火车 Chinesische Aussprache, 坐火车 Chinesisch lernen
  • 4 Wie sagt man auf Chinesisch „Bus nehmen“? 坐车 Chinesische Aussprache, 坐车 Chinesisch lernen
  • 5 Wie sagt man „Fahren“ auf Chinesisch? 开车 Chinesische Aussprache, 开车 Chinesisch lernen
  • 6 Wie sagt man Schwimmen auf Chinesisch? 游泳 Chinesische Aussprache, 游泳 Chinesisch lernen
  • 7 Wie sagt man auf Chinesisch „Fahrrad fahren“? 骑自行车 Chinesische Aussprache, 骑自行车 Chinesisch lernen
  • 8 Wie sagt man auf Chinesisch Hallo? 你好Chinesische Aussprache, 你好Chinesisch lernen
  • 9 Wie sagt man „Danke“ auf Chinesisch? 谢谢Chinesische Aussprache, 谢谢Chinesisch lernen
  • 10 How to say goodbye in Chinese? 再见Chinese pronunciation, 再见Chinese learning

  WerkzeugMehr>

  

  Bildbase64-Dekodierung

  

  Chinesisches Pinyin

  

  Unicode-Kodierung

  

  Komprimierung der JS-Verschleierungsverschlüsselung

  

  URL-Hexadezimal-Verschlüsselungstool

  

  Konvertierungstool für UTF-8-Kodierung

  

  Online-Tools zur ASCII-Kodierung und -Dekodierung

  

  MD5-Verschlüsselungstool

  

  Hash/Hash-Text-Online-Verschlüsselungs- und Entschlüsselungstool

  

  Online-SHA-Verschlüsselung

  Haftungsausschluss: Alle bereitgestellten Ressourcen stammen teilweise aus dem Internet. Wenn eine Verletzung Ihres Urheberrechts oder anderer Rechte und Interessen vorliegt, erläutern Sie bitte die detaillierten Gründe und legen Sie einen Nachweis des Urheberrechts oder Ihrer Rechte und Interessen vor und senden Sie ihn dann an die E-Mail-Adresse: [email protected] Wir werden die Angelegenheit so schnell wie möglich für Sie erledigen.

  Copyright© 2022 湘ICP备2022001581号-3