Heim > Artikel > Backend-Entwicklung > Wie verwende ich Websockets in Go für die Echtzeitkommunikation?

Wie verwende ich Websockets in Go für die Echtzeitkommunikation?

WBOYOriginal: 2023-05-11 16:07:411924Durchsuche

Websockets ist eine Technologie, die eine bidirektionale Kommunikation zwischen einem Webbrowser und einem Server herstellt und es Webanwendungen ermöglicht, Daten in Echtzeit an den Client zu übertragen. Websockets können beispielsweise zur Implementierung eines Online-Chatrooms verwendet werden, der Echtzeit-Chatinhalte direkt in der Webanwendung anzeigt, ohne die Seite zu aktualisieren.

In diesem Artikel stellen wir vor, wie man Websockets in der Go-Sprache für die Echtzeitkommunikation verwendet. Um dies zu erreichen, werden wir die Gorilla Websockets-Bibliothek verwenden. Diese Bibliothek bietet einige sehr praktische Hilfsfunktionen und Beispielcode.

1. Gorilla Websockets installieren

Bevor wir beginnen, müssen wir Gorilla Websockets installieren. Sie können es mit dem folgenden Befehl installieren:

go get github.com/gorilla/websocket

2. Stellen Sie eine Websockets-Verbindung her

Als Nächstes können wir mit dem Schreiben von Code zum Herstellen einer Websockets-Verbindung beginnen. Wir müssen eine HTTP-Handlerfunktion definieren, um Websockets-Verbindungen zu verarbeiten. Hier ist ein einfacher Beispielcode:

package main

import (
    "log"
    "net/http"

    "github.com/gorilla/websocket"
)

var upgrader = websocket.Upgrader{
    ReadBufferSize:  1024,
    WriteBufferSize: 1024,
}

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

    for {
        messageType, p, err := conn.ReadMessage()
        if err != nil {
            log.Println(err)
            return
        }
        log.Printf("received: %s", p)

        err = conn.WriteMessage(messageType, p)
        if err != nil {
            log.Println(err)
            return
        }
    }
}

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

In diesem Beispielcode definieren wir eine handleWebsocket-Funktion, um Websockets-Verbindungen zu verarbeiten. Diese Funktion verwendet Upgrader, um den HTTP-Handler auf den Websockets-Handler zu aktualisieren. Upgrader ist eine Struktur, die einige Parameter definiert, z. B. ReadBufferSize und WriteBufferSize, mit denen die Größe des Lese- und Schreibpuffers der Verbindung festgelegt wird.

In der Funktion lesen wir die Nachricht aus der Verbindung, drucken die Nachricht im Terminal aus und senden sie an den Client zurück. Tritt beim Lesen oder Schreiben ein Fehler auf, wird die Verbindung unterbrochen. In der Hauptfunktion registrieren wir die Funktion handleWebsocket im HTTP-Prozessor und starten den HTTP-Server.

3. Verwenden Sie Websockets für die Echtzeitkommunikation

Jetzt haben wir einen einfachen Websockets-Prozessor geschrieben, den wir für die Echtzeitkommunikation verwenden können. Als Nächstes schreiben wir eine einfache Webanwendung, damit wir unsere Websockets-Verbindung testen können.

<!DOCTYPE html>
<html>
  <head>
    <meta charset="UTF-8">
    <title>Websockets Example</title>
  </head>
  <body>
    <input id="message-input" type="text" placeholder="Type a message...">
    <button id="send-button">Send</button>
    <ul id="message-list"></ul>
    <script>
      const socket = new WebSocket('ws://localhost:8080/ws');
      socket.addEventListener('message', event => {
        const li = document.createElement('li');
        li.textContent = event.data;
        document.querySelector('#message-list').appendChild(li);
      });
      document.querySelector('#send-button').addEventListener('click', () => {
        const input = document.querySelector('#message-input');
        const value = input.value.trim();
        if (value) {
          socket.send(value);
          input.value = '';
        }
      });
    </script>
  </body>
</html>

In dieser Beispiel-Webanwendung erstellen wir eine Seite, die ein Texteingabefeld, eine Schaltfläche zum Senden und eine Nachrichtenliste enthält. Wenn der Benutzer eine Nachricht in das Textfeld eingibt und auf die Schaltfläche „Senden“ klickt, senden wir diese über eine Websockets-Verbindung an den Server. Der Server sendet die Nachricht dann zurück und zeigt sie in der Liste an. Immer wenn wir eine neue Nachricht erhalten, erstellen wir ein neues Listenelement und fügen es der Liste hinzu.

4. Fazit

In diesem Artikel haben wir vorgestellt, wie man Websockets in Go für die Echtzeitkommunikation verwendet. Wir haben die Gorilla Websockets-Bibliothek verwendet, um eine Websockets-Verbindung herzustellen, und eine einfache Webanwendung geschrieben, um unsere Verbindung zu testen. Websockets sind eine leistungsstarke Technologie, mit der viele Echtzeitanwendungen implementiert werden können, z. B. Online-Chatrooms, Echtzeit-Datenüberwachung und Dashboards usw. Ich hoffe, dieser Artikel ist hilfreich für Sie.

Das obige ist der detaillierte Inhalt vonWie verwende ich Websockets in Go für die Echtzeitkommunikation?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

结构体 Go语言 http

Stellungnahme：

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

Vorheriger Artikel：Wie verwende ich XML in Go?Nächster Artikel：Wie verwende ich XML in Go?

In Verbindung stehende Artikel

Mehr sehen