RabbitMQ: GoLang で RabbitMQ に接続する

このドキュメントははじめにガイドの一部です。完全なガイドはこちらからご覧いただけます:Stackhero で RabbitMQ を利用する方法

Go アプリケーションから RabbitMQ に接続する場合は、公式の Go RabbitMQ Client Library を利用すると簡単です。以下の手順で始められます:

  1. 新しいディレクトリを作成し、Go モジュールを初期化します:
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 リポジトリの Go サンプルもご参照ください:https://github.com/rabbitmq/rabbitmq-tutorials/tree/main/go