RabbitMQ: 使用 GoLang 連接 RabbitMQ

本文件是快速開始指南的一部分。請在此處查看完整指南:如何使用 Stackhero 連接 RabbitMQ

若您想從 Go 應用程式連接 RabbitMQ,官方的 Go RabbitMQ Client Library 提供了簡單的方式。以下是開始的步驟:

  1. 建立新目錄並初始化 Go module:
go mod init rabbitmq-example
  1. 接著,將 RabbitMQ 函式庫加入您的專案:
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