Go 言語でのメッセージ発行およびサブスクリプションモデル-Golang-php.cn

Go 言語でのメッセージ発行およびサブスクリプションモデル

王林

リリース： 2023-06-01 09:21:29

オリジナル

1445 人が閲覧しました

最新のアプリケーションの継続的な開発と需要の増加に伴い、ますます多くの開発者がメッセージングメカニズムに注目し始めています。この場合、多くの開発者が懸念しているタイプのメッセージモデルがあり、それがメッセージのパブリケーションおよびサブスクリプションモデルです。このモデルは、シンプルかつ効果的な方法でメッセージパッシングを実装しており、分散アーキテクチャで広く使用されています。このモデルでは、Go 言語にも独自の実装方法があります。

この記事では、Go 言語でのメッセージパブリッシングとサブスクリプションモデルを紹介します。これには、Go 言語でチャネルを使用してメッセージパブリッシングとサブスクリプションモデルを実装および使用する方法、および Go 言語キューで単純なメッセージを実装する方法が含まれます。。

1. Go 言語チャネルの概要

チャネルは、Go 言語で同時通信を実現するために使用されるメカニズムです。チャネルは、異なるゴルーチン (コルーチン) 間でデータを転送する方法を提供し、ゴルーチン間の実行を同期するために使用できます。あるゴルーチンから別のゴルーチンにデータを渡すチャネルはスレッドセーフであり、競合状態を回避できます。

Go 言語では、make 関数を使用してチャネルを作成します。 make 関数の構文は次のとおりです。

make(chan T)

ログイン後にコピー

このうち、T はチャネル内の要素の型を表します。たとえば、整数型を配信するチャネルを作成するには、次のコードを使用できます。

ch := make(chan int)

ログイン後にコピー

2. Go 言語でのメッセージパブリッシングとサブスクリプションモデルの実装

メッセージパブリッシングとサブスクリプションモデルの実装Go 言語のサブスクリプションモデル方法は非常に簡単で、Channel を使用するだけです。 Go 言語で推奨されるメッセージパブリッシングおよびサブスクリプションモデルのコード例は次のとおりです。

package main

import (
    "fmt"
)

func main() {
    ch1 := make(chan string)
    ch2 := make(chan string)

    go func() {
        for {
            str := <-ch1
            ch2 <- "go " + str
        }
    }()

    for i := 0; i < 5; i++ {
        ch1 <- fmt.Sprintf("message %d", i)
    }

    for i := 0; i < 5; i++ {
        fmt.Println(<-ch2)
    }
}

ログイン後にコピー

上記のコードブロックは、ch1 と ch2 の 2 つのチャネルを使用します。 ch1 からメッセージを読み取り、文字列に変換して「go」というプレフィックスを付けて、これらの新しいメッセージを ch2 経由で送信するゴルーチンを定義しました。次に、メインの goroutine でいくつかのメッセージを生成して ch1 に送信し、これらの新しいメッセージを ch2 から受信して出力します。この方法は、Go 言語でメッセージパブリッシングモデルとサブスクリプションモデルを実装する一般的な方法です。

3. Go 言語での単純なメッセージキューの実装

Go 言語での単純なメッセージキューの実装も非常に簡単で、Channel と goroutine を使用するだけです。

最初に、キュータイプを定義します。

type Queue struct {
    items []string
    lock  sync.Mutex
    ch    chan bool
}

ログイン後にコピー

このキュータイプには、items、lock、ch という 3 つの重要なメンバー変数があります。このうち、items はメッセージをキューに保存するために使用され、lock はキューの書き込みおよび読み取り操作を保護するために使用され、ch は新しいメッセージが到着したことをキューに通知するために使用されます。通知はブール値をチャネルに送信することで実装されます。

メッセージをキューに追加するメソッドも定義する必要があります。

func (q *Queue) Add(item string) {
    q.lock.Lock()
    defer q.lock.Unlock()

    q.items = append(q.items, item)
    q.ch <- true
}

ログイン後にコピー

このメソッドはスレッドセーフであり、競合状態の発生を回避できます。まずキューのロックを取得し、次にメッセージをキューに追加し、最後にブール値をチャネルに送信します。

キューのメッセージを取得するメソッドも定義する必要があります:

func (q *Queue) Get() (string, bool) {
    q.lock.Lock()
    defer q.lock.Unlock()

    if len(q.items) == 0 {
        return "", false
    }

    item := q.items[0]
    q.items = q.items[1:]

    return item, true
}

ログイン後にコピー

このメソッドもスレッドセーフです。最初にキューのロックを取得し、次にキューがロックされているかどうかを確認します。キューが空の場合は false を返します。それ以外の場合は、キューの先頭からメッセージを取得し、先頭要素を削除して、メッセージと true 値を返します。

このキューを使用するサンプルコードは次のとおりです。

package main

import (
    "fmt"
    "time"
)

func main() {
    q := Queue{
        items: []string{},
        ch:    make(chan bool),
    }

    // 启动一个goroutine更新队列
    go func() {
        for {
            select {
            case <-q.ch:
                for {
                    item, ok := q.Get()
                    if !ok {
                        break
                    }
                    fmt.Println(item)
                }
            }
        }
    }()

    // 向队列中添加一些消息
    for i := 0; i < 5; i++ {
        q.Add(fmt.Sprintf("message %d", i))
        time.Sleep(time.Second)
    }
}

ログイン後にコピー

上記のコードでは、キュータイプの変数 q を定義し、ゴルーチンを開始してそれを更新し、最後にそれを追加します。キューにいくつかのメッセージを追加しました。 goroutine は select ステートメントを使用してチャネルからメッセージ通知を取得し、キュー内のすべてのメッセージを取得して出力します。

概要

Go 言語のメッセージパブリッシングおよびサブスクリプションモデルは非常にシンプルかつ効率的であり、チャネルの使用により自然なスレッドセーフ性を備えています。この記事では、Go 言語でメッセージパブリッシングおよびサブスクリプションモデルを実装する方法と、Go 言語で単純なメッセージキューを実装する方法を紹介します。これらの内容を学習すると、これらを使用してさまざまな非同期処理タスクを実装し、プログラムの同時実行パフォーマンスを向上させることができます。

以上がGo 言語でのメッセージ発行およびサブスクリプションモデルの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。