Go言語でRabbitMQを使用する際のベストプラクティス：高パフォーマンスで低遅延なメッセージングを実現

2年 ago
陽, 向宇
1 minute

高いパフォーマンスと短い遅延でのメッセージのやり取りを実現するための、Golang RabbitMQ のベストプラクティスをご紹介します。

  1. 永続メッセージを使用する：メッセージを永続的にマークすれば、RabbitMQサーバーが再起動したときでも、メッセージが失われないようになります。
err := channel.Publish(
"exchange_name",
"routing_key",
true,  // 持久化消息
false, // 不等待确认
amqp.Publishing{
ContentType: "text/plain",
Body:        []byte("Hello RabbitMQ"),
})
  1. 複数の接続とチャネルを活用する：並行性能を高めるために、複数の接続とチャネルを使用できます。各接続とチャネルは一連のメッセージを処理でき、スループットの向上に役立ちます。
connection1, _ := amqp.Dial("amqp://guest:guest@localhost:5672/")
channel1, _ := connection1.Channel()
connection2, _ := amqp.Dial("amqp://guest:guest@localhost:5672/")
channel2, _ := connection2.Channel()
// 使用channel1发送消息
channel1.Publish(...)
// 使用channel2发送消息
channel2.Publish(...)
  1. 確認モードを使用する：確認モードを有効にすると、メッセージがRabbitMQにより確実に受信および処理されることを確認できます。これは、メッセージが確実に届くようになり、同時に遅延が低減することを保証するのに役立ちます。
channel.Confirm(false) // 启用确认模式
ack := channel.NotifyPublish(make(chan amqp.Confirmation, 1))
// 发送消息
err := channel.Publish(...)
// 等待确认
confirmation := <-ack
if !confirmation.Ack {
// 消息未被确认
}
  1. メッセージプリーフェッチを使用します。プリーフェッチを使用すると、コンシューマーのスループットを上げることができます。各コンシューマーがキューからプリーフェッチするメッセージの数を制限することにより、消費速度と負荷分散を効率的に制御できます。
channel.Qos(
1,     // 每个消费者预取的消息数量
0,     // 预取消息大小的限制（0表示无限制）
false, // 应用于整个连接而不仅仅是当前通道
)
  1. 永続化キューおよび交換機を使用する: キューおよび交換機に永続化フラグを立てることで、RabbitMQサーバの再起動後も消失しないようにします。
_, err := channel.QueueDeclare(
"queue_name",
true,  // 持久化队列
false, // 非自动删除队列
false, // 非独占队列
false, // 不使用额外的参数
nil,
)
err = channel.ExchangeDeclare(
"exchange_name",
"direct",
true,  // 持久化交换机
false, // 非自动删除交换机
false, // 不使用内部交换机
false, // 不使用额外的参数
nil,
)
  1. 頻繁なコンシューマー再起動を避ける：コンシューマーの再起動は、コンシューマーがRabbitMQサーバーに再接続することを引き起こすことがあり、パフォーマンスと遅延に影響を与える可能性があります。頻繁なコンシューマーの再起動を避けるために、長時間にわたる接続を使用して接続のオーバーヘッドを低減します。
connection, _ := amqp.Dial("amqp://guest:guest@localhost:5672/")
channel, _ := connection.Channel()
// 持续消费消息
for {
// 消费消息
delivery, _ := channel.Consume(
"queue_name",
"",
false, // 不自动确认消息
false, // 非独占消费者
false, // 不等待确认
false, // 不使用额外的参数
nil,
)
for msg := range delivery {
// 处理消息
processMessage(msg)
// 手动确认消息
_ = msg.Ack(false)
}
}

これらのベストプラクティスはGoにおけるRabbitMQのパフォーマンスを向上させ遅延を減らすことを目的としていますが、実際の効果はアプリケーションや環境によって異なる可能性があります。

bannerAds