golang で RabbitMq を使用する方法について話しましょう
- PHPzオリジナル
- 2023-04-14 13:33:181160ブラウズ
1. RabbitMq とは
RabbitMq は、信頼性が高く、高速な、オープン ソースのメッセージ キューイング システムです。AMQP (Advanced Message Queuing Protocol) 標準に準拠しており、分散アプリケーション シナリオで広く使用されています。 。
2. RabbitMq を使用する理由
一部のビジネス シナリオでは、メッセージの処理、送信、および保存が非常に重要です。アプリケーション システムの規模が徐々に数百万に達すると、これらのメッセージを効果的に処理する方法が最優先事項になります。 RabbitMq は、メッセージの非同期配信、永続ストレージ、メッセージ キューを介したトラフィックのピーク シェービングをサポートできます。
3. golang で RabbitMq を使用する方法
- RabbitMq のインストール
まず、golang を使用して RabbitMq を実装する前に、RabbitMq をインストールする必要があります。ここでは CentOS システムを使用します。 たとえば、yum を使用してインストールします。
sudo yum install rabbitmq-server
- golang で RabbitMq を使用する
Golang で RabbitMq を使用するには、AMQP ライブラリを使用する必要があります。 go get コマンドを使用して使用できます。 インストールするには:
go get github.com/streadway/amqp
- サンプル コードの実装
以下は、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 サイトの他の関連記事を参照してください。