GolangでWebSocket双方向通信を実装する方法-Golang-php.cn

GolangでWebSocket双方向通信を実装する方法

WBOY

リリース： 2023-12-18 16:06:42

オリジナル

1307 人が閲覧しました

GolangでWebSocket双方向通信を実装する方法

Golang で WebSocket の双方向通信を実装する方法

WebSocket は、クライアントとサーバーの間に永続的な接続を確立する通信プロトコルです。リアルタイムのパフォーマンスと効率の点で優れたパフォーマンスを発揮します。 Golang では、標準ライブラリの net/http および gorilla/websocket パッケージを使用して、WebSocket 双方向通信を実装できます。この記事では、Golang で WebSocket 双方向通信を実装する方法と具体的なコード例を紹介します。

ステップ 1: 依存関係パッケージをインポートする

まず、net/http および gorilla/websocket パッケージをインポートする必要があります。 net/http パッケージは HTTP サーバーおよびクライアント機能を提供し、gorilla/websocket パッケージは WebSocket 実装ライブラリです。

import (
    "log"
    "net/http"

    "github.com/gorilla/websocket"
)

ログイン後にコピー

ステップ 2: WebSocket 処理関数を設定する

次に、WebSocket 処理関数を設定する必要があります。この関数はクライアントの接続要求を処理し、接続が正常に確立された後にクライアントから送信されたメッセージを処理します。

func websocketHandler(w http.ResponseWriter, r *http.Request) {
    // 将 HTTP 连接升级为 WebSocket 连接
    ws, err := upgrader.Upgrade(w, r, nil)
    if err != nil {
        log.Println("Error upgrading HTTP connection to WebSocket:", err)
        return
    }

    // 在连接结束时关闭 WebSocket
    defer ws.Close()

    // 循环处理客户端发来的消息
    for {
        // 读取客户端发来的消息
        messageType, message, err := ws.ReadMessage()
        if err != nil {
            log.Println("Error reading message from WebSocket:", err)
            break
        }

        // 打印收到的消息
        log.Printf("Received message: %s", message)

        // 回复客户端收到的消息
        if err = ws.WriteMessage(messageType, message); err != nil {
            log.Println("Error writing message to WebSocket:", err)
            break
        }
    }
}

ログイン後にコピー

ステップ 3: WebSocket アップグレーダーを設定する

処理関数では、gorilla/websocket# のアップグレーダー (upgrader) を使用する必要があります。 ## HTTP 接続を WebSocket 接続にアップグレードするパッケージ。アップグレーダーは、許可されたドメインやハンドシェイクタイムアウトなどのいくつかのパラメーターを設定することもできます。

var upgrader = websocket.Upgrader{
    // 允许跨域访问
    CheckOrigin: func(r *http.Request) bool {
        return true
    },
}

ログイン後にコピー

ステップ 4: HTTP サーバーをセットアップする

最後に、クライアントが WebSocket に接続できるように、HTTP サーバーをセットアップし、処理関数を対応するパスにマップする必要があります。パス。コード例の

func main() {
    // 设置 WebSocket 处理函数
    http.HandleFunc("/", websocketHandler)

    // 启动 HTTP 服务器
    err := http.ListenAndServe(":8080", nil)
    if err != nil {
        log.Fatal("Error starting HTTP server:", err)
    }
}

ログイン後にコピー

:8080 は、サーバーのリスニングアドレスとポート番号です。必要に応じて変更できます。

上記のコードを使用して、WebSocket を介した双方向通信の機能を Golang に実装することに成功しました。クライアント接続が成功したら、次のようなコードを使用してメッセージを送受信できます。

const socket = new WebSocket("ws://localhost:8080/");

socket.addEventListener("open", (event) => {
    socket.send("Hello, server!");
});

socket.addEventListener("message", (event) => {
    console.log("Received message from server:", event.data);
});

socket.addEventListener("close", (event) => {
    console.log("Server connection closed:", event);
});

ログイン後にコピー

要約すると、Golang で WebSocket 双方向通信を実装する方法を詳しく紹介し、具体的なコードを提供しました。例。これらのサンプルコードを通じて、WebSocket に基づくリアルタイム通信機能をすぐに開始し、実装することができます。

以上がGolangでWebSocket双方向通信を実装する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。