Heim > Backend-Entwicklung > Golang > Golang implementiert die Rabbitmq-Überwachung

Golang implementiert die Rabbitmq-Überwachung

PHPz
Freigeben: 2023-05-10 10:53:06
Original
614 Leute haben es durchsucht

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
Nach dem Login kopieren

)

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

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

)

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,
Nach dem Login kopieren

)

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
Nach dem Login kopieren

}

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)
Nach dem Login kopieren

)

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

"log"

"github.com/streadway/amqp"
Nach dem Login kopieren

}

func main() {

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

}

#🎜🎜 #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!

Quelle:php.cn
Erklärung dieser Website
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn
Beliebte Tutorials
Mehr>
Neueste Downloads
Mehr>
Web-Effekte
Quellcode der Website
Website-Materialien
Frontend-Vorlage