RabbitMQ: 使用 GoLang 連接 RabbitMQ

此文件屬於入門指南指南的一部分。請在此處查看完整指南:如何使用 Stackhero 連接 RabbitMQ

如果您想從 Go 應用程式連接 RabbitMQ,官方的 Go RabbitMQ Client Library 讓流程變得非常簡單。以下是開始步驟:

  1. 建立新目錄並初始化 Go module:
go mod init rabbitmq-example
  1. 接著將 RabbitMQ library 加入您的專案:
go get github.com/rabbitmq/amqp091-go
  1. 現在,建立一個名為 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")
    }
    
  2. 執行您的程式碼:

go run main.go

如果連線成功,您會看到 "Successfully connected to RabbitMQ instance" 訊息。這代表您已透過認證及 TLS 加密安全連線。

如需更進階範例,建議參考 RabbitMQ 官方 repository 的 Go 範例:https://github.com/rabbitmq/rabbitmq-tutorials/tree/main/go