この HTML クライアント:

• ws://localhost:8080/ws. の WebSocket サーバーに接続
• 入力ボックスに入力されたメッセージを送信します。

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

  これで、メッセージが受信されるたびに、接続されているすべてのクライアントにブロードキャストされます。これは、チャット アプリケーションやリアルタイム更新の一般的なアプローチです。

  切断を適切に処理する

  クライアントの切断を処理するには、defer ws.Close() を使用し、読み取り操作が失敗した場合にクライアント マップからクライアントを削除します。
  

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

  接続状態のピンポン

  WebSocket は、接続を維持し、クライアントがまだ接続されているかどうかを確認するために ping/pong フレームをサポートします。
  

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

  ---

  WebSocket のベスト プラクティス

  1. 接続の制限: アクティブな接続の数を制限することで、サーバーが過負荷になるのを防ぎます。
  2. 非アクティブな接続を閉じる: タイムアウトまたはピンポン フレームを使用して、非アクティブな接続を閉じます。
  3. TLS (wss) を使用する: セキュリティのため、運用環境では常に wss (WebSocket Secure) を使用して接続を暗号化します。
  4. エラーを適切に処理する: WebSocket の読み取りまたは書き込み時にエラーを常にチェックし、適切にログに記録します。

  ---

  最終的な考え

  WebSocket を使用すると、従来の要求/応答サイクルを超えた対話型のリアルタイム アプリケーションを構築できます。 Go で WebSocket サーバーをセットアップすると、リアルタイム データを簡単に処理できるようになります。チャット アプリ、ライブ ダッシュボード、共同作業ツールのいずれを構築している場合でも、WebSocket を使用すると、シームレスでインタラクティブなエクスペリエンスを作成できます。

  試してみる: WebSocket サーバーをセットアップして実験を開始してください。一度コツを掴めば、WebSocket がリアルタイム アプリケーションに不可欠である理由がわかるでしょう。

  ---

  WebSocket のお気に入りの使用例は何ですか? コメントで知らせたり、リアルタイム アプリケーションを構築するためのヒントがあれば共有してください!

  ","image":"http://www.luping.net/uploads/20241013/1728810388670b8d9479c1a.jpg","datePublished":"2024-11-06T23:40:30+08:00","dateModified":"2024-11-06T23:40:30+08:00","author":{"@type":"Person","name":"luping.net","url":"https://www.luping.net/articlelist/0_1.html"}}
  「労働者が自分の仕事をうまくやりたいなら、まず自分の道具を研ぎ澄まさなければなりません。」 - 孔子、「論語。陸霊公」

  オンラインツール

  ソフトウェアチュートリアル

  サイトナビゲーション

  プログラミング
  表紙 > プログラミング > Go で WebSocket を使用してリアルタイム通信を行う

  Go で WebSocket を使用してリアルタイム通信を行う

  2024 年 11 月 6 日に公開

  ブラウズ：710

  

  チャット アプリケーション、ライブ通知、共同作業ツールなど、リアルタイムの更新が必要なアプリを構築するには、従来の HTTP よりも高速でインタラクティブな通信方法が必要です。そこで WebSocket が登場します。今日は、アプリケーションにリアルタイム機能を追加できるように、Go で WebSocket を使用する方法を検討します。

  この投稿では以下について説明します:

  • WebSocket とは何か、そしてその仕組み。
  • Go で WebSocket サーバーをセットアップします。
  • 単純な WebSocket クライアントを作成します。
  • イベントの処理と接続の維持。

  リアルタイムにやってみよう！ ?

  ---

  WebSocketとは何ですか? ?

  WebSocket は、単一の長期間存続する接続を介して全二重通信チャネルを提供します。リクエストとレスポンスのサイクルに従う従来の HTTP リクエストとは異なり、WebSocket を使用すると、サーバーとクライアントがメッセージを個別に送受信できるため、リアルタイム アプリケーションに最適です。

  主な特徴:

  • 全二重通信: クライアントとサーバーの両方が、応答を待たずに独立してメッセージを送信できます。
  • 低遅延: WebSocket は永続的な接続を開いたままにし、メッセージ間の遅延を短縮します。
  • イベント駆動型: WebSocket はデータをイベントとして処理し、受信メッセージに即座に反応できるようにします。

  ---

  Go での WebSocket サーバーのセットアップ

  WebSocket サーバーを作成するには、Gorilla WebSocket パッケージを使用します。これにより、Go で WebSocket を簡単に操作できるようになります。

  ステップ 1: Gorilla WebSocket をインストールする

  go get を使用してパッケージをインストールします:
  

  go get -u github.com/gorilla/websocket
  

  ステップ 2: WebSocket サーバーを作成する

  次に、受信接続をリッスンし、受信したメッセージをエコーバックする単純な WebSocket サーバーをセットアップしましょう。
  

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

  この例では:

  • アップグレード: Upgrader を使用して HTTP 接続を WebSocket 接続にアップグレードします。
  • 読み取り/書き込みループ: クライアントからのメッセージを読み取り、エコーバックするループに入ります。

  注: Upgrader の CheckOrigin ではすべての接続が許可されます。運用環境では、クロスサイト WebSocket ハイジャックを回避するために、オリジンを必ず検証してください。

  ---

  単純な WebSocket クライアントのセットアップ

  WebSocket サーバーをテストするには、JavaScript で HTML クライアントを使用し、WebSocket サーバーに接続してメッセージを送受信します。

  HTML クライアントの例:

  
  
      
  WebSocket Client
      Send
      
  
  
      

  letsocket = new WebSocket("ws://localhost:8080/ws"); ソケット.onopen = 関数(イベント) { document.getElementById("messages").textContent = "WebSocket サーバーに接続しました\n"; }; ソケット.onmessage = 関数(イベント) { document.getElementById("messages").textContent = "受信しました: "event.data "\n"; }; ソケット.onclose = 関数(イベント) { document.getElementById("messages").textContent = "WebSocket サーバーから切断されました\n"; }; 関数 sendMessage() { let message = document.getElementById("messageInput").value; ソケット.send(メッセージ); document.getElementById("messageInput").value = ""; }

  リリースステートメント この記事は次の場所に転載されています: https://dev.to/neelp03/using-websockets-in-go-for-real-time-communication-4b3l?1 侵害がある場合は、削除するために[email protected]に連絡してください。それ

  最新のチュートリアル もっと>

  • 

    キーが 1 つしかないのに、MySQL エラー 1022: 「書き込めません。テーブル内のキーが重複しています。」が発生するのはなぜですか?

    プログラミング 2024 年 11 月 7 日に公開
  • 

    Amazonのレビューを購入する

    https://dmhelpshop.com/product/buy-amazon-reviews/ Amazon レビューを購入 コマースや Amazon での商品販売に関しては、レビューの重要性はどれだけ強調してもしすぎることはありません。たった 1 つのレビューが購入の成否を左右するため、潜在...

    プログラミング 2024 年 11 月 7 日に公開
  • 

    DTO を使用して Laravel でのデータ転送を簡素化する

    Laravel Dataを使用してデータ転送オブジェクト (DTO) を作成する方法のステップバイステップの例を示します: 1. Laravel データパッケージをインストールします まず、Composer を使用して spatie/laravel-data パッケージをインストール...

    プログラミング 2024 年 11 月 7 日に公開
  • 

    Go でソース ファイルに関連するファイルを見つけるにはどうすればよいですか?

    Go でのソース ファイルに関連するファイルの検索インタープリタ型言語とは異なり、Go プログラムはコンパイルされるため、実行にソース ファイルは必要ありません。したがって、Ruby の __FILE__ に見られる、ソース ファイルを基準にしてファイルを配置するという概念は、Go には適用できませ...

    プログラミング 2024 年 11 月 7 日に公開
  • 

    Python で項目の出現を効率的にカウントするにはどうすればよいですか?

    効率が向上した Python の項目頻度カウントリスト内の項目の出現回数をカウントすることは、一般的なプログラミング タスクです。この質問では、Python でこの問題に対するより効率的なアプローチを検討します。提示された最初のコードは機能しますが、リストを 2 回反復する必要があるため、最適なパフ...

    プログラミング 2024 年 11 月 7 日に公開
  • 

    非同期ディープグラム API の探索: Python を使用した Speech-to-Text

    今日は、音声をテキストに変換するための Deepgram API [文字起こし] について説明します。音声アシスタントの構築、会議の文字起こし、音声制御アプリの作成など、Deepgram を使用すると、これまでよりも簡単に始めることができます。 ディープグラムとは何ですか？ Deep...

    プログラミング 2024 年 11 月 7 日に公開
  • 

    PHP JSON エンコーディングで不正な UTF-8 文字を処理するにはどうすればよいですか?

    PHP JSON エンコーディングでの不正な UTF-8 文字の処理json_encode() を使用してロシア語の文字を含む配列をシリアル化すると、次のような問題が発生する可能性があります。不正な UTF-8 文字に関連するエラー。この問題を解決するには、次の手順を実行します。ステップ 1: 文字...

    プログラミング 2024 年 11 月 7 日に公開
  • 

    Java 認定試験で Var を利用するための ips

    Java 認定試験では、ローカル変数の型推論での var の使用など、言語とそのさまざまな機能を深く理解する必要があります。これは細かいことのように思えるかもしれませんが、コードの読みやすさと効率に大きな影響を与える可能性があります。 Java 認定試験に合格するために、コード内で var を利用す...

    プログラミング 2024 年 11 月 7 日に公開
  • 

    (愚かな) ストーリー ジェネレーターを作成して状態管理を学びます (Modulo.js を学ぶ - パート f)

    ?おかえり！パート 1 を理解できませんでしたか?心配はいりません。最初から始めることも、ここからいきなり始めることもできます。 導入: SillyStory Web コンポーネント このチュートリアルのタスクは、ストーリー生成コンポーネントを構築することです。これにより、State...

    プログラミング 2024 年 11 月 7 日に公開
  • 

    次の行を取得 ファイル記述子とシステムの I/O の処理方法を学ぶためのプロジェクト

    C プログラミングの分野では、入力、出力、メモリを効果的に管理することが基本です。これらの重要な概念を理解するのに役立つように、get_next_line は、ファイル記述子を使用してファイルを 1 行ずつ読み取る関数を作成するプロジェクトです。関数を呼び出すたびにファイルから次の行が読み取られるた...

    プログラミング 2024 年 11 月 7 日に公開
  • 

    Go の main 関数に無限ループがあるのはなぜですか?

    Go ランタイム: Main 関数の無限ループの謎Go のランタイムの中心には src/runtime/proc.go があります。ここには不可解な機能が存在します。それは、main 関数の最後にある無限の for ループです。なぜこのような一見無意味な構造がランタイムに存在するのか不思議に思う人も...

    プログラミング 2024 年 11 月 7 日に公開
  • 

    iostream と iostream.h: 最新の C++ ではどちらを使用する必要がありますか?

    iostream と iostream.h の違いC では、プログラマは、同様の目的を果たす 2 つの用語、 iostream と iostream.h に遭遇することがあります。 。このガイドは、この 2 つの基本的な違いを明確にすることを目的としています。iostream.h: 非推奨のレガシ...

    プログラミング 2024 年 11 月 7 日に公開
  • 

    VLONE Clothing: アーバン ファッションを再定義するストリートウェア ブランド

    VLONE は、急速に変化する市場においてストリートウェア業界が生み出すあらゆるものを超える成果を上げた数少ないブランドの一例です。集団 A$AP Mob 内の映画制作者の 1 人である A$AP Bari によって設立された VLONE は、ニッチなプロジェクトに成長し、時には都市ファッションにお...

    プログラミング 2024 年 11 月 7 日に公開
  • 

    PDO を使用して単一行の単一列をクエリするにはどうすればよいですか?

    PDO を使用した単一行の単一列のクエリ単一行の特定の列をターゲットとする SQL クエリを処理する場合、多くの場合、ループを必要とせずに直接値を取得します。 PDO でこれを実現するには、 fetchColumn() メソッドが便利です。fetchColumn() の構文は次のとおりです:$col...

    プログラミング 2024 年 11 月 7 日に公開
  • 

    PeerSplit を構築した方法: 無料のピアツーピア経費分割アプリ - アイデアから立ち上げまでわずか数週間で完了

    私は、Splitwise の無料のピアツーピア代替手段である PeerSplit を、アイデアから立ち上げまでわずか 2 週間で構築しました。 PeerSplit は、グループの費用を分割するためのローカルファーストのアプリです。オフラインで動作し、完全に無料かつプライベートであり、サインアップや個...

    プログラミング 2024 年 11 月 7 日に公開

  分類もっと>

  日本語を学ぶ 韓国語を学ぶ 中国語を学びます 外国語を学ぶ ゲーム よくある問題 テクノロジー周辺機器 AI ソフトウェアチュートリアル プログラミング 記事

  中国語を勉強する

  • 1 「歩く」は中国語で何と言いますか？ 走路 中国語の発音、走路 中国語学習
  • 2 「飛行機に乗る」は中国語で何と言いますか？ 坐飞机 中国語の発音、坐飞机 中国語学習
  • 3 「電車に乗る」は中国語で何と言いますか？ 坐火车 中国語の発音、坐火车 中国語学習
  • 4 「バスに乗る」は中国語で何と言いますか？ 坐车 中国語の発音、坐车 中国語学習
  • 5 中国語でドライブは何と言うでしょう？ 开车 中国語の発音、开车 中国語学習
  • 6 水泳は中国語で何と言うでしょう？ 游泳 中国語の発音、游泳 中国語学習
  • 7 中国語で自転車に乗るってなんて言うの？ 骑自行车 中国語の発音、骑自行车 中国語学習
  • 8 中国語で挨拶はなんて言うの？ 你好中国語の発音、你好中国語学習
  • 9 中国語でありがとうってなんて言うの？ 谢谢中国語の発音、谢谢中国語学習
  • 10 How to say goodbye in Chinese? 再见Chinese pronunciation, 再见Chinese learning

  道具もっと>

  

  画像のbase64デコード

  

  中国語のピンイン

  

  Unicodeエンコーディング

  

  JS難読化暗号化圧縮

  

  URL 16 進暗号化ツール

  

  UTF-8エンコード変換ツール

  

  オンラインの Ascii エンコードおよびデコード ツール

  

  MD5暗号化ツール

  

  ハッシュ/ハッシュ テキストのオンライン暗号化および復号化ツール

  

  オンライン SHA 暗号化

  免責事項: 提供されるすべてのリソースの一部はインターネットからのものです。お客様の著作権またはその他の権利および利益の侵害がある場合は、詳細な理由を説明し、著作権または権利および利益の証拠を提出して、電子メール [email protected] に送信してください。 できるだけ早く対応させていただきます。

  Copyright© 2022 湘ICP备2022001581号-3