RabbitMQ: Mit GoLang eine Verbindung zu RabbitMQ herstellen

Diese Dokumentation ist Teil des Erste Schritte-Leitfadens. Den vollständigen Leitfaden finden Sie hier: Wie Sie Stackhero für RabbitMQ nutzen.

Wenn Sie mit einer Go-Anwendung eine Verbindung zu RabbitMQ herstellen möchten, ist dies mit der offiziellen Go RabbitMQ Client Library sehr einfach. So können Sie starten:

1. Erstellen Sie ein neues Verzeichnis und initialisieren Sie Ihr Go-Modul:

go mod init rabbitmq-example

1. Fügen Sie anschließend die RabbitMQ-Bibliothek zu Ihrem Projekt hinzu:

go get github.com/rabbitmq/amqp091-go

1. Erstellen Sie nun eine Datei mit dem Namen main.go und fügen Sie folgenden Code ein:

   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. Sie können Ihren Code mit folgendem Befehl ausführen:

go run main.go

Wenn die Verbindung erfolgreich ist, sehen Sie die Meldung "Successfully connected to RabbitMQ instance". Das bedeutet, dass Sie sicher mit Authentifizierung und TLS-Verschlüsselung verbunden sind.

Für weiterführende Beispiele empfiehlt sich ein Blick in die Go-Beispiele im offiziellen RabbitMQ-Repository: https://github.com/rabbitmq/rabbitmq-tutorials/tree/main/go.