Go WebSocket はどのようにして負荷分散を実現しますか?

Go での WebSocket ロード バランシングの実装には、WebSocket ハンドラーの作成、HTTP リクエストのアップグレード、および接続の処理、サーバーへのリクエストの割り当てを担当するポーリング ロード バランサーの作成、および使用可能なサーバーの選択へのポーリングが含まれます。

Go WebSocket が負荷分散を実装する方法

負荷分散は、可用性とパフォーマンスを向上させるためにリクエストを複数のサーバーに分散する手段です。負荷分散は、個々のサーバーの過負荷を防ぐため、WebSocket 接続では特に重要です。

ここでは、Go を使用して WebSocket 負荷分散を実装するためのステップバイステップ ガイドを示します:

1. WebSocket ハンドラーを作成します

まず、WebSocket リクエストを処理するプログラムを作成する必要があります。このプログラムは、接続要求とメッセージ交換を処理できます。

import "net/http"

// 升级 HTTP 请求并处理 WebSocket 连接
func WsUpgrade(res http.ResponseWriter, req *http.Request) {
    conn, err := websocket.Upgrade(res, req, nil, 1024, 1024)
    if err != nil {
        http.Error(res, "Could not establish websocket.", http.StatusBadRequest)
        return
    }
    defer conn.Close()

    // 处理 WebSocket 消息
    for {
        // 读取并处理传入的消息
        _, message, err := conn.ReadMessage()
        if err != nil {
            break
        }

        // 向客户端发送消息
        conn.WriteMessage(websocket.TextMessage, []byte("消息已收到："+string(message)))
    }
}

2. ロードバランサーを作成します

ロードバランサーを作成するには、ラウンドロビンアルゴリズムを使用して各リクエストをルーティングするサーバーを決定します。

import "sync"

// 轮训负载均衡器
type RoundRobinBalancer struct {
    lock    sync.Mutex
    servers []*websocket.Conn
    index   int
}

// 添加服务器
func (b *RoundRobinBalancer) AddServer(conn *websocket.Conn) {
    b.lock.Lock()
    defer b.lock.Unlock()
    b.servers = append(b.servers, conn)
}

// 选择服务器
func (b *RoundRobinBalancer) SelectServer() *websocket.Conn {
    b.lock.Lock()
    defer b.lock.Unlock()
    conn := b.servers[b.index]
    b.index = (b.index + 1) % len(b.servers)
    return conn
}

3. ロードバランサーを統合します

次に、ロードバランサーを WebSocket ハンドラーに統合します。

import (
    "net/http"
    "sync"

    "github.com/gorilla/websocket"
)

var (
    balancer = &RoundRobinBalancer{}
    once     sync.Once
)

// 升级 HTTP 请求并处理 WebSocket 连接
func HttpHandler(res http.ResponseWriter, req *http.Request) {
    conn, err := websocket.Upgrade(res, req, nil, 1024, 1024)
    if err != nil {
        http.Error(res, "Could not establish websocket.", http.StatusBadRequest)
        return
    }
    defer conn.Close()

    once.Do(func() {
        go balancer.Run() // 启动负载均衡器
    })

    balancer.AddServer(conn)

    // 启动协程发送数据
    go func() {
        for {
            // 读取并处理传入的消息
            _, message, err := conn.ReadMessage()
            if err != nil {
                break
            }

            conn.WriteMessage(websocket.TextMessage, []byte("消息已收到："+string(message)))
        }
    }()
}

実際的なケース

• デプロイサーバー: Docker または Kubernetes を使用して、複数の WebSocket サーバー インスタンスをデプロイします。
• ロードバランサーを開始します: アプリケーションでロードバランサーコルーチンを開始します。
• WebSocket 接続の確立: クライアントは利用可能なサーバーに接続でき、ロード バランサーはリクエストを現在利用可能なサーバーに自動的にルーティングします。

これらの手順を実装すると、接続数が多い場合でも効率的に実行できる、可用性が高くスケーラブルな WebSocket アプリケーションを作成できます。

以上がGo WebSocket はどのようにして負荷分散を実現しますか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。