Woher weiß Rabbitmq, ob die Verbraucherausführung erfolgreich ist?

Szenario: Geben Sie eine Bestellung auf und ziehen Sie den Lagerbestand ab.
Meine Idee ist es, die Aufgaben der Auftragserteilung in die Warteschlange zu stellen und sie einzeln abzuarbeiten, damit beim Abzug des Lagerbestands keine Fehler passieren.
Es ist der Produzent und der Verbraucher
Wenn der Benutzer in der Benutzeroberfläche auf „Bestellung senden“ klickt, wird die Aufgabe in die Warteschlange gestellt und wartet darauf, dass die Warteschlange das Ergebnis der Aufgabe verarbeitet, und die Seite springt basierend darauf das Ergebnis (Erfolg oder Misserfolg)

Aber es gibt ein Problem: Wie kann der Produzent nach der Verarbeitung der Warteschlange über das Ergebnis informiert werden?
Nehmen Sie RabbitMQ als Beispiel. Kann jemand den Code bereitstellen?

Antwortinhalt:

Szenario: Geben Sie eine Bestellung auf und ziehen Sie den Lagerbestand ab.
Meine Idee ist es, die Aufgaben der Auftragserteilung in die Warteschlange zu stellen und sie einzeln abzuarbeiten, damit beim Abzug des Lagerbestands keine Fehler passieren.
Es ist der Produzent und der Verbraucher
Wenn der Benutzer in der Benutzeroberfläche auf „Bestellung senden“ klickt, wird die Aufgabe in die Warteschlange gestellt und wartet darauf, dass die Warteschlange das Ergebnis der Aufgabe verarbeitet, und die Seite springt basierend darauf das Ergebnis (Erfolg oder Misserfolg)

Aber es gibt ein Problem: Wie kann der Produzent nach der Verarbeitung der Warteschlange über das Ergebnis informiert werden?
Nehmen Sie RabbitMQ als Beispiel. Kann jemand den Code bereitstellen?

quene kann nur garantieren, ob die Nachricht angekommen ist oder nicht, insbesondere, ob Ihr Geschäft erfolgreich ausgeführt wurde. Diese Nachrichtenwarteschlange ist nicht garantiert.

Nachdem der Produzent die Nachricht veröffentlicht hat, lauscht er auf eine andere Warteschlange für Antwortnachrichten, z. B. Warteschlange b.
Nachdem der Verbraucher mit dem Konsum fertig ist, wird die Ergebnisnachricht in Warteschlange b verschoben.
Auf diese Weise kann der ursprüngliche Hersteller die zurückgegebenen Ergebnisse erhalten.

Der Mechanismus zur Implementierung von RPC in RabbitMQ ist:

• Wenn der Client eine Anfrage (Nachricht) sendet, legen Sie in den Nachrichteneigenschaften (MessageProperties) zwei Werte „replyTo“ (eine Warteschlange) fest. Im AMQP-Protokoll sind 14 Eigenschaften definiert. Diese Eigenschaften werden zusammen mit gesendet (Nachricht) Name, der verwendet wird, um dem Server mitzuteilen, dass er nach Abschluss der Verarbeitung eine Benachrichtigungsnachricht an diese Warteschlange senden soll) und Korrelations-ID (die Identifikationsnummer dieser Anforderung. Der Server muss dieses Attribut zurückgeben, nachdem die Verarbeitung abgeschlossen ist. Der Client wird dies tun Verstehen Sie, welche Anfrage auf dieser ID basiert. Wurde erfolgreich ausgeführt oder fehlgeschlagen)

• Der Server empfängt die Nachricht und verarbeitet sie

• Nachdem der Server die Nachricht verarbeitet hat, generiert er eine Antwortnachricht an die durch „replyTo“ angegebene Warteschlange mit dem Korrelations-ID-Attribut

• Der Client hat zuvor die durch „replyTo“ angegebene Warteschlange abonniert. Nachdem er die Antwortnachricht vom Server erhalten hat, analysiert er basierend auf dem Korrelations-ID-Attribut, welche Anforderung ausgeführt wurde, und führt die nachfolgende Geschäftsverarbeitung basierend auf den Ausführungsergebnissen durch 🎜>

Es wird darauf hingewiesen, dass der Produzent eine andere ReplyTo-Warteschlange abhört und die entsprechende Antwortnachricht erhält, um nachfolgende Vorgänge auszulösen.