RabbitMQ - Senden Sie Daten an einen anderen Verbraucher

Question

Ich bin ein Neophyt mit RabbitMQ verwenden. Ich möchte wissen, ob es möglich ist, Daten von einem Verbraucher zu einem anderen zu senden.

Lassen Sie mich erklären,

Ich möchte die Pipeline pattern zu meiner Anwendung Rohrklassen Ausführung implementieren.

Beispiel:

// payload = 20 (at the entrance) 
$pipeline = (new Pipeline) 
    ->pipe(function ($payload) { 
     return $payload * 10; 
    }) 
    ->pipe(function ($payload) { 
     return $payload + 10; 
    }) 
    ->pipe(function ($payload) { 
     return $payload - 5; 
    }) 
; 
// payload = 205 (at the end) 

Was ich tun möchte, ist die erste Rückruf in einem Verbraucher auszuführen, wenn es fertig ist die berechneten Daten an die anderen Verbraucher senden und so weiter. Um schließlich 205 als Wert für $payload zu haben.

Ich will nur wissen, ob es möglich ist, das mit RabbitMQ zu tun?

Vielen Dank viel für Ihre Antworten, :)

Answer 1

natürlich Ja. Ein rabbitmq-Client wäre gleichzeitig Verbraucher und Publisher, wobei jede der "Funktionalitäten" in zwei unabhängigen Threads und jeder von ihnen einen eigenen Kanal verwenden würde.

Bitte beachten Sie auch, dass Sie niemals eine Nachricht direkt an einen Kunden senden, sondern an eine Vermittlungsstelle, die die Nachricht (auf bestimmte Arten) an Warteschlangen weiterleitet, die an sie gebunden sind. Verbraucher "hängen" sich an Warteschlangen an und konsumieren von ihnen.