Golang と RabbitMQ を使用したメッセージ永続性とデータセキュリティの設計と実装-Golang-php.cn

Golang と RabbitMQ を使用したメッセージ永続性とデータセキュリティの設計と実装

WBOY

リリース： 2023-09-28 16:45:45

オリジナル

1312 人が閲覧しました

Golang と RabbitMQ を使用したメッセージ永続性とデータセキュリティの設計と実装

Golang と RabbitMQ は、メッセージの永続性とデータセキュリティの設計と実装を実装します。特定のコード例が必要です。

はじめに:

分散システムでは、メッセージキューが使用されます。一般的に使用される通信モード。 RabbitMQ は、オープンソースの AMQP (Advanced Message Queuing Protocol) メッセージブローカーとして、その安定性と信頼性により、さまざまなアプリケーションシナリオで広く使用されています。この記事では、Golang プログラミング言語と RabbitMQ を使用して、メッセージの永続性とデータセキュリティの設計と実装を実現します。

1. Golang と RabbitMQ 間の接続

まず、Golang を使用して RabbitMQ に接続し、永続的なメッセージキューを作成する必要があります。 <div class="code" style="position:relative; padding:0px; margin:0px;"><pre class='brush:php;toolbar:false;'>package main import ( "log" "github.com/streadway/amqp" ) func failOnError(err error, msg string) { if err != nil { log.Fatalf("%s: %s", msg, err) } } func main() { conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/") failOnError(err, "Failed to connect to RabbitMQ") defer conn.Close() ch, err := conn.Channel() failOnError(err, "Failed to open a channel") defer ch.Close() q, err := ch.QueueDeclare( "my_queue", // queue name true, // durable false, // delete when unused false, // exclusive false, // no-wait nil, // arguments ) failOnError(err, "Failed to declare a queue") }</pre><div class="contentsignin">ログイン後にコピー</div></div>上記のコードでは、amqp.Dial() 関数を通じて RabbitMQ に接続し、

amqp.Dial()

関数キューを使用して永続メッセージを作成します。

2. メッセージの永続性

次に、メッセージを送受信することでメッセージの永続性を実現します。

メッセージを送信するコードは次のとおりです。 <div class="code" style="position:relative; padding:0px; margin:0px;"><pre class='brush:php;toolbar:false;'>// ... err = ch.Publish( "", // exchange q.Name, // routing key false, // mandatory false, // immediate amqp.Publishing{ ContentType: "text/plain", Body: []byte("Hello, RabbitMQ!"), DeliveryMode: amqp.Persistent, // make message persistent }) failOnError(err, "Failed to publish a message")</pre><div class="contentsignin">ログイン後にコピー</div></div>

amqp.Persistent

フラグを設定することで、RabbitMQ の再起動時にメッセージを永続化できます。

メッセージを受信するコードは次のとおりです: <div class="code" style="position:relative; padding:0px; margin:0px;"><pre class='brush:php;toolbar:false;'>// ... msg, err := ch.Consume( q.Name, // queue name "", // consumer true, // auto-ack false, // exclusive false, // no-local false, // no-wait nil, // arguments ) failOnError(err, "Failed to register a consumer") go func() { for d := range msg { log.Printf("Received a message: %s", d.Body) } }() select {}</pre><div class="contentsignin">ログイン後にコピー</div></div>上記のコードでは、auto-ack パラメーターを に設定することで受信を自動的に確認します。 true メッセージを取得し、

msg

チャネルを通過してメッセージを取得します。

3. データセキュリティ

データセキュリティを確保するために、TLS (Transport Layer Security) を使用して RabbitMQ との接続を暗号化できます。

まず、証明書と秘密キーを生成する必要があります。次のコマンドを使用して生成できます。

openssl req -new -newkey rsa:2048 -days 365 -nodes -x509 -keyout server.key -out server.crt

ログイン後にコピー

証明書と秘密キーを作成した後、次のコードスニペットを使用して RabbitMQ に接続できます。 <div class="code" style="position:relative; padding:0px; margin:0px;"><pre class='brush:php;toolbar:false;'>// ... cert, err := tls.LoadX509KeyPair("server.crt", "server.key") failOnError(err, "Failed to load certificates") config := &tls.Config{ Certificates: []tls.Certificate{cert}, } conn, err := amqp.DialTLS("amqps://guest:guest@localhost:5671/", config) failOnError(err, "Failed to connect to RabbitMQ") defer conn.Close() // ...</pre><div class="contentsignin">ログイン後にコピー</div></div>

amqp を設定します。 DialTLS()

を使用して RabbitMQ に接続し、TLS 構成を渡します。

結論:

Golang プログラミング言語と RabbitMQ を使用することで、メッセージの永続性とデータのセキュリティを実現できます。永続化フラグを設定すると、RabbitMQ の再起動時にメッセージが残り、データのセキュリティを確保するために TLS を使用して接続が暗号化されます。上記のサンプルコードを通じて、Golang と RabbitMQ を使用してメッセージの永続性とデータセキュリティの設計と実装を実装する方法を理解できます。

###上記は、Golang と RabbitMQ を使用したメッセージ永続性とデータセキュリティの設計と実装に関する記事です。 ###

以上がGolang と RabbitMQ を使用したメッセージ永続性とデータセキュリティの設計と実装の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。