RabbitMQ: 使用 GoLang 連接 RabbitMQ
本文件是快速開始指南的一部分。請在此處查看完整指南:如何使用 Stackhero 連接 RabbitMQ。
若您想從 Go 應用程式連接 RabbitMQ,官方的 Go RabbitMQ Client Library 提供了簡單的方式。以下是開始的步驟:
- 建立新目錄並初始化 Go module:
go mod init rabbitmq-example
- 接著,將 RabbitMQ 函式庫加入您的專案:
go get github.com/rabbitmq/amqp091-go
-
現在,建立一個名為
main.go的檔案並加入以下程式碼:package main import ( "fmt" amqp "github.com/rabbitmq/amqp091-go" ) func main() { connection, err := amqp.Dial("amqps://<PASSWORD>@<XXXXXX>.stackhero-network.com:<AMQP_PORT_TLS>") if err != nil { panic(err) } defer connection.Close() fmt.Println("Successfully connected to RabbitMQ instance") } -
使用以下指令執行您的程式:
go run main.go
若連線成功,您會看到訊息 "Successfully connected to RabbitMQ instance"。這表示您已透過驗證與 TLS 加密安全連線。
如需更進階的範例,建議參考 RabbitMQ 官方 repository 的 Go 範例:https://github.com/rabbitmq/rabbitmq-tutorials/tree/main/go。