効率的にGo言語を使用してRabbitMQと通信するには？

2年 ago
海斗, 葵
1 minute

効率的にGolangでRabbitMQと通信するには、次の手順に従います。

  1. インストール方法： RabbitMQのオフィシャルサイトからダウンロードしてインストールするか、パッケージマネージャからインストールできます.
  2. GoのRabbitMQクライアントライブラリのインストール: Golangのパッケージマネージャーであるgo modを使用して、インストールできます。ターミナルで以下のコマンドを実行してください: go get github.com/streadway/amqp
  3. Golangコード内でgithub.com/streadway/amqpパッケージをインポートし、提供されるメソッドを使ってRabbitMQへの接続を作成してください。たとえば、
conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
if err != nil {
// 处理连接错误
}
defer conn.Close()
  1. チャンネルを作成します。RabbitMQに接続して、メッセージを送信または受信するチャンネルを作成します。たとえば、
channel, err := conn.Channel()
if err != nil {
// 处理Channel创建错误
}
defer channel.Close()
  1. キューの宣言: チャネルを使用して、メッセージの送信と受信に使用するキューを宣言します。 たとえば、
queue, err := channel.QueueDeclare(
"myQueue", // 队列名称
false,    // 是否持久化
false,    // 是否自动删除
false,    // 是否排他性队列
false,    // 是否非阻塞
nil,      // 额外参数
)
if err != nil {
// 处理队列声明错误
}
  1. メッセージの送信: Channel の Publish メソッドを使用してメッセージをキューに送信します。例:
err = channel.Publish(
"",         // 交换机名称
queue.Name, // 队列名称
false,      // 是否强制
false,      // 是否立即
amqp.Publishing{
ContentType: "text/plain",
Body:        []byte("Hello, RabbitMQ!"),
},
)
if err != nil {
// 处理消息发送错误
}
  1. メッセージを受信するには: ChannelクラスのConsumeメソッドを使ってキューからメッセージを受信します。例:
msgs, err := channel.Consume(
queue.Name, // 队列名称
"",         // 消费者标签
true,       // 是否自动应答
false,      // 是否排他性消费者
false,      // 是否阻塞
false,      // 是否非阻塞
nil,        // 额外参数
)
if err != nil {
// 处理消息接收错误
}
// 在goroutine中循环处理接收到的消息
go func() {
for msg := range msgs {
// 处理接收到的消息
}
}()

上記の手順を実行することで、GolangからRabbitMQと効率的に通信できるようになります。

bannerAds