RabbitMQ: 使用 GoLang 連接 RabbitMQ
此文件屬於入門指南指南的一部分。請在此處查看完整指南:如何使用 Stackhero 連接 RabbitMQ。
如果您想從 Go 應用程式連接 RabbitMQ,官方的 Go RabbitMQ Client Library 讓流程變得非常簡單。以下是開始步驟:
- 建立新目錄並初始化 Go module:
go mod init rabbitmq-example
- 接著將 RabbitMQ library 加入您的專案:
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。