要連接到 RabbitMQ 集群,可以使用以下方法:
package main
import (
"fmt"
"github.com/streadway/amqp"
)
func main() {
// 連接配置
configs := []string{
"amqp://user:password@node1:5672",
"amqp://user:password@node2:5672",
"amqp://user:password@node3:5672",
}
// 創建連接
conn, err := amqp.Dial(configs[0])
if err != nil {
fmt.Println("Failed to connect to RabbitMQ:", err)
return
}
defer conn.Close()
// 其他操作...
}
在上面的示例中,我們創建了一個包含多個 RabbitMQ 連接配置的切片。然后,我們使用第一個連接配置來創建一個連接。如果連接失敗,可以嘗試使用其他連接配置。
package main
import (
"fmt"
"github.com/streadway/amqp"
)
func main() {
// 連接配置(只指定一個節點)
config := "amqp://user:password@node1:5672"
// 創建連接
conn, err := amqp.Dial(config)
if err != nil {
fmt.Println("Failed to connect to RabbitMQ:", err)
return
}
defer conn.Close()
// 創建通道
ch, err := conn.Channel()
if err != nil {
fmt.Println("Failed to open a channel:", err)
return
}
defer ch.Close()
// 其他操作...
}
在上面的示例中,我們只指定了一個節點的連接配置。然后,我們使用該配置創建一個連接。然后,我們使用該連接創建一個通道。RabbitMQ 集群會自動路由消息到可用的節點上。