ホームページ バックエンド開発 Golang Go言語Websocketアプリケーションのスレッドブロック問題を解決する

Go言語Websocketアプリケーションのスレッドブロック問題を解決する

Dec 14, 2023 pm 01:40 PM
言語を移動 websocket スレッドブロックの問題

Go言語Websocketアプリケーションのスレッドブロック問題を解決する

Go 言語 Websocket アプリケーションにおけるスレッド ブロッキング問題の解決

Web アプリケーションを開発する場合、Websocket を使用するのは非常に一般的で一般的な方法です。永続的な接続を確立し、サーバーとクライアントの間でリアルタイムで通信します。ただし、場合によっては、スレッド ブロックの問題が発生し、アプリケーションのパフォーマンスが低下したり、応答しなくなったりする可能性があります。

Go 言語では、ゴルーチンを使用することでノンブロッキングの同時操作を簡単に実現できます。ただし、Websocket 接続を処理するときは注意しないと、スレッド ブロックの問題が発生する可能性があります。この問題を解決する方法をいくつか紹介します。

  1. メッセージ配信にチャネルを使用する

Websocket 接続を処理する場合、多くの場合、複数の接続を同時に処理する必要があります。したがって、接続ごとに goroutine を開始し、チャネルを使用して goroutine 間でメッセージを渡すことができます。

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

type Message struct {

    // 定义消息结构

    ConnID string

    Data   []byte

}

 

type ConnManager struct {

    // 定义连接管理器

    connections map[string]*websocket.Conn

    broadcast   chan Message

}

 

func NewConnManager() *ConnManager {

    // 创建连接管理器

    return &ConnManager{

        connections: make(map[string]*websocket.Conn),

        broadcast:   make(chan Message),

    }

}

 

func (cm *ConnManager) Add(connID string, conn *websocket.Conn) {

    // 添加连接到管理器

    cm.connections[connID] = conn

}

 

func (cm *ConnManager) Remove(connID string) {

    // 从管理器中删除连接

    delete(cm.connections, connID)

}

 

func (cm *ConnManager) Broadcast(msg Message) {

    // 广播消息给所有连接

    for _, conn := range cm.connections {

        conn.WriteMessage(websocket.TextMessage, msg.Data)

    }

}

 

func (cm *ConnManager) Run() {

    // 运行连接管理器

    for {

        select {

        case msg := <-cm.broadcast:

            // 接收广播消息并发送给所有连接

            cm.Broadcast(msg)

        }

    }

}

ログイン後にコピー

上記のコードでは、接続のコレクションとブロードキャスト チャネルを管理する接続マネージャー ConnManager を作成します。各接続はゴルーチンに対応し、接続上にメッセージが到着するかどうかを常に監視します。メッセージが到着すると、そのメッセージはブロードキャスト チャネルに送信され、接続マネージャーはそれをすべての接続にブロードキャストする責任を負います。

  1. バッファリングされたチャネルを使用する

上記のコードでは、ブロードキャスト メッセージがブロックされて送信されます。接続が時間内に処理されない場合、送信者がブロックされる可能性があります。この問題を解決するには、バッファリングされたチャネルを使用します。

1

2

3

4

5

6

7

8

9

10

11

12

type ConnManager struct {

    // ...

    broadcast   chan Message

}

 

func NewConnManager() *ConnManager {

    // ...

    return &ConnManager{

        connections: make(map[string]*websocket.Conn),

        broadcast:   make(chan Message, 10), // 设置channel的缓冲大小

    }

}

ログイン後にコピー

チャネルのバッファ サイズを設定すると、送信者のブロックによって引き起こされるブロックの問題を回避できます。ただし、バッファ サイズの設定が小さすぎると、メッセージが失われる可能性があることに注意してください。

  1. タイムアウト機構を使用する

何らかの理由で接続処理が異常になったり、時間がかかったりする場合がありますが、タイムアウト機構を設定することでスレッドの発生を回避できます。長い間。

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

func (cm *ConnManager) HandleConnection(connID string, conn *websocket.Conn) {

    go func() {

        for {

            messageType, message, err := conn.ReadMessage()

            if err != nil {

                // 处理连接异常

                break

            }

            // 处理消息

            msg := Message{ConnID: connID, Data: message}

            select {

            case cm.broadcast <- msg:

                // 广播消息

            case <-time.After(3 * time.Second):

                // 处理超时

                break

            }

        }

        // 关闭连接

        conn.Close()

        cm.Remove(connID)

    }()

}

 

func main() {

    cm := NewConnManager()

    // ...

}

ログイン後にコピー

上記のコードでは、time.After関数を使用してタイムアウトを設定していますが、指定時間内にブロードキャストチャンネルの受信操作が受信されなかった場合は、タイムアウトが発生したものとみなされます。タイムアウトしました。

概要:

Go 言語 Websocket アプリケーションにおけるスレッド ブロッキングの問題は、メッセージ配信にチャネルを使用し、バッファリングされたチャネルを使用し、タイムアウト メカニズムを設定することで効果的に解決できます。これらの方法により、アプリケーションの同時処理能力とパフォーマンスの安定性が向上し、応答不能を回避できます。

実際のアプリケーションでは、特定のビジネス要件を満たすために、特定のニーズやシナリオに従ってこれらのメソッドを改良し、最適化する必要があることに注意してください。

以上がGo言語Websocketアプリケーションのスレッドブロック問題を解決するの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

このウェブサイトの声明
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。

ホットAIツール

Undresser.AI Undress

Undresser.AI Undress

リアルなヌード写真を作成する AI 搭載アプリ

AI Clothes Remover

AI Clothes Remover

写真から衣服を削除するオンライン AI ツール。

Undress AI Tool

Undress AI Tool

脱衣画像を無料で

Clothoff.io

Clothoff.io

AI衣類リムーバー

AI Hentai Generator

AI Hentai Generator

AIヘンタイを無料で生成します。

ホットツール

メモ帳++7.3.1

メモ帳++7.3.1

使いやすく無料のコードエディター

SublimeText3 中国語版

SublimeText3 中国語版

中国語版、とても使いやすい

ゼンドスタジオ 13.0.1

ゼンドスタジオ 13.0.1

強力な PHP 統合開発環境

ドリームウィーバー CS6

ドリームウィーバー CS6

ビジュアル Web 開発ツール

SublimeText3 Mac版

SublimeText3 Mac版

神レベルのコード編集ソフト(SublimeText3)

golang でリフレクションを使用してプライベート フィールドとメソッドにアクセスする方法 golang でリフレクションを使用してプライベート フィールドとメソッドにアクセスする方法 May 03, 2024 pm 12:15 PM

golang でリフレクションを使用してプライベート フィールドとメソッドにアクセスする方法

golang 関数で新しい関数を動的に作成するためのヒント golang 関数で新しい関数を動的に作成するためのヒント Apr 25, 2024 pm 02:39 PM

golang 関数で新しい関数を動的に作成するためのヒント

Go 言語でのパフォーマンス テストと単体テストの違い Go 言語でのパフォーマンス テストと単体テストの違い May 08, 2024 pm 03:09 PM

Go 言語でのパフォーマンス テストと単体テストの違い

Golang テクノロジーを使用して分散システムを設計する場合、どのような落とし穴に注意する必要がありますか? Golang テクノロジーを使用して分散システムを設計する場合、どのような落とし穴に注意する必要がありますか? May 07, 2024 pm 12:39 PM

Golang テクノロジーを使用して分散システムを設計する場合、どのような落とし穴に注意する必要がありますか?

機械学習で使用される Golang テクノロジー ライブラリとツール 機械学習で使用される Golang テクノロジー ライブラリとツール May 08, 2024 pm 09:42 PM

機械学習で使用される Golang テクノロジー ライブラリとツール

モバイルIoT開発におけるGolangテクノロジーの役割 モバイルIoT開発におけるGolangテクノロジーの役割 May 09, 2024 pm 03:51 PM

モバイルIoT開発におけるGolangテクノロジーの役割

golang 関数の命名規則の進化 golang 関数の命名規則の進化 May 01, 2024 pm 03:24 PM

golang 関数の命名規則の進化

golang 変数パラメータは関数の戻り値に使用できますか? golang 変数パラメータは関数の戻り値に使用できますか? Apr 29, 2024 am 11:33 AM

golang 変数パラメータは関数の戻り値に使用できますか?

See all articles