Golang implementiert die Rabbitmq-Überwachung

Wir wissen, dass die Nachrichtenwarteschlange ein häufig verwendetes Architekturmuster zur Lösung von Problemen wie asynchroner Verarbeitung und Aufgabenverteilung ist, und RabbitMQ ist derzeit eine der am häufigsten verwendeten Nachrichten-Middleware. In praktischen Anwendungen müssen wir möglicherweise Golang verwenden, um die RabbitMQ-Überwachung zu implementieren. In diesem Artikel wird erläutert, wie Golang zur Implementierung der RabbitMQ-Überwachung verwendet wird.

Vorbereitung

Bevor Sie beginnen, müssen Sie sicherstellen, dass RabbitMQ installiert wurde. Da RabbitMQ von Erlang abhängt, muss auch Erlang installiert werden.

Nach Abschluss der Installation müssen wir das Golang-Drittanbieterpaket installieren. Darunter ist das AMQP-Paket unerlässlich, mit dem wir RabbitMQ einfach verbinden und betreiben können.

Holen Sie sich github.com/streadway/amqp

Code-Implementierung

Zuerst müssen wir eine Verbindung zu RabbitMQ herstellen. Nachdem die Verbindung erfolgreich hergestellt wurde, müssen wir einen Austausch mit dem Namen „test“ deklarieren und „fanout“ eingeben. Exchange ist ein wichtiger Teil des Nachrichtenroutings in RabbitMQ. Es ist für den Empfang von Nachrichten und deren Verteilung an Warteschlangen verantwortlich. In diesem Fall deklarieren wir einen Austausch mit dem Namen „test“ und setzen seinen Typ auf „fanout“, was bedeutet, dass er Nachrichten an alle bei ihm abonnierten Warteschlangen sendet.

conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
failOnError(err, "Failed to connect to RabbitMQ")#🎜 🎜#defer conn.Close()

ch, err := conn.Channel()

failOnError(err, "Fehler beim Öffnen eines Kanals")
defer ch.Close ()#?? Als nächstes müssen wir eine neue, nicht persistente Warteschlange mit einem automatisch generierten Namen erstellen. Hier verwenden wir die Namen der Warteschlangen, um sie an den soeben deklarierten „Test“-Austausch zu binden.

q, err := ch.QueueDeclare(

"test",   // name
"fanout", // type
true,     // durable
false,    // auto-deleted
false,    // internal
false,    // no-wait
nil,      // arguments

)

failOnError(err, "Fehler beim Deklarieren einer Warteschlange")
#🎜🎜 #err = ch.QueueBind(

"",    // name
false, // durable
false, // delete when unused
true,  // exclusive
false, // no-wait
nil,   // arguments

)

failOnError(err, „Fehler beim Binden einer Warteschlange“)

Jetzt ist RabbitMQ bereit, wir können beginnen Überwachung seiner Nachrichten. Mit der Consume-Funktion können wir das Abhören von Nachrichten implementieren, wodurch wir kontinuierlich Nachrichten aus der Warteschlange empfangen und verarbeiten können.

msgs, err := ch.Consume(

q.Name, // queue name
"",     // routing key
"test", // exchange
false,
nil,

)

failOnError(err, „Fehler beim Registrieren eines Verbrauchers“)

#🎜🎜 #for msg := range msgs {

q.Name, // queue name
"",     // consumer
true,   // auto-ack
false,  // exclusive
false,  // no-local
false,  // no-wait
nil,    // args

}

Im obigen Code verwenden wir die Methode ch.Consume(), um die Nachrichten in der angegebenen Warteschlange abzuhören und pass Der Nachrichteninhalt wird im Protokollformat ausgegeben. Es ist zu beachten, dass wir zum Bereitstellen der Nachrichtenüberwachung eine Endlosschleife verwenden. Dies bedeutet, dass wir die Warteschlange weiterhin abhören, bis das Programm gestoppt wird oder ein Fehler auftritt.

Der vollständige Code lautet wie folgt:

package main

import (

log.Printf("Received a message: %s", msg.Body)

)

# 🎜🎜# func failOnError(err error, msg string) {

"log"

"github.com/streadway/amqp"

}

func main() {

if err != nil {
    log.Fatalf("%s: %s", msg, err)
}

}

#🎜🎜 #Zusammenfassung

In diesem Artikel wird erläutert, wie Sie mit Golang die Rabbitmq-Überwachung implementieren. Zuerst müssen wir eine Verbindung zu Rabbitmq herstellen, einen Austausch deklarieren, eine Warteschlange erstellen und die Warteschlange an den Austausch binden Verwenden Sie schließlich Verbraucher, um auf Nachrichten in der Warteschlange zu warten. Ich hoffe, dass dieser Artikel für Entwickler hilfreich sein kann, die Golang für die RabbitMQ-Entwicklung verwenden.

Das obige ist der detaillierte Inhalt vonGolang implementiert die Rabbitmq-Überwachung. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!