以下是Golang RabbitMQ的一些最佳實踐,以實現高性能和低延遲的消息傳遞:
err := channel.Publish(
"exchange_name",
"routing_key",
true, // 持久化消息
false, // 不等待確認
amqp.Publishing{
ContentType: "text/plain",
Body: []byte("Hello RabbitMQ"),
})
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(...)
channel.Confirm(false) // 啟用確認模式
ack := channel.NotifyPublish(make(chan amqp.Confirmation, 1))
// 發送消息
err := channel.Publish(...)
// 等待確認
confirmation := <-ack
if !confirmation.Ack {
// 消息未被確認
}
channel.Qos(
1, // 每個消費者預取的消息數量
0, // 預取消息大小的限制(0表示無限制)
false, // 應用于整個連接而不僅僅是當前通道
)
_, err := channel.QueueDeclare(
"queue_name",
true, // 持久化隊列
false, // 非自動刪除隊列
false, // 非獨占隊列
false, // 不使用額外的參數
nil,
)
err = channel.ExchangeDeclare(
"exchange_name",
"direct",
true, // 持久化交換機
false, // 非自動刪除交換機
false, // 不使用內部交換機
false, // 不使用額外的參數
nil,
)
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)
}
}
這些最佳實踐旨在提高Golang RabbitMQ的性能和降低延遲,但實際效果可能會因應用和環境的不同