Go で Websocket を使用してリアルタイム通信を行うにはどうすればよいですか?-Golang-php.cn

Go で Websocket を使用してリアルタイム通信を行うにはどうすればよいですか?

WBOY

リリース： 2023-05-11 16:07:41

オリジナル

1966 人が閲覧しました

Websockets は、Web ブラウザとサーバーの間の双方向通信を確立するテクノロジーで、Web アプリケーションがリアルタイムでクライアントにデータをプッシュできるようにします。たとえば、Websocket を使用してオンラインチャットルームを実装し、ページを更新せずに Web アプリケーションにリアルタイムのチャットコンテンツを直接表示できます。

この記事では、Go 言語で Websocket を使用してリアルタイム通信を行う方法を紹介します。これを実現するには、Gorilla Websockets ライブラリを使用します。このライブラリは、いくつかの非常に便利なユーティリティ関数とサンプルコードを提供します。

1. Gorilla Websocket のインストール

始める前に、Gorilla Websocket をインストールする必要があります。次のコマンドを使用してインストールできます:

go get github.com/gorilla/websocket

ログイン後にコピー

2. Websocket 接続を確立する

次に、Websocket 接続を確立するコードの作成を開始できます。 Websocket 接続を処理するには、HTTP ハンドラー関数を定義する必要があります。以下は簡単なサンプルコードです。

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

ログイン後にコピー

このサンプルコードでは、Websocket 接続を処理する handleWebsocket 関数を定義します。この関数は、Upgrader を使用して、HTTP ハンドラーを Websockets ハンドラーにアップグレードします。 Upgrader は、接続の読み取りおよび書き込みバッファーのサイズを設定するために使用される、ReadBufferSize や WriteBufferSize などのいくつかのパラメーターを定義する構造体です。

関数では、接続からメッセージを読み取り、ターミナルにメッセージを出力して、クライアントに送り返します。読み取りまたは書き込み中にエラーが発生した場合、接続は中断されます。 main 関数では、handleWebsocket 関数を HTTP プロセッサに登録し、HTTP サーバーを起動します。

3. リアルタイム通信に Websocket を使用する

これで、リアルタイム通信に使用できる単純な Websocket プロセッサを作成できました。次に、Websocket 接続をテストできるように、単純な Web アプリケーションを作成しましょう。

<!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>

ログイン後にコピー

このサンプル Web アプリケーションでは、テキスト入力ボックス、送信ボタン、メッセージリストを含むページを作成します。ユーザーがテキストボックスにメッセージを入力し、送信ボタンをクリックすると、Websocket 接続を使用してメッセージがサーバーに送信されます。その後、サーバーはメッセージを送り返し、リストに表示します。新しいメッセージを受信するたびに、新しいリスト項目を作成してリストに追加します。

4. 結論

この記事では、Go で Websocket を使用してリアルタイム通信を行う方法を紹介しました。 Gorilla Websockets ライブラリを使用して Websockets 接続を確立し、接続をテストするための簡単な Web アプリケーションを作成しました。 Websocket は、オンラインチャットルーム、リアルタイムデータ監視およびダッシュボードなど、多くのリアルタイムアプリケーションを実装するために使用できる強力なテクノロジです。この記事がお役に立てば幸いです。

以上がGo で Websocket を使用してリアルタイム通信を行うにはどうすればよいですか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。