So verwenden Sie die Go-Sprache, um die Aufrechterhaltung einer langen Websocket-Verbindung zu implementieren

So verwenden Sie die Go-Sprache, um die Aufrechterhaltung einer langen Websocket-Verbindung zu implementieren

Websocket ist ein von HTML5 bereitgestelltes Protokoll, das eine bidirektionale Kommunikation zwischen dem Server und dem Client erreichen kann. In der tatsächlichen Entwicklung erfordern viele Szenarien die Aufrechterhaltung langer Verbindungen, um Daten in Echtzeit zu übertragen oder Instant-Messaging-Funktionen zu implementieren. In diesem Artikel wird erläutert, wie Sie mithilfe der Go-Sprache die Wartung langer Websocket-Verbindungen implementieren, einschließlich spezifischer Codebeispiele.

1. Erstellen Sie eine Go-Sprachentwicklungsumgebung
Zuerst müssen wir eine Go-Sprachentwicklungsumgebung erstellen. Informationen zu bestimmten Vorgängen finden Sie in der Installationsanleitung auf der offiziellen Website der Go-Sprache.

2. Erstellen Sie einen WebSocket-Server
Als nächstes beginnen wir mit der Erstellung eines WebSocket-Servers. Zuerst müssen wir die Bibliothek github.com/gorilla/websocket importieren und eine globale Variable upgrader definieren, um die HTTP-Verbindung auf eine WebSocket-Verbindung zu aktualisieren. github.com/gorilla/websocket库，并定义一个全局的upgrader变量，用于升级HTTP连接为WebSocket连接。

import (
    "log"
    "net/http"

    "github.com/gorilla/websocket"
)

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

然后，我们创建一个处理函数wsHandler，处理客户端的WebSocket连接请求。

func wsHandler(w http.ResponseWriter, r *http.Request) {
    // 升级HTTP连接为WebSocket连接
    conn, err := upgrader.Upgrade(w, r, nil)
    if err != nil {
        log.Println(err)
        return
    }

    // 循环读取客户端发送的消息
    for {
        // 读取消息
        msgType, msg, err := conn.ReadMessage()
        if err != nil {
            log.Println(err)
            return
        }

        // 打印消息
        log.Printf("Received: %s
", msg)

        // 响应消息
        err = conn.WriteMessage(msgType, msg)
        if err != nil {
            log.Println(err)
            return
        }
    }
}

三、启动WebSocket服务器
接下来，我们需要将上述wsHandler

func main() {
    http.HandleFunc("/ws", wsHandler) // 注册处理函数
    log.Fatal(http.ListenAndServe(":8000", nil)) // 启动服务器
}

// 创建WebSocket连接
const socket = new WebSocket('ws://localhost:8000/ws');

// 打开连接
socket.addEventListener('open', function (event) {
    socket.send('Hello Server');
});

// 接收消息
socket.addEventListener('message', function (event) {
    console.log('Received: ' + event.data);
});

// 关闭连接
socket.addEventListener('close', function (event) {
    console.log('Connection closed');
});

rrreee

Das obige ist der detaillierte Inhalt vonSo verwenden Sie die Go-Sprache, um die Aufrechterhaltung einer langen Websocket-Verbindung zu implementieren. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!