RabbitMQ: GoLang で RabbitMQ に接続する
このドキュメントははじめにガイドの一部です。完全なガイドはこちらからご覧いただけます:Stackhero で RabbitMQ を利用する方法。
Go アプリケーションから RabbitMQ に接続する場合は、公式の Go RabbitMQ Client Library を利用すると簡単です。以下の手順で始められます:
- 新しいディレクトリを作成し、Go モジュールを初期化します:
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 リポジトリの Go サンプルもご参照ください:https://github.com/rabbitmq/rabbitmq-tutorials/tree/main/go。