golang で RabbitMq を使用する方法について話しましょう

1. RabbitMq とは

RabbitMq は、信頼性が高く、高速な、オープン ソースのメッセージ キューイング システムです。AMQP (Advanced Message Queuing Protocol) 標準に準拠しており、分散アプリケーション シナリオで広く使用されています。 。

2. RabbitMq を使用する理由

一部のビジネス シナリオでは、メッセージの処理、送信、および保存が非常に重要です。アプリケーション システムの規模が徐々に数百万に達すると、これらのメッセージを効果的に処理する方法が最優先事項になります。 RabbitMq は、メッセージの非同期配信、永続ストレージ、メッセージ キューを介したトラフィックのピーク シェービングをサポートできます。

3. golang で RabbitMq を使用する方法

1. RabbitMq のインストール

まず、golang を使用して RabbitMq を実装する前に、RabbitMq をインストールする必要があります。ここでは CentOS システムを使用します。 たとえば、yum を使用してインストールします。

sudo yum install rabbitmq-server

2. golang で RabbitMq を使用する

Golang で RabbitMq を使用するには、AMQP ライブラリを使用する必要があります。 go get コマンドを使用して使用できます。 インストールするには:

go get github.com/streadway/amqp

3. サンプル コードの実装

以下は、RabbitMq サーバーに接続して送信する簡単な RabbitMq の例です。キューへの hello 文字列:

package main

import (
    "fmt"
    "log"

    "github.com/streadway/amqp"
)

func main() {
    conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
    if err != nil {
        log.Fatalf("failed to connect to RabbitMQ: %s", err)
    }
    defer conn.Close()

    ch, err := conn.Channel()
    if err != nil {
         log.Fatalf("failed to open a channel: %s", err)
    }
    defer ch.Close()

    q, err := ch.QueueDeclare(
        "hello", // 队列名称
        false,   // 是否持久化
        false,   // 是否自动删除
        false,   // 是否在服务器端独立
        false,   // 是否等待服务器回复
        nil,     // 其他属性
    )
    if err != nil {
        log.Fatalf("failed to declare a queue: %s", err)
    }

    body := "hello"
    err = ch.Publish(
        "",     // 交换机名称
        q.Name, // 队列名称
        false,  // 是否服务器端确认
        false,  // 是否等待服务器回复
        amqp.Publishing {
            ContentType: "text/plain",
            Body:        []byte(body),
        })
    if err != nil {
        log.Fatalf("failed to publish a message: %s", err)
    }

    fmt.Println("Message sent")
}

4. RabbitMq Notes

1. 同時実行セキュリティ

複数のゴルーチンで AMQP クライアント ライブラリを使用することは同時実行安全ではありません。データ競争かも知れません。したがって、各 goroutine で個別の接続、チャネル、パブリッシャ/サブスクライバを使用するか、ロック、ミューテックス、チャネルを通じて応答を取得して待機する必要があります。

2. 永続性

RabbitMq を使用する場合、プログラム例外によるメッセージの損失を避けるために、メッセージの永続性に注意を払う必要があります。同時に、メッセージの信頼性を確保するために、キューとスイッチの永続性にも注意を払う必要があります。

3. フロー制御

同時実行性が高い状況では、RabbitMq サーバーのダウンタイムを回避するために、キューとスイッチのプロパティを適切に設定し、フローの数を適切に制限する必要があります。現在のサーバーの状況に応じて送信されるメッセージ。

5. 結論

RabbitMq を golang に実装することで、分散システム間のメッセージ送信を実現し、結合度を減らし、システムの可用性を向上させるメッセージ キュー サービスを迅速に構築できます。 . そしてスケーラビリティ。同時に、システム内で RabbitMq の利点を最大限に発揮できるように、メッセージの永続性、同時実行性のセキュリティ、トラフィック制限などの問題にも注意を払う必要があります。

以上がgolang で RabbitMq を使用する方法について話しましょうの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。