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 官方仓库中的 Go 示例：https://github.com/rabbitmq/rabbitmq-tutorials/tree/main/go。