GoFrame を使用した WebSocket 通信とハートビートメカニズムの実装: ハンズオンガイド-Golang-php.cn

GoFrame を使用した WebSocket 通信とハートビートメカニズムの実装: ハンズオンガイド

DDD

リリース： 2024-12-19 14:32:09

オリジナル

274 人が閲覧しました

Implementing WebSocket Communication and Heartbeat Mechanism with GoFrame: A Hands-on Guide

現代の Web 開発では、リアルタイム通信がますます重要になっています。 WebSocket は、クライアントとサーバー間の双方向通信を実装するための頼りになるテクノロジとして際立っています。このガイドでは、GoFrame を使用した WebSocket 通信と堅牢なハートビートメカニズムの実装について説明します。

学べること

GoFrame を使用した WebSocket サーバーのセットアップ
クライアント側の WebSocket 通信の実装
WebSocket の同時接続の処理
信頼性の高いハートビートメカニズムの構築
本番環境に対応した WebSocket アプリケーションのベストプラクティス

前提条件

Go プログラミングの基礎知識
GoFrame フレームワークがインストールされました
WebSocket プロトコルの基本の理解

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

基本的な WebSocket サーバーを作成することから始めましょう:

package main

import (
    "github.com/gogf/gf/v2/frame/g"
    "github.com/gogf/gf/v2/net/ghttp"
    "github.com/gogf/gf/v2/os/gctx"
)

func main() {
    ctx := gctx.New()
    s := g.Server()
    s.BindHandler("/ws", func(r *ghttp.Request) {
       ws, err := r.WebSocket()
       if err != nil {
          g.Log().Error(ctx, err)
          return
       }
       defer ws.Close()

       for {
          msgType, msg, err := ws.ReadMessage()
          if err != nil {
             return
          }
          if err = ws.WriteMessage(msgType, msg); err != nil {
             return
          }
       }
    })
    s.SetPort(8399)
    s.Run()
}

ログイン後にコピー

これにより、ポート 8399 でリッスンし、受信したメッセージをエコーバックする単純なエコーサーバーが作成されます。

クライアント側の実装

基本的な HTML/JavaScript クライアントの実装は次のとおりです。

<!DOCTYPE html>
<html>
<head>
    <title>WebSocket Client</title>
</head>
<body>
    <script>
        const socket = new WebSocket('ws://localhost:8399/ws');

        socket.onopen = function(e) {
            console.log('Connection established');
            socket.send('Hello, server!');
        };

        socket.onmessage = function(event) {
            console.log('Message received:', event.data);
        };

        socket.onclose = function(event) {
            console.log('Connection closed');
        };
    </script>
</body>
</html>

ログイン後にコピー

同時接続の処理

実稼働環境では、複数の接続を効率的に処理する必要があります。接続プールを実装する方法は次のとおりです:

import "github.com/gogf/gf/v2/os/gmlock"

var (
    connPool = make(map[string]*ghttp.WebSocket)
    mu       = gmlock.New()
)

func addConn(id string, ws *ghttp.WebSocket) {
    mu.Lock()
    connPool[id] = ws
    mu.Unlock()
}

func removeConn(id string) {
    mu.Lock()
    delete(connPool, id)
    mu.Unlock()
}

func broadcastMessage(ctx context.Context, id string, message []byte) {
    mu.RLock(id)
    defer mu.RUnlock(id)

    for _, ws := range connPool {
       go func(ws *ghttp.WebSocket) {
          if err := ws.WriteMessage(websocket.TextMessage, message); err != nil {
             g.Log().Error(ctx, err)
          }
       }(ws)
    }
}

ログイン後にコピー

ハートビートメカニズムの実装

これは実稼働対応のハートビート実装です:

package main

import (
    "github.com/gogf/gf/v2/frame/g"
    "github.com/gogf/gf/v2/net/ghttp"
    "github.com/gogf/gf/v2/os/gctx"
)

func main() {
    ctx := gctx.New()
    s := g.Server()
    s.BindHandler("/ws", func(r *ghttp.Request) {
       ws, err := r.WebSocket()
       if err != nil {
          g.Log().Error(ctx, err)
          return
       }
       defer ws.Close()

       for {
          msgType, msg, err := ws.ReadMessage()
          if err != nil {
             return
          }
          if err = ws.WriteMessage(msgType, msg); err != nil {
             return
          }
       }
    })
    s.SetPort(8399)
    s.Run()
}

ログイン後にコピー

クライアント側のハートビート処理

<!DOCTYPE html>
<html>
<head>
    <title>WebSocket Client</title>
</head>
<body>
    <script>
        const socket = new WebSocket('ws://localhost:8399/ws');

        socket.onopen = function(e) {
            console.log('Connection established');
            socket.send('Hello, server!');
        };

        socket.onmessage = function(event) {
            console.log('Message received:', event.data);
        };

        socket.onclose = function(event) {
            console.log('Connection closed');
        };
    </script>
</body>
</html>

ログイン後にコピー