GoとRabbitMQで複数のサービス間で非同期通信を実装しています

2年 ago
芽依, 雨夜
1 minute

Go言語とRabbitMQを利用した複数サービ間での非同期通信を実現するには、以下の手順に従う必要があります。

  1. RabbitMQのインストール：最初に、RabbitMQメッセージブローカーサーバーをインストールする必要があります。RabbitMQの公式サイトからあなたのシステムに合ったインストーラーをダウンロードし、公式ドキュメントに従ってインストールすることができます。
  2. RabbitMQクライアントライブラリの導入：Goプロジェクトでは、RabbitMQのクライアントライブラリをインポートする必要があります。最も一般的なライブラリはgithub.com/streadway/amqpで、Goモジュール管理ツールを使用してインポートできます。以下のコマンドでインポートできます。
go get github.com/streadway/amqp
  1. RabbitMQへの接続を作成する：Golangコードでは、RabbitMQクライアントライブラリを使用してRabbitMQサーバーへの接続を作成する必要があります。RabbitMQサーバーのアドレス、ユーザー名、およびパスワードを指定する必要があります。以下にサンプルコードを示します。
package main
import (
"log"
"github.com/streadway/amqp"
)
func main() {
// 创建RabbitMQ连接
conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
if err != nil {
log.Fatalf("Failed to connect to RabbitMQ: %v", err)
}
defer conn.Close()
// 程序继续执行...
}
  1. メッセージキューの作成：RabbitMQクライアントライブラリを使用すると、メッセージキュー(エクスチェンジとも呼ばれます)を作成できます。メッセージキューはコンシューマにメッセージを配信するために使用されます。以下にサンプルコードを示します。
// 创建一个名为"myqueue"的消息队列
ch, err := conn.Channel()
if err != nil {
log.Fatalf("Failed to open a channel: %v", err)
}
defer ch.Close()
q, err := ch.QueueDeclare(
"myqueue", // 队列名称
false,     // 是否持久化
false,     // 是否自动删除
false,     // 是否排他性队列
false,     // 是否等待服务器确认
nil,       // 额外的属性
)
if err != nil {
log.Fatalf("Failed to declare a queue: %v", err)
}
// 程序继续执行...
  1. メッセージをパブリッシュするには、RabbitMQ クライアントライブラリを使用してメッセージキューにメッセージをパブリッシュできます。サンプルコードを以下に示します。
// 发布一条消息到"myqueue"队列
body := []byte("Hello, RabbitMQ!")
err = ch.Publish(
"",      // 交换机名称
q.Name,  // 队列名称
false,   // 是否等待服务器确认
false,   // 是否强制发布消息
amqp.Publishing{
ContentType: "text/plain",
Body:        body,
})
if err != nil {
log.Fatalf("Failed to publish a message: %v", err)
}
  1. RabbitMQ クライアントライブラリを使用するとコンシューマを作成してメッセージを受信できます。以下にサンプルコードを示します。
// 创建一个消费者
msgs, err := ch.Consume(
q.Name, // 队列名称
"",     // 消费者名称（留空表示随机生成名称）
true,   // 是否自动应答（即处理完消息后自动发送确认消息给RabbitMQ）
false,  // 是否排他性消费者
false,  // 是否等待服务器确认
false,  // 额外的参数
)
if err != nil {
log.Fatalf("Failed to register a consumer: %v", err)
}
// 开始接收消息
go func() {
for d := range msgs {
log.Printf("Received a message: %s", d.Body)
}
}()
// 程序继续执行...

GoでRabbitMQを利用して、複数のサービス間の非同期通信を実現するための基本的な手順は以上です。実際のニーズに応じて調整と拡張を行ってください。

bannerAds