Golang と RabbitMQ を使用したメッセージ永続性とデータ セキュリティの設計と実装
- WBOYオリジナル
- 2023-09-28 16:45:451306ブラウズ
Golang と RabbitMQ は、メッセージの永続性とデータ セキュリティの設計と実装を実装します。特定のコード例が必要です。
分散システムでは、メッセージ キューが使用されます。一般的に使用される通信モード。 RabbitMQ は、オープン ソースの AMQP (Advanced Message Queuing Protocol) メッセージ ブローカーとして、その安定性と信頼性により、さまざまなアプリケーション シナリオで広く使用されています。この記事では、Golang プログラミング言語と RabbitMQ を使用して、メッセージの永続性とデータ セキュリティの設計と実装を実現します。
1. Golang と RabbitMQ 間の接続
まず、Golang を使用して RabbitMQ に接続し、永続的なメッセージ キューを作成する必要があります。 <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>上記のコードでは、amqp.Dial() 関数を通じて RabbitMQ に接続し、
関数キューを使用して永続メッセージを作成します。
2. メッセージの永続性
次に、メッセージを送受信することでメッセージの永続性を実現します。
メッセージを送信するコードは次のとおりです。 <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>
フラグを設定することで、RabbitMQ の再起動時にメッセージを永続化できます。
メッセージを受信するコードは次のとおりです: <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>上記のコードでは、auto-ack パラメーターを に設定することで受信を自動的に確認します。 true メッセージを取得し、
チャネルを通過してメッセージを取得します。
3. データ セキュリティ
データ セキュリティを確保するために、TLS (Transport Layer Security) を使用して RabbitMQ との接続を暗号化できます。
まず、証明書と秘密キーを生成する必要があります。次のコマンドを使用して生成できます。
openssl req -new -newkey rsa:2048 -days 365 -nodes -x509 -keyout server.key -out server.crt
証明書と秘密キーを作成した後、次のコード スニペットを使用して RabbitMQ に接続できます。 <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>
を使用して RabbitMQ に接続し、TLS 構成を渡します。
Golang プログラミング言語と RabbitMQ を使用することで、メッセージの永続性とデータのセキュリティを実現できます。永続化フラグを設定すると、RabbitMQ の再起動時にメッセージが残り、データのセキュリティを確保するために TLS を使用して接続が暗号化されます。上記のサンプル コードを通じて、Golang と RabbitMQ を使用してメッセージの永続性とデータ セキュリティの設計と実装を実装する方法を理解できます。
###上記は、Golang と RabbitMQ を使用したメッセージ永続性とデータ セキュリティの設計と実装に関する記事です。 ###以上がGolang と RabbitMQ を使用したメッセージ永続性とデータ セキュリティの設計と実装の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。