Go言語でRabbitMQを利用してマルチサービス間のメッセージングとコラボレーションソリューションを構築

2年 ago
陽, 向宇
2 minutes

GoでRabbitMQを使えば、複数のサービス間でメッセージングやコラボレーションの仕組みが構築できます。RabbitMQはオープンソースのメッセージングブローカーであり、パブリッシュ/サブスクライブ、キュー、ルーティングなどの様々なメッセージングパターンをサポートしています。

RabbitMQを利用したサンプル構成で、複数のサービスがメッセージの受け渡しや連携を行う方法を以下で説明します。

  1. RabbitMQのインストール：まず最初に、システム上にRabbitMQをインストールする必要があります。RabbitMQの公式ウェブサイト（https://www.rabbitmq.com/）から、ご使用のOSに対応するバージョンをダウンロードしてインストールすることができます。
  2. RabbitMQのGoクライアントライブラリをインポート：以下のコマンドを使用してRabbitMQのGoクライアントライブラリを取得できます。
go get github.com/streadway/amqp
  1. プロデューササービスを作成する：あなたのサービスの中で、RabbitMQのキューにメッセージを送信するためにプロデューサを作成することができます。 例えば、”my_queue”という名前のキューにメッセージを送信する”producer”という名前のサービスを作成することができます。コードは次のとおりです。
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: %v", err)
}
defer conn.Close()
ch, err := conn.Channel()
if err != nil {
log.Fatalf("Failed to open a channel: %v", err)
}
defer ch.Close()
queue, err := ch.QueueDeclare(
"my_queue",
false,
false,
false,
false,
nil,
)
if err != nil {
log.Fatalf("Failed to declare a queue: %v", err)
}
message := "Hello, RabbitMQ!"
err = ch.Publish(
"",
queue.Name,
false,
false,
amqp.Publishing {
ContentType: "text/plain",
Body:        []byte(message),
},
)
if err != nil {
log.Fatalf("Failed to publish a message: %v", err)
}
fmt.Println("Message sent to RabbitMQ!")
}
  1. RabbitMQのキューからメッセージを取得して処理するためのコンシューマーを別のサービスで作成できます。例えば、”consumer”という名前のサービスを作成して、”my_queue”という名前のキューからのメッセージを受信するコードを以下に示します。
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: %v", err)
}
defer conn.Close()
ch, err := conn.Channel()
if err != nil {
log.Fatalf("Failed to open a channel: %v", err)
}
defer ch.Close()
queue, err := ch.QueueDeclare(
"my_queue",
false,
false,
false,
false,
nil,
)
if err != nil {
log.Fatalf("Failed to declare a queue: %v", err)
}
messages, err := ch.Consume(
queue.Name,
"",
true,
false,
false,
false,
nil,
)
if err != nil {
log.Fatalf("Failed to register a consumer: %v", err)
}
forever := make(chan bool)
go func() {
for message := range messages {
fmt.Printf("Received a message: %s\n", message.Body)
}
}()
fmt.Println("Waiting for messages...")
<-forever
}

「producer」サービスがこの「my_queue」というキューに簡単なメッセージを送信し、「consumer」サービスが同じキューからそのメッセージを受け取って処理する、という構成例です。

このようにすることで、複数のサービス間でメッセージングや協調のシナリオを構築できるようになります。これらのサービスは必要に応じてスケール可能になり、複数のプロデューサーとコンシューマが存在でき、メッセージングや協調には異なるキューを利用できます。

bannerAds